Package | Description |
---|---|
com.gigaspaces.async |
Provides GigaSpaces asynchronous operations related interfaces.
|
com.gigaspaces.async.internal | |
com.gigaspaces.internal.client.spaceproxy.executors | |
com.gigaspaces.internal.cluster.node.impl.replica | |
com.gigaspaces.internal.remoting.routing.clustered | |
com.gigaspaces.internal.space.actions | |
com.gigaspaces.internal.space.requests | |
org.openspaces.core.executor.internal | |
org.openspaces.core.executor.juc | |
org.openspaces.core.executor.support | |
org.openspaces.core.transaction.internal | |
org.openspaces.events.support | |
org.openspaces.remoting |
A package including OpenSpaces support for Sync and Async remoting inspired by other Spring remoting
integrations.
|
Modifier and Type | Method and Description |
---|---|
AsyncResult<T> |
AsyncResultFilterEvent.getCurrentResult()
Returns the current result that caused this event.
|
AsyncResult<T>[] |
AsyncResultFilterEvent.getReceivedResults()
Returns the received results without the current result.
|
Modifier and Type | Method and Description |
---|---|
void |
AsyncFutureListener.onResult(AsyncResult<T> result)
A callback when a result of an async invocation arrives.
|
Modifier and Type | Method and Description |
---|---|
R |
AsyncResultsReducer.reduce(List<AsyncResult<T>> results) |
Constructor and Description |
---|
AsyncResultFilterEvent(AsyncResult<T> currentResult,
AsyncResult<T>[] receivedResults,
int totalExpectedResults)
Constructs a new async result filter event
|
AsyncResultFilterEvent(AsyncResult<T> currentResult,
AsyncResult<T>[] receivedResults,
int totalExpectedResults)
Constructs a new async result filter event
|
Modifier and Type | Class and Description |
---|---|
class |
DefaultAsyncResult<T>
Default container for async result
|
Modifier and Type | Method and Description |
---|---|
void |
CompoundFuture.onResult(AsyncResult<T> result) |
Modifier and Type | Method and Description |
---|---|
AddReplicationGatewayTargetResponseInfo |
AddReplicationGatewayTargetTask.reduce(List<AsyncResult<AddReplicationGatewayTargetResponseInfo>> results) |
AddTypeIndexesResult |
AddTypeIndexesTask.reduce(List<AsyncResult<AddTypeIndexesResult>> results) |
GetTypeDescriptorActionInfo |
GetTypeDescriptorTask.reduce(List<AsyncResult<GetTypeDescriptorActionInfo>> results) |
RegisterTypeDescriptorResponseInfo |
RegisterTypeDescriptorTask.reduce(List<AsyncResult<RegisterTypeDescriptorResponseInfo>> results) |
RemoveReplicationGatewayTargetResponseInfo |
RemoveReplicationGatewayTargetTask.reduce(List<AsyncResult<RemoveReplicationGatewayTargetResponseInfo>> results) |
Modifier and Type | Method and Description |
---|---|
void |
SpaceCopyReplicaRunnable.onResult(AsyncResult<Collection<ISpaceReplicaData>> result) |
Modifier and Type | Method and Description |
---|---|
void |
ClusterRemoteOperationRouter.AsyncOperationExecutor.onResult(AsyncResult<T> asyncResult) |
Modifier and Type | Method and Description |
---|---|
GetTypeDescriptorActionInfo |
GetTypeDescriptorActionInfo.reduce(List<AsyncResult<GetTypeDescriptorActionInfo>> results) |
Modifier and Type | Method and Description |
---|---|
AddTypeIndexesResult |
AddTypeIndexesRequestInfo.reduce(List<AsyncResult<AddTypeIndexesResult>> results) |
RegisterReplicationLocalViewResponseInfo |
RegisterReplicationLocalViewRequestInfo.reduce(List<AsyncResult<RegisterReplicationLocalViewResponseInfo>> results) |
RegisterReplicationNotificationResponseInfo |
RegisterReplicationNotificationRequestInfo.reduce(List<AsyncResult<RegisterReplicationNotificationResponseInfo>> results) |
RegisterTypeDescriptorResponseInfo |
RegisterTypeDescriptorRequestInfo.reduce(List<AsyncResult<RegisterTypeDescriptorResponseInfo>> results) |
RegisterReplicationNotificationResponseInfo |
UnregisterReplicationNotificationRequestInfo.reduce(List<AsyncResult<SpaceResponseInfo>> results) |
RegisterReplicationLocalViewResponseInfo |
UnregisterReplicationLocalViewRequestInfo.reduce(List<AsyncResult<SpaceResponseInfo>> results) |
Modifier and Type | Method and Description |
---|---|
R |
InternalDistributedSpaceTaskWrapper.reduce(List<AsyncResult<T>> asyncResults) |
Modifier and Type | Method and Description |
---|---|
R |
CallableDistributedTaskAdapter.reduce(List<AsyncResult<T>> results)
Delegates the call to the provided reducer.
|
R |
RunnableDistributedTaskAdapter.reduce(List<AsyncResult<T>> results)
Delegates the call to the provided reducer.
|
Modifier and Type | Method and Description |
---|---|
void |
WaitForAllListener.onResult(AsyncResult<T> result) |
void |
WaitForAnyListener.onResult(AsyncResult<T> result) |
Modifier and Type | Method and Description |
---|---|
R |
SumReducer.reduce(List<AsyncResult<T>> results) |
T |
MinReducer.reduce(List<AsyncResult<T>> results) |
R |
AvgTask.reduce(List<AsyncResult<T>> results)
Performs the actual sum operation by delegating to its internal
SumReducer . |
T |
MinTask.reduce(List<AsyncResult<T>> results)
Performs the actual sum operation by delegating to its internal
SumReducer . |
T |
MaxTask.reduce(List<AsyncResult<T>> results)
Performs the actual sum operation by delegating to its internal
SumReducer . |
R |
PrivilegedDistributedTask.reduce(List<AsyncResult<T>> results)
Reduces the provided task under access controls.
|
R |
AvgReducer.reduce(List<AsyncResult<T>> results) |
T |
MaxReducer.reduce(List<AsyncResult<T>> results) |
R |
SimpleDelegatingDistributedTask.reduce(List<AsyncResult<T>> asyncResults) |
R |
SumTask.reduce(List<AsyncResult<T>> results)
Performs the actual sum operation by delegating to its internal
SumReducer . |
Constructor and Description |
---|
AsyncResultFuture(AsyncResult<T> result) |
Modifier and Type | Method and Description |
---|---|
void |
TransactionalAsyncFutureListener.onPostCommitTransaction(AsyncResult<T> asyncResult) |
void |
TransactionalAsyncFutureListener.onPostRollbackTransaction(AsyncResult<T> asyncResult) |
void |
InternalAsyncFutureListener.onResult(AsyncResult<T> asyncResult) |
void |
TransactionalAsyncFutureListener.onTransactionalResult(AsyncResult<T> asyncResult,
org.springframework.transaction.TransactionStatus txStatus) |
Modifier and Type | Method and Description |
---|---|
Boolean |
UnregisterDistributedEventContainerTask.reduce(List<AsyncResult<Boolean>> results) |
Object |
RegisterDistributedEventContainerTask.reduce(List<AsyncResult<Serializable>> asyncResults) |
Modifier and Type | Method and Description |
---|---|
List<AsyncResult<ExecutorRemotingTask.InternalExecutorResult<T>>> |
ExecutorRemotingTask.reduce(List<AsyncResult<ExecutorRemotingTask.InternalExecutorResult<T>>> results) |
Modifier and Type | Method and Description |
---|---|
List<AsyncResult<ExecutorRemotingTask.InternalExecutorResult<T>>> |
ExecutorRemotingTask.reduce(List<AsyncResult<ExecutorRemotingTask.InternalExecutorResult<T>>> results) |
Copyright © GigaSpaces.