Package | Description |
---|---|
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.space.mode |
A package exposing Space mode (primary/backup) events through Spring application event
support.
|
org.openspaces.core.space.support | |
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.grid.esm | |
org.openspaces.grid.gsm.machines.backup | |
org.openspaces.jdbc.datasource |
Implementations of Jdbc DataSource interface using GigaSpaces support for Jdbc based on an
actual IJSpace or GigaSpace implementation.
|
org.openspaces.jms |
Holds simple factory beans to create GigaSpaces implementations of JMS ConnectionFactory and XAConnectionFactory.
|
org.openspaces.memcached | |
org.openspaces.remoting |
A package including OpenSpaces support for Sync and Async remoting inspired by other Spring remoting
integrations.
|
org.openspaces.remoting.scripting |
Modifier and Type | Method and Description |
---|---|
GigaSpace |
Space.getGigaSpace()
Returns the clustered view of the space to operate on.
|
GigaSpace |
SpaceInstance.getGigaSpace()
Returns the direct proxy to the actual space instance.
|
Modifier and Type | Method and Description |
---|---|
void |
ArchivePollingContainer.onEvent(Object data,
GigaSpace gigaSpace,
TransactionStatus txStatus,
Object source) |
void |
DefaultArchivePollingContainerExceptionHandler.onException(ListenerExecutionFailedException exception,
Object data,
GigaSpace gigaSpace,
TransactionStatus txStatus,
Object source)
This is the default handler if
#setExceptionHandler(EventExceptionHandler) was not called. |
void |
DefaultArchivePollingContainerExceptionHandler.onSuccess(Object data,
GigaSpace gigaSpace,
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. |
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 |
---|---|
static CountModifiers |
IsolationLevelHelpers.mergeWithIsolationLevelModifiersIfNeeded(CountModifiers modifiers,
GigaSpace gigaSpace) |
static ReadModifiers |
IsolationLevelHelpers.mergeWithIsolationLevelModifiersIfNeeded(ReadModifiers modifiers,
GigaSpace gigaSpace) |
Constructor and Description |
---|
IteratorBuilder(GigaSpace gigaSpace)
Constructs a new iterator builder using the given GigaSpace.
|
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 | 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 |
WorkerAdapter.setGigaSpace(GigaSpace gigaSpace)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
protected 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,
TransactionStatus txStatus,
Object source)
An event callback with the actual data object of the event.
|
void |
EventExceptionHandler.onException(ListenerExecutionFailedException exception,
T data,
GigaSpace gigaSpace,
TransactionStatus txStatus,
Object source)
A callback to handle exception in an event container.
|
void |
EventExceptionHandler.onSuccess(T data,
GigaSpace gigaSpace,
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,
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,
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,
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,
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 |
AsyncOperationHandler.asyncReceive(Object template,
GigaSpace gigaSpace,
long receiveTimeout,
AsyncFutureListener listener)
Perform the async receive operation.
|
AsyncFuture |
ExclusiveReadAsyncOperationHandler.asyncReceive(Object template,
GigaSpace gigaSpace,
long receiveTimeout,
AsyncFutureListener listener)
Performs a single take usign
asyncRead(Object) under exclusive
read lock. |
AsyncFuture |
SingleReadAsyncOperationHandler.asyncReceive(Object template,
GigaSpace gigaSpace,
long receiveTimeout,
AsyncFutureListener listener)
Performs a single take usign
asyncRead(Object) . |
AsyncFuture |
SingleTakeAsyncOperationHandler.asyncReceive(Object template,
GigaSpace gigaSpace,
long receiveTimeout,
AsyncFutureListener listener)
Performs a single take usign
asyncTake(Object) . |
Constructor and Description |
---|
SimpleNotifyContainerConfigurer(GigaSpace gigaSpace) |
Constructor and Description |
---|
SimplePollingContainerConfigurer(GigaSpace gigaSpace) |
Modifier and Type | Method and Description |
---|---|
protected abstract Object |
AbstractNonBlockingReceiveOperationHandler.doReceiveBlocking(Object template,
GigaSpace gigaSpace,
long receiveTimeout)
Performs a receive operations in a blocking manner.
|
protected Object |
ExclusiveReadReceiveOperationHandler.doReceiveBlocking(Object template,
GigaSpace gigaSpace,
long receiveTimeout)
Performs single read operation using
read(Object,long,int)
under an exclusive read lock. |
protected Object |
MultiExclusiveReadReceiveOperationHandler.doReceiveBlocking(Object template,
GigaSpace gigaSpace,
long receiveTimeout)
First tries and perform a
readMultiple(Object,int,int) using
the provided template, configured maxEntries (defaults to 50 ) and the configured fifoGroups (default to false ). |
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 |
MultiTakeReceiveOperationHandler.doReceiveBlocking(Object template,
GigaSpace gigaSpace,
long receiveTimeout)
First tries and perform a
takeMultiple(Object,int,int)
using the provided template, the configured maxEntries (defaults to 50 ) and the configured fifoGroups (default to false ). |
protected Object |
SingleReadReceiveOperationHandler.doReceiveBlocking(Object template,
GigaSpace gigaSpace,
long receiveTimeout)
Performs single read operation using
read(Object,long) with the
given timeout. |
protected Object |
SingleTakeReceiveOperationHandler.doReceiveBlocking(Object template,
GigaSpace gigaSpace,
long receiveTimeout)
Performs a single take operation using
take(Object, long,int) with
the given timeout. |
protected abstract Object |
AbstractNonBlockingReceiveOperationHandler.doReceiveNonBlocking(Object template,
GigaSpace gigaSpace)
Performs a receive operations in a non blocking manner.
|
protected Object |
ExclusiveReadReceiveOperationHandler.doReceiveNonBlocking(Object template,
GigaSpace gigaSpace)
Performs single read operation using
read(Object,long,int)
under an exclusive read lock with no timeout. |
protected Object |
MultiExclusiveReadReceiveOperationHandler.doReceiveNonBlocking(Object template,
GigaSpace gigaSpace)
Perform a
readMultiple(Object,int,int)
using the provided template, configured maxEntries (defaults to 50 ) and the configured fifoGroups (default to false ). |
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 |
MultiTakeReceiveOperationHandler.doReceiveNonBlocking(Object template,
GigaSpace gigaSpace)
Performs a non blocking
takeMultiple(Object,int,int)
using the provided template, the configured maxEntries (defaults to 50 ) and the configured fifoGroups (default to false ). |
protected Object |
SingleReadReceiveOperationHandler.doReceiveNonBlocking(Object template,
GigaSpace gigaSpace)
Performs single read operation using
read(Object,long) with no
timeout. |
protected Object |
SingleTakeReceiveOperationHandler.doReceiveNonBlocking(Object template,
GigaSpace gigaSpace)
Performs a single take operation using
take(Object,long,int) with
no timeout. |
Object |
AbstractNonBlockingReceiveOperationHandler.receive(Object template,
GigaSpace gigaSpace,
long receiveTimeout)
Performs the receive operation.
|
Object |
ReceiveOperationHandler.receive(Object template,
GigaSpace gigaSpace,
long receiveTimeout)
Performs the actual receive operation.
|
Modifier and Type | Method and Description |
---|---|
Object |
ReadTriggerOperationHandler.triggerReceive(Object template,
GigaSpace gigaSpace,
long receiveTimeout)
Uses
read(Object,long) and returns its result. |
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.
|
Modifier and Type | Method and Description |
---|---|
static GigaSpace |
AnnotationProcessorUtils.findGigaSpace(Object bean,
String gigaSpaceName,
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 | Field and Description |
---|---|
protected GigaSpace |
ESMImpl.managementSpace |
Modifier and Type | Method and Description |
---|---|
void |
ESMImplInitializer.AdminCreatedEventListener.adminCreated(Admin admin,
GigaSpace managementSpace) |
Constructor and Description |
---|
MachinesStateBackupToSpace(Admin admin,
GigaSpace space,
MachinesSlaEnforcementState machinesSlaEnforcementState) |
Modifier and Type | Method and Description |
---|---|
void |
DbcpBasicDataSource.setGigaSpace(GigaSpace gigaSpace) |
void |
SpaceDriverManagerDataSource.setGigaSpace(GigaSpace gigaSpace) |
Modifier and Type | Method and Description |
---|---|
void |
GigaSpaceConnectionFactory.setGigaSpace(GigaSpace gigaSpace)
The GigaSpace instance to acquire the
IJSpace
from. |
void |
GigaSpaceXAConnectionFactory.setGigaSpace(GigaSpace gigaSpace)
The GigaSpace instance to acquire the
IJSpace
from. |
Modifier and Type | Method and Description |
---|---|
void |
MemCacheDaemon.setSpace(GigaSpace space) |
Constructor and Description |
---|
SpaceCache(GigaSpace space) |
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,
TransactionStatus txStatus,
Object source)
Receives a
SpaceRemotingEntry which holds all the relevant
invocation information. |
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 . |
void |
ExecutorSpaceRemotingProxyFactoryBean.setGigaSpace(GigaSpace gigaSpace)
Sets the GigaSpace interface that will be used to work with the space as the transport layer.
|
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 |
Copyright © GigaSpaces.