Package | Description |
---|---|
com.gigaspaces.dih.consumer.web | |
com.gigaspaces.persistency.archive | |
org.openspaces.admin.internal.pu.scale_horizontal | |
org.openspaces.admin.internal.pu.scale_horizontal.steps | |
org.openspaces.admin.internal.space |
Internally Used.
|
org.openspaces.admin.space |
Support for managing of Space(s) through the Admin API.
|
org.openspaces.archive | |
org.openspaces.core |
Top level core package holding main OpenSpaces API for Space (GigaSpace) and Map (GigaMap) and
the ability to create it.
|
org.openspaces.core.context |
Allowing to inject configured GigaSpace instances within Spring application context using annotations.
|
org.openspaces.core.executor | |
org.openspaces.core.executor.juc | |
org.openspaces.core.internal | |
org.openspaces.core.space |
This package is responsible for simplifying the creation of IJSpace implementation.
|
org.openspaces.core.space.mode |
A package exposing Space mode (primary/backup) events through Spring application event
support.
|
org.openspaces.core.space.support | |
org.openspaces.core.transaction.internal | |
org.openspaces.events |
A package including based classes and support classes for different OpenSpaces event containers.
|
org.openspaces.events.adapter |
A package including adapter implementation of SpaceDataEventListener allowing to use either
annotation or method listing to listen for events generated by different event containers.
|
org.openspaces.events.asyncpolling | |
org.openspaces.events.asyncpolling.receive | |
org.openspaces.events.notify |
A notify event container allowing to use GigaSpace support for notifications.
|
org.openspaces.events.polling |
A polling event container generating events by performing polling receive operations.
|
org.openspaces.events.polling.receive |
An abstraction on top of the actual receive operation performed by the polling event container.
|
org.openspaces.events.polling.trigger |
An abstraction on top of the trigger operation performed before the initiation of transactional receive
operation.
|
org.openspaces.events.support | |
org.openspaces.extensions | |
org.openspaces.jdbc.datasource |
Implementations of Jdbc DataSource interface using GigaSpaces support for Jdbc based on an
actual IJSpace or GigaSpace implementation.
|
org.openspaces.persistency.cassandra.archive | |
org.openspaces.persistency.space | |
org.openspaces.pu.container.jee.jetty.session | |
org.openspaces.remoting |
A package including OpenSpaces support for Sync and Async remoting inspired by other Spring remoting
integrations.
|
org.openspaces.remoting.scripting | |
org.openspaces.rest.utils |
Modifier and Type | Field and Description |
---|---|
protected GigaSpace |
PipelineConsumerServlet.gigaSpace |
Modifier and Type | Method and Description |
---|---|
protected abstract GigaSpace |
PipelineConsumerServlet.getSpace(javax.servlet.ServletContext servletContext,
String spaceName)
Should resolve Space using ServletContext defined in the pu.xml, else it will resolve it manually from the spaceName
|
Modifier and Type | Method and Description |
---|---|
void |
GSConsumerHandler.init(GigaSpace gigaSpace,
String puName,
ConsumerConfiguration consumerConfigFromZK) |
protected abstract void |
PipelineConsumerServlet.registerTypes(GigaSpace gigaSpace) |
Modifier and Type | Method and Description |
---|---|
GigaSpace |
MongoArchiveOperationHandler.getGigaSpace() |
Modifier and Type | Method and Description |
---|---|
MongoArchiveOperationHandlerConfigurer |
MongoArchiveOperationHandlerConfigurer.gigaSpace(GigaSpace gigaSpace) |
void |
MongoArchiveOperationHandler.setGigaSpace(GigaSpace gigaSpace) |
Modifier and Type | Method and Description |
---|---|
protected static GigaSpace |
DynamicPartitionProxy.createProxy(ProcessingUnitInstance instance,
String spaceName,
QuiesceToken quiesceToken) |
GigaSpace |
DynamicPartitionProxy.getProxy(QuiesceToken quiesceToken) |
Modifier and Type | Method and Description |
---|---|
default boolean |
IStepOperation.checkIfStepIsCompleted(DefaultProcessingUnit pu,
AttributeStore attributeStore,
String stepName,
GigaSpace gigaSpace,
InternalAdminDriver driver) |
void |
DrainStep.executePerInstance(DefaultProcessingUnit pu,
AttributeStore attributeStore,
GigaSpace gigaSpace,
int partitionId) |
void |
CopyChunksStep.executePerInstance(DefaultProcessingUnit pu,
AttributeStore attributeStore,
GigaSpace gigaSpace,
int partitionId) |
default void |
IStepOperation.executePerInstance(DefaultProcessingUnit pu,
AttributeStore attributeStore,
GigaSpace gigaSpace,
int partitionId) |
void |
DeleteChunksStep.executePerInstance(DefaultProcessingUnit pu,
AttributeStore attributeStore,
GigaSpace gigaSpace,
int partitionId) |
void |
KillInstancesStep.executeStepOperation(DefaultProcessingUnit pu,
AttributeStore attributeStore,
GigaSpace gigaSpace,
InternalAdminDriver driver,
long timeout) |
void |
RevertTopologyStep.executeStepOperation(DefaultProcessingUnit pu,
AttributeStore attributeStore,
GigaSpace gigaSpace,
InternalAdminDriver driver,
long timeout) |
void |
InformTopologyChangeStep.executeStepOperation(DefaultProcessingUnit pu,
AttributeStore attributeStore,
GigaSpace gigaSpace,
InternalAdminDriver driver,
long timeout) |
void |
UnquiesceOnRollbackStep.executeStepOperation(DefaultProcessingUnit pu,
AttributeStore attributeStore,
GigaSpace gigaSpace,
InternalAdminDriver driver,
long timeout) |
void |
DrainStep.executeStepOperation(DefaultProcessingUnit pu,
AttributeStore attributeStore,
GigaSpace gigaSpace,
InternalAdminDriver driver,
long timeout) |
void |
CreateNewTopologyStep.executeStepOperation(DefaultProcessingUnit pu,
AttributeStore attributeStore,
GigaSpace gigaSpace,
InternalAdminDriver driver,
long timeout) |
void |
TriggerInstancesInitiationStep.executeStepOperation(DefaultProcessingUnit pu,
AttributeStore attributeStore,
GigaSpace gigaSpace,
InternalAdminDriver driver,
long timeout) |
void |
UnquiesceStep.executeStepOperation(DefaultProcessingUnit pu,
AttributeStore attributeStore,
GigaSpace gigaSpace,
InternalAdminDriver driver,
long timeout) |
void |
CopyChunksStep.executeStepOperation(DefaultProcessingUnit pu,
AttributeStore attributeStore,
GigaSpace gigaSpace,
InternalAdminDriver driver,
long timeout) |
void |
RevertPuMetaDataStep.executeStepOperation(DefaultProcessingUnit pu,
AttributeStore attributeStore,
GigaSpace gigaSpace,
InternalAdminDriver driver,
long timeout) |
void |
QuiesceStep.executeStepOperation(DefaultProcessingUnit pu,
AttributeStore attributeStore,
GigaSpace gigaSpace,
InternalAdminDriver driver,
long timeout) |
void |
SetNewTopologyStep.executeStepOperation(DefaultProcessingUnit pu,
AttributeStore attributeStore,
GigaSpace gigaSpace,
InternalAdminDriver driver,
long timeout) |
void |
IStepOperation.executeStepOperation(DefaultProcessingUnit pu,
AttributeStore attributeStore,
GigaSpace gigaSpace,
InternalAdminDriver driver,
long timeout) |
void |
DeleteChunksStep.executeStepOperation(DefaultProcessingUnit pu,
AttributeStore attributeStore,
GigaSpace gigaSpace,
InternalAdminDriver driver,
long timeout) |
default void |
IStepOperation.executeTaskRequest(GigaSpace gigaSpace,
AttributeStore attributeStore,
SystemTask<SpaceResponseInfo> task,
Step step,
String puName,
int partitionId) |
Modifier and Type | Method and Description |
---|---|
GigaSpace |
DefaultSpaceInstance.getGigaSpace() |
GigaSpace |
DefaultSpace.getGigaSpace() |
Modifier and Type | Method and Description |
---|---|
GigaSpace |
SpaceInstance.getGigaSpace()
Returns the direct proxy to the actual space instance.
|
GigaSpace |
Space.getGigaSpace()
Returns the clustered view of the space to operate on.
|
Modifier and Type | Method and Description |
---|---|
void |
ArchivePollingContainer.onEvent(Object data,
GigaSpace gigaSpace,
org.springframework.transaction.TransactionStatus txStatus,
Object source) |
void |
DefaultArchivePollingContainerExceptionHandler.onException(ListenerExecutionFailedException exception,
Object data,
GigaSpace gigaSpace,
org.springframework.transaction.TransactionStatus txStatus,
Object source)
This is the default handler if
#setExceptionHandler(EventExceptionHandler) was not
called. |
void |
DefaultArchivePollingContainerExceptionHandler.onSuccess(Object data,
GigaSpace gigaSpace,
org.springframework.transaction.TransactionStatus txStatus,
Object source)
This is the default handler if
#setExceptionHandler(EventExceptionHandler) was not
called. |
Constructor and Description |
---|
ArchivePollingContainerConfigurer(GigaSpace gigaSpace) |
Modifier and Type | Class and Description |
---|---|
class |
DefaultGigaSpace
Default implementation of
GigaSpace . |
Modifier and Type | Method and Description |
---|---|
GigaSpace |
GigaSpaceConfigurer.create()
Creates a new
GigaSpace instance if non already created. |
GigaSpace |
DefaultGigaSpace.getClustered() |
GigaSpace |
GigaSpace.getClustered()
Returns a clustered view of this
GigaSpace instance. |
protected GigaSpace |
GigaSpaceConfigurer.getGigaSpaceIfInitialized() |
GigaSpace |
GigaSpaceConfigurer.gigaSpace()
Creates a new
GigaSpace instance if non already created. |
Modifier and Type | Method and Description |
---|---|
Class<? extends GigaSpace> |
GigaSpaceFactoryBean.getObjectType() |
Modifier and Type | Method and Description |
---|---|
protected GigaSpace |
GigaSpaceContextBeanPostProcessor.findGigaSpaceByName(String gsName) |
protected GigaSpace |
GigaSpaceLateContextBeanFactoryPostProcessor.findGigaSpaceByName(String gsName) |
Modifier and Type | Method and Description |
---|---|
static TaskExecutorService |
TaskExecutors.newExecutorService(GigaSpace gigaSpace)
Constructs a new
DefaultTaskExecutorService which is
an executor service that can execute tasks on top of the Space. |
void |
TaskGigaSpaceAware.setGigaSpace(GigaSpace gigaSpace)
Injects the space the task is executed on.
|
Constructor and Description |
---|
DefaultTaskExecutorService(GigaSpace gigaSpace) |
Modifier and Type | Interface and Description |
---|---|
interface |
InternalGigaSpace
An internal API of
GigaSpace |
Modifier and Type | Method and Description |
---|---|
void |
RestBean.setGigaSpace(GigaSpace gigaSpace) |
Modifier and Type | Method and Description |
---|---|
void |
SpaceModeContextLoader.setGigaSpace(GigaSpace gigaSpace)
Allows to set the GigaSpace instance that will control (based on its Space mode - PRIMARY or
BACKUP) if the context will be loaded or not.
|
Modifier and Type | Method and Description |
---|---|
void |
SpaceDocumentWrapperJavaClassGenerator.generate(GigaSpace gigaSpace,
String className)
Generate the Java files of all the classes extending this className;
|
void |
WorkerAdapter.setGigaSpace(GigaSpace gigaSpace)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
static <T> AsyncFutureListener<T> |
InternalAsyncFutureListener.wrapIfNeeded(AsyncFutureListener<T> listener,
GigaSpace gigaSpace) |
Constructor and Description |
---|
InternalAsyncFuture(AsyncFuture<T> future,
GigaSpace gigaSpace) |
InternalAsyncFuture(AsyncFuture<T> future,
GigaSpace gigaSpace,
Transaction tx) |
InternalAsyncFutureListener(GigaSpace gigaSpace,
AsyncFutureListener<T> listener) |
InternalAsyncFutureListener(GigaSpace gigaSpace,
AsyncFutureListener<T> listener,
org.springframework.transaction.TransactionStatus txStatus,
org.springframework.transaction.PlatformTransactionManager transactionManager,
JiniTransactionHolder holder) |
Modifier and Type | Method and Description |
---|---|
GigaSpace |
AbstractEventListenerContainer.getGigaSpace()
Returns the GigaSpace instance to be used for Space operations.
|
Modifier and Type | Method and Description |
---|---|
void |
SpaceDataEventListener.onEvent(T data,
GigaSpace gigaSpace,
org.springframework.transaction.TransactionStatus txStatus,
Object source)
An event callback with the actual data object of the event.
|
void |
EventExceptionHandler.onException(ListenerExecutionFailedException exception,
T data,
GigaSpace gigaSpace,
org.springframework.transaction.TransactionStatus txStatus,
Object source)
A callback to handle exception in an event container.
|
void |
EventExceptionHandler.onSuccess(T data,
GigaSpace gigaSpace,
org.springframework.transaction.TransactionStatus txStatus,
Object source)
A callback when a successful execution of a listener.
|
void |
AbstractEventListenerContainer.setGigaSpace(GigaSpace gigaSpace)
Sets the GigaSpace instance to be used for space event listening operations.
|
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractResultEventListenerAdapter.handleResult(Object result,
GigaSpace gigaSpace)
Writes the result back to the space (if not
null ) under the configured write
lease. |
void |
AbstractResultEventListenerAdapter.onEvent(Object data,
GigaSpace gigaSpace,
org.springframework.transaction.TransactionStatus txStatus,
Object source)
Implements the
SpaceDataEventListener by delegating to AbstractResultEventListenerAdapter.onEventWithResult(Object, org.openspaces.core.GigaSpace, org.springframework.transaction.TransactionStatus,
Object) and writing the result back to the space (if it is not null ) using
AbstractResultEventListenerAdapter.handleResult(Object, org.openspaces.core.GigaSpace) . |
void |
TaskExecutorEventListenerAdapter.onEvent(Object data,
GigaSpace gigaSpace,
org.springframework.transaction.TransactionStatus txStatus,
Object source)
Listens for events and and delegates them to the
TaskExecutorEventListenerAdapter.setDelegate(org.openspaces.events.SpaceDataEventListener)
to be executed using the provided TaskExecutorEventListenerAdapter.setTaskExecutor(org.springframework.core.task.TaskExecutor) . |
protected Object |
AbstractReflectionEventListenerAdapter.onEventWithResult(Object data,
GigaSpace gigaSpace,
org.springframework.transaction.TransactionStatus txStatus,
Object source)
Delegates the event listener invocation to the appropriate method of the configured
AbstractReflectionEventListenerAdapter.setDelegate(Object) . |
protected abstract Object |
AbstractResultEventListenerAdapter.onEventWithResult(Object data,
GigaSpace gigaSpace,
org.springframework.transaction.TransactionStatus txStatus,
Object source)
An event listener callback allowing to return a result that will be written back to the
space.
|
Constructor and Description |
---|
SimpleAsyncPollingContainerConfigurer(GigaSpace gigaSpace) |
Modifier and Type | Method and Description |
---|---|
AsyncFuture |
SingleReadAsyncOperationHandler.asyncReceive(Object template,
GigaSpace gigaSpace,
long receiveTimeout,
AsyncFutureListener listener)
Performs a single take usign
asyncRead(Object) . |
AsyncFuture |
ExclusiveReadAsyncOperationHandler.asyncReceive(Object template,
GigaSpace gigaSpace,
long receiveTimeout,
AsyncFutureListener listener)
Performs a single take usign
asyncRead(Object) under
exclusive read lock. |
AsyncFuture |
SingleTakeAsyncOperationHandler.asyncReceive(Object template,
GigaSpace gigaSpace,
long receiveTimeout,
AsyncFutureListener listener)
Performs a single take usign
asyncTake(Object) . |
AsyncFuture |
AsyncOperationHandler.asyncReceive(Object template,
GigaSpace gigaSpace,
long receiveTimeout,
AsyncFutureListener listener)
Perform the async receive operation.
|
Constructor and Description |
---|
SimpleNotifyContainerConfigurer(GigaSpace gigaSpace) |
Constructor and Description |
---|
SimplePollingContainerConfigurer(GigaSpace gigaSpace) |
Modifier and Type | Method and Description |
---|---|
protected Object |
MultiTakeReceiveOperationHandler.doReceiveBlocking(Object template,
GigaSpace gigaSpace,
long receiveTimeout)
First tries and perform a
takeMultiple(Object, int,
TakeModifiers) using the provided template, the configured maxEntries (defaults to 50 )
and the configured fifoGroups (default to false ). |
protected abstract Object |
AbstractNonBlockingReceiveOperationHandler.doReceiveBlocking(Object template,
GigaSpace gigaSpace,
long receiveTimeout)
Performs a receive operations in a blocking manner.
|
protected Object |
SingleReadReceiveOperationHandler.doReceiveBlocking(Object template,
GigaSpace gigaSpace,
long receiveTimeout)
Performs single read operation using
read(Object, long)
with the given timeout. |
protected Object |
MultiReadReceiveOperationHandler.doReceiveBlocking(Object template,
GigaSpace gigaSpace,
long receiveTimeout)
First tries and perform a
readMultiple(Object, int)
using the provided template and configured maxEntries (defaults to 50 ). |
protected Object |
MultiExclusiveReadReceiveOperationHandler.doReceiveBlocking(Object template,
GigaSpace gigaSpace,
long receiveTimeout)
First tries and perform a
readMultiple(Object, int,
ReadModifiers) using the provided template, configured maxEntries (defaults to 50 ) and
the configured fifoGroups (default to false ). |
protected Object |
SingleTakeReceiveOperationHandler.doReceiveBlocking(Object template,
GigaSpace gigaSpace,
long receiveTimeout)
Performs a single take operation using
take(Object,
long, TakeModifiers) with the given timeout. |
protected Object |
ExclusiveReadReceiveOperationHandler.doReceiveBlocking(Object template,
GigaSpace gigaSpace,
long receiveTimeout)
Performs single read operation using
read(Object, long,
ReadModifiers) under an exclusive read lock. |
protected Object |
MultiTakeReceiveOperationHandler.doReceiveNonBlocking(Object template,
GigaSpace gigaSpace)
Performs a non blocking
takeMultiple(Object, int, TakeModifiers)
using the provided template, the configured maxEntries (defaults to 50 ) and the
configured fifoGroups (default to false ). |
protected abstract Object |
AbstractNonBlockingReceiveOperationHandler.doReceiveNonBlocking(Object template,
GigaSpace gigaSpace)
Performs a receive operations in a non blocking manner.
|
protected Object |
SingleReadReceiveOperationHandler.doReceiveNonBlocking(Object template,
GigaSpace gigaSpace)
Performs single read operation using
read(Object, long)
with no timeout. |
protected Object |
MultiReadReceiveOperationHandler.doReceiveNonBlocking(Object template,
GigaSpace gigaSpace)
Perform a
readMultiple(Object, int) using the provided
template and configured maxEntries (defaults to 50 ). |
protected Object |
MultiExclusiveReadReceiveOperationHandler.doReceiveNonBlocking(Object template,
GigaSpace gigaSpace)
Perform a
readMultiple(Object, int, ReadModifiers) using the
provided template, configured maxEntries (defaults to 50 ) and the configured
fifoGroups (default to false ). |
protected Object |
SingleTakeReceiveOperationHandler.doReceiveNonBlocking(Object template,
GigaSpace gigaSpace)
Performs a single take operation using
take(Object,
long, TakeModifiers) with no timeout. |
protected Object |
ExclusiveReadReceiveOperationHandler.doReceiveNonBlocking(Object template,
GigaSpace gigaSpace)
Performs single read operation using
read(Object, long,
ReadModifiers) under an exclusive read lock with no timeout. |
Object |
ReceiveOperationHandler.receive(Object template,
GigaSpace gigaSpace,
long receiveTimeout)
Performs the actual receive operation.
|
Object |
AbstractNonBlockingReceiveOperationHandler.receive(Object template,
GigaSpace gigaSpace,
long receiveTimeout)
Performs the receive operation.
|
Modifier and Type | Method and Description |
---|---|
Object |
TriggerOperationHandler.triggerReceive(Object template,
GigaSpace gigaSpace,
long receiveTimeout)
Allows to perform a trigger receive operation which control if the active receive operation
will be performed in a polling event container.
|
Object |
ReadTriggerOperationHandler.triggerReceive(Object template,
GigaSpace gigaSpace,
long receiveTimeout)
Uses
read(Object, long) and returns its result. |
Modifier and Type | Method and Description |
---|---|
static GigaSpace |
AnnotationProcessorUtils.findGigaSpace(Object bean,
String gigaSpaceName,
org.springframework.context.ApplicationContext applicationContext,
String beanName) |
Modifier and Type | Method and Description |
---|---|
static <T,D extends Number> |
ChangeExtension.addAndGet(GigaSpace gigaSpace,
IdQuery<T> idQuery,
String path,
D delta)
Atomically adds the given value to the current value of an entry's property.
|
static <T,D extends Number> |
ChangeExtension.addAndGet(GigaSpace gigaSpace,
IdQuery<T> idQuery,
String path,
D delta,
ChangeModifiers modifiers,
long timeout,
TimeUnit timeUnit)
Atomically adds the given value to the current value of an entry's property.
|
static <T,D extends Number> |
ChangeExtension.addAndGet(GigaSpace gigaSpace,
IdQuery<T> idQuery,
String path,
D delta,
long timeout,
TimeUnit timeUnit)
Atomically adds the given value to the current value of an entry's property.
|
static <T> CompletableFuture<ChangeResult<T>> |
AsyncExtension.asyncChange(GigaSpace gigaSpace,
ISpaceQuery<T> query,
ChangeSet changeSet) |
static <T> CompletableFuture<ChangeResult<T>> |
AsyncExtension.asyncChange(GigaSpace gigaSpace,
ISpaceQuery<T> query,
ChangeSet changeSet,
ChangeModifiers modifiers) |
static <T> CompletableFuture<ChangeResult<T>> |
AsyncExtension.asyncChange(GigaSpace gigaSpace,
ISpaceQuery<T> query,
ChangeSet changeSet,
ChangeModifiers modifiers,
long timeout,
TimeUnit timeUnit) |
static <T> CompletableFuture<ChangeResult<T>> |
AsyncExtension.asyncChange(GigaSpace gigaSpace,
ISpaceQuery<T> query,
ChangeSet changeSet,
long timeout,
TimeUnit timeUnit) |
static <T> CompletableFuture<ChangeResult<T>> |
AsyncExtension.asyncChange(GigaSpace gigaSpace,
T template,
ChangeSet changeSet) |
static <T> CompletableFuture<ChangeResult<T>> |
AsyncExtension.asyncChange(GigaSpace gigaSpace,
T template,
ChangeSet changeSet,
ChangeModifiers modifiers) |
static <T> CompletableFuture<ChangeResult<T>> |
AsyncExtension.asyncChange(GigaSpace gigaSpace,
T template,
ChangeSet changeSet,
ChangeModifiers modifiers,
long timeout,
TimeUnit timeUnit) |
static <T> CompletableFuture<ChangeResult<T>> |
AsyncExtension.asyncChange(GigaSpace gigaSpace,
T template,
ChangeSet changeSet,
long timeout,
TimeUnit timeUnit) |
static <T> CompletableFuture<T> |
AsyncExtension.asyncRead(GigaSpace gigaSpace,
ISpaceQuery<T> template) |
static <T> CompletableFuture<T> |
AsyncExtension.asyncRead(GigaSpace gigaSpace,
ISpaceQuery<T> template,
long timeout,
TimeUnit timeUnit) |
static <T> CompletableFuture<T> |
AsyncExtension.asyncRead(GigaSpace gigaSpace,
ISpaceQuery<T> template,
long timeout,
TimeUnit timeUnit,
ReadModifiers modifiers) |
static <T> CompletableFuture<T> |
AsyncExtension.asyncRead(GigaSpace gigaSpace,
T template) |
static <T> CompletableFuture<T> |
AsyncExtension.asyncRead(GigaSpace gigaSpace,
T template,
long timeout,
TimeUnit timeUnit) |
static <T> CompletableFuture<T> |
AsyncExtension.asyncRead(GigaSpace gigaSpace,
T template,
long timeout,
TimeUnit timeUnit,
ReadModifiers modifiers) |
static <T> CompletableFuture<T> |
AsyncExtension.asyncTake(GigaSpace gigaSpace,
ISpaceQuery<T> template) |
static <T> CompletableFuture<T> |
AsyncExtension.asyncTake(GigaSpace gigaSpace,
ISpaceQuery<T> template,
long timeout,
TimeUnit timeUnit) |
static <T> CompletableFuture<T> |
AsyncExtension.asyncTake(GigaSpace gigaSpace,
ISpaceQuery<T> template,
long timeout,
TimeUnit timeUnit,
TakeModifiers modifiers) |
static <T> CompletableFuture<T> |
AsyncExtension.asyncTake(GigaSpace gigaSpace,
T template) |
static <T> CompletableFuture<T> |
AsyncExtension.asyncTake(GigaSpace gigaSpace,
T template,
long timeout,
TimeUnit timeUnit) |
static <T> CompletableFuture<T> |
AsyncExtension.asyncTake(GigaSpace gigaSpace,
T template,
long timeout,
TimeUnit timeUnit,
TakeModifiers modifiers) |
static <T extends Number> |
QueryExtension.average(GigaSpace gigaSpace,
ISpaceQuery query,
String path) |
static long |
QueryExtension.count(GigaSpace gigaSpace,
ISpaceQuery query,
String path) |
static <T> List<T> |
QueryExtension.distinct(GigaSpace gigaSpace,
ISpaceQuery query,
DistinctAggregator<T> aggregator) |
static <T extends Serializable,R> |
AsyncExtension.execute(GigaSpace gigaSpace,
DistributedTask<T,R> task) |
static <T extends Serializable> |
AsyncExtension.execute(GigaSpace gigaSpace,
Task<T> task) |
static <T extends Serializable> |
AsyncExtension.execute(GigaSpace gigaSpace,
Task<T> task,
Object... routing) |
static <T extends Serializable> |
AsyncExtension.execute(GigaSpace gigaSpace,
Task<T> task,
Object routing) |
static GroupByResult |
QueryExtension.groupBy(GigaSpace gigaSpace,
ISpaceQuery query,
GroupByAggregator aggregator) |
static <T extends Comparable> |
QueryExtension.max(GigaSpace gigaSpace,
ISpaceQuery query,
String path) |
static <T> T |
QueryExtension.maxEntry(GigaSpace gigaSpace,
ISpaceQuery<T> query,
String path) |
static <T extends Comparable> |
QueryExtension.min(GigaSpace gigaSpace,
ISpaceQuery query,
String path) |
static <T> T |
QueryExtension.minEntry(GigaSpace gigaSpace,
ISpaceQuery<T> query,
String path) |
static <T> List<T> |
QueryExtension.orderBy(GigaSpace gigaSpace,
ISpaceQuery query,
OrderByAggregator aggregator) |
static <T extends Number> |
QueryExtension.sum(GigaSpace gigaSpace,
ISpaceQuery query,
String path) |
Modifier and Type | Method and Description |
---|---|
void |
SpaceDriverManagerDataSource.setGigaSpace(GigaSpace gigaSpace) |
Modifier and Type | Method and Description |
---|---|
GigaSpace |
CassandraArchiveOperationHandler.getGigaSpace() |
Modifier and Type | Method and Description |
---|---|
CassandraArchiveOperationHandlerConfigurer |
CassandraArchiveOperationHandlerConfigurer.gigaSpace(GigaSpace gigaSpace) |
void |
CassandraArchiveOperationHandler.setGigaSpace(GigaSpace gigaSpace) |
Constructor and Description |
---|
GigaSpaceSynchronizationEndpoint(GigaSpace targetSpace,
Map<String,SpaceTypeSchemaAdapter> spaceTypeSchemaAdapters) |
Constructor and Description |
---|
SpaceSessionDataStore(GigaSpace gigaSpace) |
Modifier and Type | Method and Description |
---|---|
protected GigaSpace |
RemotingAnnotationBeanPostProcessor.findGigaSpaceByName(String gsName) |
Modifier and Type | Method and Description |
---|---|
void |
SpaceRemotingServiceExporter.onEvent(SpaceRemotingEntry remotingEntry,
GigaSpace gigaSpace,
org.springframework.transaction.TransactionStatus txStatus,
Object source)
Receives a
SpaceRemotingEntry which holds all the relevant invocation information. |
void |
ExecutorSpaceRemotingProxyFactoryBean.setGigaSpace(GigaSpace gigaSpace)
Sets the GigaSpace interface that will be used to work with the space as the transport
layer.
|
void |
EventDrivenSpaceRemotingProxyFactoryBean.setGigaSpace(GigaSpace gigaSpace)
Sets the GigaSpace interface that will be used to work with the space as the transport layer
for both writing and taking
SpaceRemotingEntry . |
Constructor and Description |
---|
EventDrivenRemoteFuture(GigaSpace gigaSpace,
SpaceRemotingEntry remotingEntry) |
EventDrivenRemotingProxyConfigurer(GigaSpace gigaSpace,
Class<T> serviceInterface) |
ExecutorRemotingProxyConfigurer(GigaSpace gigaSpace,
Class<T> serviceInterface) |
Constructor and Description |
---|
EventDrivenScriptingProxyConfigurer(GigaSpace gigaSpace)
Creates a new
AsyncScriptingProxyConfigurer on top of the given space |
ExecutorScriptingProxyConfigurer(GigaSpace gigaSpace)
Creates a new
ExecutorScriptingProxyConfigurer on top of the given space |
Modifier and Type | Method and Description |
---|---|
GigaSpace |
ControllerUtils.XapConnectionCache.get() |
Modifier and Type | Method and Description |
---|---|
static SpaceDocument[] |
ControllerUtils.createSpaceDocuments(String type,
String body,
GigaSpace gigaSpace) |
Copyright © GigaSpaces.