All Classes and Interfaces
Class
Description
An implementation of a
com.sun.jini.mahalo.Job which interacts with a set of
net.jini.core.transaction.server.TransactionParticipants to inform them to roll back
changes associated with a given net.jini.core.transaction.Transaction.ITimeProvider implementation of the underlying OS system or wall-clock time.Built in mathematical sql function to get absolute value of a parameter.
Base class for implementing adapters which encrypt properties using AES.
An abstraction over a fired alert, exposing the
Alert API.Created by Barak Bar Orion 12/30/14.
Base class for
ColumnMetadata implementationsAbstractCompoundIndexScanner defines an index scanner that scans more than one space index.
Encapsulates information about an index segment of a compound index.
Base class for
CompoundTypeNode implementations.Base class for compound custom queries.
Base class for configurations
A skeletal implementation of the
Configuration interface, used to simplify writing
implementations.Represents the value of an entry with a primitive type.
A base class for replication routers that are using
IReplicationConnectionProxy to
communicate with each other.Base class for all custom query interfaces.
A base class for data consume fix generated by
ReplicationPacketDataProducer and consumed
by ReplicationPacketDataConsumer.the super class of all DataEventSession implementations.
A base class for delegating tasks that are also distributed tasks
The element of synchronizing a direct-persistency uid
Title: Description:
Copyright (c) 2010 GigaSpaces Technologies Ltd.
An abstract implementation of
Entry that provides useful implementations of
equals, hashCode, and toString.A wrapper around an entry's class-type meta-data.
A simple based class for
SpaceDataEventListener based containers.Implements EvictionStrategy and acts as a base for all the eviction strategies
Base class for externalizable classes in gigaspaces, providing forward/backward compatibility
info.
The AbstractFaultDetectionHandler provides a base class which can be extended to provide concrete
FaultDetectionHandler capabilities.
Defines the semantics of an internal class which will be used in perform service-specific
monitoring
Support class to perform receive operations with or without Fifo Grouping.
A base class for filter adapters that delegate the invocation of filter operation and
lifecycle methods to another class.
A base factory for
FilterProvider allowing to construct a
filter provider that can be used to provide pre initialized ISpaceFilter implementation including its different aspects to an
embedded space.Common part shared by both
FractionFormat and BigFractionFormat.Base class for replication gateway components.
Provides a base class for the dynamic Getter implementation.
Base class for GigaSpaces Services that supports registration in Jini Lookup Service.
A base template packet for IdsQueryPacket and IdsMultiRoutingQueryPacket The template packet
contains an IDs array.
Base class for Jini implementation of Springs
PlatformTransactionManager.Jini Transaction object.
A base class for implementing lease objects.
A base class for implementing LeaseMaps.
A base class for local cache based beans.
Base class for different Local cache space proxies that work with a master
IJSpace.A base class for Local Cluster operations data.
A base class for local cluster replication in handlers used by a gateway Sink component.
Deprecated.
since 9.5
Deprecated.
since 9.5 - use
SpaceDataSourceSplitter or SpaceSynchronizationEndpointSplitter instead.!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!! SAME AS AbstractMap in
java.util, but public instead of package !!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!
This class provides a skeletal implementation of the Map interface, to minimize the
effort required to implement this interface.
Base class for all Map implementations.
This should be made public as soon as possible.
Support class to perform receive operations with or without memory only search..
Provides a base class for the dynamic method implementation.
Abstract class for
MirrorOperations implementations.A base class for monitor classes.
Abstraction for a data producers that is a composition of multiple data producers.
TODO add Javadoc
Support class to perform either non blocking or blocking receive operation.
Simple base class for different policies.
Base class for replication packets that depend on a previous
TransactionPrepareReplicationPacketData occurringAbstractProcessingUnitDependencies<T extends ProcessingUnitDependency,IT extends InternalProcessingUnitDependency>
AbstractProcessingUnitDependenciesConfigurer<T extends ProcessingUnitDependency,IT extends InternalProcessingUnitDependency,S extends ProcessingUnitDetailedDependencies<T>,IS extends InternalProcessingUnitDetailedDependencies<T,IT>>
AbstractProcessingUnitDetailedDependencies<T extends ProcessingUnitDependency,IT extends InternalProcessingUnitDependency>
Contains projection information and logic
A base class for all the Proxies created by reflection.
This private class implements the Comparator and is used to sort.
Base class for reflection driven invocation of event template provider method.
Base class for reflection driven invocation of event listener methods.
Base class allowing to simplify replicaiton filter provider factories.
A base class for
IReplicationPacketData implementations that contains only one IReplicationPacketEntryDataBase for all the resources that can stored in the
ThreadLocalPool.Base class for response context implementations
A base class event listener allowing for event listeners result handling by writing it back to
the space.
Provides a general selector logic.
Copyright (c) 2010 GigaSpaces Technologies Ltd.
A base implementation of
ServiceDiscoveryListener in order to listen to LookupCache.Provides a base class for the dynamic Setter implementation.
Base class for jvm shutdown hook implementation.
AbstractSingleFileGroupBacklog<T extends IReplicationOrderedPacket,CType extends AbstractSingleFileConfirmationHolder>
A base class for
IReplicationGroupBacklog that contains a single IRedoLogFile and
treat the order of packets in that file for the global order of the backlogBase class for most space factory beans responsible for creating/finding
IJSpace
implementation.Base class for different space mode events.
AbstractSpaceOperation<TResult extends RemoteOperationResult,TRequest extends RemoteOperationRequest<TResult>>
A common basic implementation for space predicate implementations.
A common base class for most space proxies.
An action manager, holding all the action listeners used by different space proxies.
Base class for different modifier types beans.
Common base class for space query implementations.
Common basic implementation for ISpaceValueGetter implementations.
An abstract implementation of the IStoredList, provides common
Base class for statistics configurations that aggregate samples based on a specified time window
Base class for transaction replication packet data
Common base class for ITypeIntrospector implementations.
The synchronizing direct-persistency embedded list op info
Handle accept events from selector.
Thrown if an operation is performed without a required authority.
Represents permission to call a method.
A server context element for registering interest in receiving an acknowledgment that the remote
call's result data has been delivered to and processed by the client.
A callback object for registering with an
AcknowledgmentSource server context element
to handle the receipt of an acknowledgment that the remote call's result data has been
processed by the client.Should be implemented in order to receive events from ActionMaker
Should be implemented in order to notify events to Action ActionListener
This class provides a configuration object of
ActiveElectionManager.This event sends by
IActiveElectionListener to notify the listener implementation about
new elected active service.This exception thrown by
ActiveElectionManager on unexpected functionality behavior.ActiveElectionManager based on distributed naming service
INamingService
and provides a distributed active election algorithm to select only one active service
between all candidates.The election state attribute registered in conjunction with service candidate.
Service states
Provides a failure detection on active service.
Represents a change operation which correlate with a
ChangeSet.addAllToCollection(String, java.io.Serializable...) invocation.Provides an interface for handling an
AddIndexesConflict.A
ConflictCause implementation for an add indexes operation conflict.Factory containing a singleton
IAdditionalClassProvider, currently used to load classed
from the LRMIClassLoadersHolder from the ServiceClassLoader due to backward reference between jar
dependenciesRepresents a change operation which correlate with a
ChangeSet.addToCollection(String, java.io.Serializable) invocation.A tuple for holding an
IServerTypeDesc and AddTypeDescResultType as a result of a
SpaceTypeManager.addTypeDesc(com.gigaspaces.internal.metadata.ITypeDesc) invocation.Encapsulates information on the result of an add type indexes operation.
The main interface for accessing Admin API.
A general interface implements by elements that can provide access to
Admin.A generics marker interface for all different Admin Events.
Base for all admin exceptions.
A factory allowing to create
Admin instance.Interface that defines filtering behavior for Admin services
Helper class for filter Admin services
Every administrable service should implement this interface.
A spring namespace handler for the "admin" namespace.
A shared admin thread pool.
Adapter for encrypting properties using AES/CBC.
A
ContentEncoder using AES as the cryptographic algorithm.AES is a federal standard for private-key or symmetric cryptography.
Adapter for encrypting properties using AES/GCM.
Filter callback after all notify trigger.
Filter callback before change operation.
A matcher filter that will return log entries that happened from (after) the provided log entry.
Filter callback after execute operation
Filter callback after notify trigger.
Filter callback after read operation.
Filter callback after read multiple operation.
Filter callback after an entry was removed due to lease expression or lease cancel.
A Space mode event that is raised after the space mode was changed to the space mode reflected in
this event.
Filter callback after take operation.
Filter callback after take multiple operation.
A matcher filter that will match only on log entries that occurred after the specified time.
Filter callback after update operation.
Filter callback after write operation.
An Agent grid component is a
GridComponent that can be started by a
GridServiceAgent.Async Polling container service details.
Notify container service details.
An aggregation of
ServiceDetails that share at lease the same
service type.Created by niv on 6/17/14.
Security policy provider which supports associating security sub-policies with context class
loaders.
This class is intended for internal usage only.
The set of aggregations to run for matches entries of the aggregate operation.
Utility to help perform aggregation queries on space from JDBC
An interface representing an alert issued by an alert bean or an alert provider.
A configuration of an alert trigger.
An alert configuration exception; the
Throwable.getCause() can be one the subclasses of BeanConfigException.A configuration parser for setting a bulk of alert configurations using the call to
AlertManager.configure(AlertConfiguration[]).An exception thrown on a parsing error from
AlertConfigurationParser.An interface for implementations carrying out the 'builder/chaining' pattern on top of an
AlertConfiguration.A factory for constructing an alert instance to be fired by an alert bean.
The AlertManager is a manager for configuring of alerts, firing of alerts, and
registering for alert events.
The alert severity levels.
Allows to postpone alerts listener registration.
The alert status levels.
An event listener for all types of alerts.
An event manager allowing to remove and add
AlertTriggeredEventListeners.TODO add Javadoc
A cache policy that stores all the data in the space.
A matcher that returns all the log entries.
Route every operation to all groups
An implementation of a logical multiple AND condition: This predicate returns true if and only if
all operands return true.
The ALTER TABLE implementation.
This is the AndNode, expressing an 'and' between conditions.
An implementation of a logical binary AND condition: This predicate returns true if and only if
both left and right operands return true.
An extension of
ObjectInputStream that implements the dynamic class loading
semantics of RMI argument and result unmarshalling (using RMIClassLoader).An extension of
ObjectOutputStream that implements the dynamic class loading
semantics of RMI argument and result marshalling (using RMIClassLoader).The annotation event template provider adapter uses
DynamicEventTemplate annotation in
order to find the event template provider to delegate to.An event listener adapter that uses
SpaceDataEvent annotation in order to find event
listener methods to delegate to.A
FilterProvider factory that accepts a Pojo
filter with annotation markers as to which filter operation to listen to.Registers the
ModeAnnotationRegistry and ModeAnnotationRegistryPostProcessor.General utility methods for working with annotations, handling bridge methods (which the compiler
generates for generic declarations) as well as super methods (for optional "annotation
inheritance").
A visitor to visit a Java annotation.
Instances of this class are mediators between the receiver to the rest of the engine.
This internal class for communication between client/server protocol.
An implementation of a logical multiple OR condition: This predicate returns true if and only if
any of the operands return true.
Satisified by any zones PU[] is statisfied by GSC[] PU[] is statisfied by GSC[A]
Built in string sql function to append any number of given string arguments.
Describes a group of processing units that interact together as an application.
An event listener allowing to listen for
Application
additions (deployment).An event manager allowing to add and remove
ApplicationAddedEventListeners.A processing unit container that is based on Spring
ApplicationContext.Describes an application deployment that consists of one or more processing unit deployments.
An Application Exception abstracts a logical exception rather than an exception in network
infrastructure (which is abstracted by RemoteException).
A helper method that creates a
ApplicationConfig by reading an xml fileA simple life-cycle event listener that implements both the application added and zone removed
event listeners.
An event listener allowing to listen for
Application
removal (undeployment).An event manager allowing to add and remove
ApplicationRemovedEventListeners.Holds one or more
ApplicationsMarks an event listener as archive event listener.
A
Archive annotation post processor.Takes objects specified in the template into the archive handler defined by
ArchivePollingContainer.setArchiveHandler(ArchiveOperationHandler) This container can be used to take (remove) objects
from the Space and persist them into an external service.A configuration for
ArchivePollingContainer using fluent API.TODO add Javadoc
Creates ASM created classes that represents that provides fast default constructor "reflection"
mechanism.
Base class for all the ASM factories
Creates ASM created classes that represents that provides fast fields "reflection" mechanism.
Creates ASM created classes that represents that provides fast fields "reflection" mechanism.
Creates ASM created classes that represents that provides fast "reflection" mechanism.
Creates ASM created classes that represents that provides fast methods "reflection" mechanism.
Implement
IReflectionFactory based on ASM.a client handler context implementation.
Extends
Future to provide a listener API.Allows to register for a callback on an
AsyncFuture to be notified when a result arrives.An annotation marking a method as one that is responsilbe to return a
AsyncOperationHandler to be used with an async
polling container.The async operation handler allows for pluggable options to execute the async receive operation
when using
SimpleAsyncPollingEventListenerContainer.Marks an event listener an asyncronous polled event listener.
A
AsyncPolling annotation post processor.Async Polling container service details.
Async Polling container service monitors.
used to indicate async invocation of the annotated method.
An async invocation result holding the actual result of the invocation or an possible exception
raised during the invocation.
An optional filter that can be used with distributed tasks.
Controls what should be done with the results.
Represents an
AsyncResultFilter event.A wrapper that implemetns
Future that wras an already arrived AsyncResult.A generic interface that reduces a list of
AsyncResult.Primary backup async target group
Satisfied if at least one of the zones exist
PU[A,B] is statisfied by GSC[A,B] PU[A,B] is statisfied by GSC[A] PU[A,B] is statisfied by GSC[B]
PU[A] is statisfied by GSC[A,B] PU[A] is statisfied by GSC[A] PU[A] is NOT statisfied by
GSC[]
A non standard class, field, method or Code attribute, as defined in the Java Virtual Machine
Specification (JVMS).
The
AuditDetails are client side auditing details sent to the server on each
authentication request.A declarable extension to
RollingFileHandler.The java logging facility formats a
LogRecord before it is logged.Represents an authenticated request, returned on successful call to
SecurityManager.authenticate(UserDetails).Thrown if an authentication is invalid.
Represents permission to use the private credentials of subjects for the purpose of
authenticating as any subset of the local principals specified in the target name, during secure
remote calls with any peer that authenticates as at least the set of peer principals specified in
the target name.
An Authentication token which is used to further interact without using sensitive authentication
details (i.e.
Interface for all authorities that may be granted to a user.
A factory for creating an
Authority instance back from its String representation returned
by Authority.getAuthority()Launches the XAP Auth server (xap-security-server) as a separate child JVM process.
A marker annotation enabling an aggregator to be autowired with resources defined within the
processing unit.
A marker interface enabling an aggregator to be autowired with resources defined within the
processing unit.
An annotation enabling autowiring of arguments in a remoting service.
A marker interface enabling autowiring of arguments in a remoting service.
A marker annotation enabling a task to be autowired with resources defined within the processing
unit.
A marker interface enabling a task to be autowired with resources defined within the processing
unit.
Calculates the average of all cluster instances values.
Fluent API for creating a new
AverageTimeWindowStatisticsConfig objectA default implementation of a reducer that averages all types
T into a result
R.A sum distrubted task that accepts a
Task to delegate the
actual execution to and implements the AvgTask.reduce(java.util.List) operation.This will throttle operations according to the backlog size and active state.
Configures a
IReplicationGroupBacklogSpecifies the way to act when the configured limit of the backlog is reached
An event indicating that a backup GSM of a processing unit was either added or removed.
The type of the event.
An event listener allowing to register for
BackupGridServiceManagerChangedEvents.An event manager allowing to add and remove
BackupGridServiceManagerChangedEventListeners
in order to listen for BackupGridServiceManagerChangedEvents.An interface for a pluggable backup policy.
Deprecated.
An exception indicating wrong SQL query usage.
Holds the entry and all the Statics.
BaseClientPeer is a convenient abstract superclass for Client Peer classes of Protocol Adapters.
Provides a base for any Map based HashSet implementation.
BaseServerPeer is a convenient superclass for Server Peer classes of Protocol Adapters.
Deprecated.
since 12.3 use EqualIndex instead
Basic implementation of
MethodConstraints, allowing limited wildcard matching on method
names and parameter types.Descriptor for specifying the constraints associated with one or more methods allowing
limited wildcard matching on method names and parameter types.
A
ProxyPreparer for verifying that proxies are trusted, granting them dynamic
permissions, and setting their constraints, as well as for creating other proxy preparer
subclasses that include those operations.A basic trust verifier for proxies.
An implementation of ServiceType that uses ResourceBundles.
Deprecated.
Since 8.0 - Use
SpaceTypeDescriptor instead.A basic trust verifier context element that provides a security context to use to restrict
privileges when invoking methods on untrusted objects, based on a specified set of permissions.
Handles batch writes according to the data type and the underlying data source
The main service that notify events in batches.
Thrown when one of the following space operations fails: readMultiple,takeMultiple,clear.
Thrown when one of the following space operations fails: readMultiple,takeMultiple,clear.
Context for batch query operations.
Received on
BatchRemoteEventListener.notifyBatch(BatchRemoteEvent) when a batch of events
that matches the pending templates registration.Extends the RemoteEventListener to provide batch events.
A packet returned from a JDBC batch execution.
A simple bean construct with resemblance to a Spring bean (interfaces InitializingBean,
DisposableBean).
A weakly typed configuration API based on String key-value pairs to configure an admin
Bean.
Base class for all admin Bean configuration exceptions.
A strongly typed bean configuration manager using the strongly typed implementation of a
BeanConfig.Exception indicating that a configuration for a bean by this name can't be found (has not been
added or has been removed).
A weakly typed properties manager for managing admin bean configurations by their name.
Indicates the bean does not implement the required interfaces.
Exception indicating that a misconfiguration occurred when initializing a bean (such as failure
to set an essential property).
A weakly-typed configuration API based on the 'builder' patterns for a more convenient
code-fluent approach to configuring a
BeanConfig.Exception indicating that an initialization of a bean failed.
A callback that sets the merged properties using
mergedProperties and the bean name that the bean implementing this interface is associated
with.Allows for beans to be injected with
BeanLevelProperties that contains the bean level
merged properties.An extension to Spring support for properties based configuration.
A callback allowing for bean to be injected with
BeanLevelProperties.Allows for beans to be injected with
BeanLevelProperties.A
BeanLevelProperties parser that parses -properties
parameter(s) and transforms it into bean level properties.A Spring
BeanPostProcessor that process beans that implement BeanLevelPropertiesAware or BeanLevelMergedPropertiesAware based on the provided BeanLevelProperties.An extension on top of Spring
PropertyPlaceholderConfigurer that works with BeanLevelProperties in order to inject bean level properties.The bean property monitor allows to register a Spring bean reference and a proeprty name which
will be monitored at a scheduled interval by invoking it.
A bean definition builder for
BeanPropertyMonitor.Filter callback before all notify trigger.
Filter callback before authentication.
Filter callback before change operation.
Filter callback after clean space operation.
A matcher filter that will return log entries that happened till the provided log entry.
Filter callback before execute operation
Filter callback before notify operation.
Filter callback before notify trigger.
Filter callback before read operation.
Filter callback before read multiple operation.
Filter callback before an entry was removed due to lease expression or lease cancel.
A Space mode event that is raised before the space mode is changed to the space mode reflected in
this event.
Filter callback before take operation.
Filter callback before take multiple operation.
A matcher filter that will match only on log entries that occurred before the specified time.
Filter callback before update operation.
Filter callback before write operation.
Represents a Between predicate.
Adapter for serializing properties using standard serialization and storing them in space in binary form.
A common basic implementation for binary composite space predicate implementations.
Contains an object serialized in a binary format.
Interface wrapping a binary payload to be stored in space.
The java.sql.Blob implementation
This OutputStream sub class is used with the Blob implementation.
base for an operation to execute as part of a bulk on off heap storage (SSD, off-heap buffers)
result an operation executed as part of a bulk on blob-store storage (SSD, off-heap buffers)
entry busy in bulk cant be locked
Off heap interface for internal cache
Off heap interface for internal cache
This class is used to inject configuration into a blobstore implementation.
A cache policy that stores data blobStore and indexes onheap.
A factory for creating
BlobStoreDataCachePolicy instance.error info used to revert failed bulk flush- currently used in backup
handling entries after blob=store errors occurred
Exception class that is thrown when any kind of BlobStore related exception happens.
provide an extention to the BlobStoreStorageHandler
off-heap initial-load of fifo/f-g classes we need to sort by fifo order and before that throw out
any non-related-to-index property
Copyright (c) 2010 GigaSpaces Technologies Ltd.
off-heap storage adapter data iterator to be used in recovery
locks The resident part of entry that resides in-heap
monitor against possible out of (secondary) memory in blob store implementation
Wrapper for BlobStoreMemoryMonitor
Exception class that is thrown when BlobStore crossed the designated memory threshold .
off-heap storage adapter meta data iterator to be used in recovery
Created by kobi on 23/8/14.
provide a wrapper over blobstore methods, used for serialization to byte-array, trapping stats
etc
handlels prefetch activity
handlels prefetch activity
handles prefetch activity
handlels prefetch activity
helper functions in order to maintain blobstore recovery consistency
Created by yechielf on 09/03/2015.
helper functions in order to maintain blobstore recovery consistency
The resident part of entry that resides blob-store
when blob store is recoverd via replication assist by bulking
when blob store is getting replication multiple ops assist by bulking in backup
A parallerl iterator for retrieving data parallely from blob store using segments used in
initial-load note- a single thread should use this iterator
Created by kobi on 4/10/14.
blobStore storage adapter to handle common blobStore i/o
classes used (in i/o ops) in off-heap storage adapter
class info used & stored in B.S.
basic methods for handling blob-stored objects specific implementations (SSD, off-heap buffers)
should extend this class
BlobStore storage adapter storedTypeDesc
Created by yechielf on 09/02/2015.
BlockedOrderedQueue is a concurrent ordered queue that can deliver unordered events to a client
in a FIFO order (using the event sequence number) the client is notified using a thread from the
proxy's thread pool.
A
BlockingQueue script pool with a configurable size.A compiles script pool factory that create a
BlockingQueueCompiledScriptPool.a resource pool that blocks clients when all resources are busy.
Serializer for Boolean.
Indicates an exception is a boot exception, i.e.
This class provides a set of static utility methods used for I/O manipulations.
A result of a bootstrap
Deprecated.
Since 8.0.4 - use
GatewaySinkSource API instead.Bootstap servlet context listener allowing to get the
ClusterInfo,
BeanLevelProperties, and handle an optional pu.xml file
within META-INF/spring by loading it.Provides static convenience methods for use in configuration files.
Created by Barak Bar Orion 2/1/15.
A bounded string builder that does not safe checks and does not expand its capacity.
Box primitive types.
Boxing methods used by the Scala macro API
An interface optionally implemented by the first parameter in a remote invocation to indicate if
broadcasting is enabled or not.
Wraps a
IRedoLogFileStorage with a buffer, allowing adding single packets in the storage
which will be flushed once a specific buffer size is reachedBulkDataItem is used by the space for execution of bulk operations
in case of transactions and mirror replication.
BulkDataItem contains the data object and the operation that needs to be executed.
in case of transactions and mirror replication.
BulkDataItem contains the data object and the operation that needs to be executed.
Deprecated.
since 9.5 - use
SpaceSynchronizationEndpoint instead.BulkDataPersisterContext an operation context that is accessible on mirror in BulkDataPersister.executeBulk(ListBulkDataPersisterContext is not accessible on any other space except mirror and not in
any other method except BulkDataPersister.executeBulk(ListExample of mirror implementation:
Deprecated.
since 9.5 - use
SpaceSynchronizationEndpointExceptionHandler instead.Deprecated.
since 9.5 - use
SpaceSynchronizationEndpointSplitter instead.Deprecated.
since 9.5 - use
SpaceSynchronizationEndpoint and DataSyncOperation
instead.A Bus Packet is an event that is sent on some MT-Queue in order to be handled by a Worker
Thread.
Serializer for byte array.
Used by
PacketSerializer as ObjectInputStreamUsed by
PacketSerializer as ObjectOutputStreamA configuration object for
ByteBufferRedoLogFileStorageAn implementation of redo log file storage which is based on an underlying byte buffer storages
provider which simulated an endless byte buffer
Thrown when a
ByteBufferRedoLogFileStorage integrity is compromised, such as unavailable
storage or some error which causes a corruption of the redolog IRedoLogFile.validateIntegrity()Thrown when an error has occurred at a
IByteBufferStorageSerializer for byte.
A
Serializer implementation for Byte values.Convenient methods for converting objects to and from bytes.
A dynamically extensible vector of bytes.
Deprecated.
Deprecated.
Exception class that is thrown when any kind of Cache related exception happens.
Deprecated.
Deprecated.
Use
MapConfigurer instead.Wraps a
INonBatchRedoLogFileStorage with a cache that keeps a constant size number of
packets in memory which were the last appended packet.Deprecated.
The Cache Manager acts as a fast intermediate storage for objects in Virtual Memory.
INITIALLOAD INFO.
usage of recent deletes.
A generic interface for cache policies.
This Exception thrown when the entry is locked under another transaction and operation timeout
expired.
A Calculable implements support required by the Calculable interface
An adapter allowing to execute a
Callable in a distributed fashion.An adapter allowing to execute a
Callable using Space task executors.used to tell the LRMI layer to create a responseContext in order to support sending the response
back from a different thread than the calling one.
Exception thrown when a transaction cannot abort because it has already already decided to
commit.
Exception indicating failure to close a container.
Happens when
IJSpace can not be closed.Exception thrown when a transaction cannot commit on multiple partitions because it has already
aborted or must now be aborted.
Exception thrown when a transaction cannot commit because it has already aborted or must now be
aborted.
Exception indicating failure to create a container.
A failure to create a notify session.
Happens when
IJSpace can not be created.Happens when
IJSpace can not be found (when using jini/rmi protocol).Exception thrown when a transaction cannot be joined because it is no longer active.
Exception thrown when an object does not support nested transactions.
Known Limitation: 1.
Parses "<os-archive:cassandra-archive-handler>
Representing consistency level for read/write operations.
A
DocumentObjectConverter that does not fail if a type is missing during conversion.Contains constants values used in the Cassandra persistency layer implementation.
A Cassandra implementation of
SpaceDataSource.A configurer for creating
CassandraSpaceDataSource instances.A
FactoryBean for creating a singleton instance of CassandraSpaceDataSource.A Cassandra implementation of
SpaceSynchronizationEndpoint.A configurer for creating
CassandraSpaceSynchronizationEndpoint instances.A
FactoryBean for creating a singleton instance of CassandraSpaceSynchronizationEndpoint.Note: the underlying cassandra jdbc implementation brings the entire batch when calling execute,
so SQLException exceptions will actually only be thrown during prepare statement and execute
statment Moreover, the iteration over the results is currently only logical because the entire
result set already lies in memory after execute statement returns.
Casts a String into the wanted data object
Built in mathematical sql function to calculate the smallest integer value not less than the
given argument.
mostly concurrent chain segment can be used for LRU and FIFO eviction insertion is totally
non-blocking removal locks the specific node + its previous in order to keep balanced list, we
use segments in order to minimize contention
segments.
ChangeBulkDataItem is used in the case of change operation and if system property
com.gs.direct_persistency.return-changed-properties provided
ChangeBulkDataItem contains list of changed properties
Used to extract the
DataSyncChangeSet from operations that represent a change operation.The result of a change operation executed on an entry
Thrown when any error occurred when trying to perform change of entries
Thrown when an error occurred while performing a
GigaSpace#change(com.gigaspaces.query.IdQuery, com.gigaspaces.client.ChangeSet, com.gigaspaces.client.ChangeModifiers, long) operation.Extensions for the
GigaSpace.change(com.gigaspaces.query.ISpaceQuery, ChangeSet, ChangeModifiers, long) API which simplify common usage patterns.A
ChangeModifiers factory bean.Provides modifiers to customize the behavior of change operations.
A single change applied on a
ChangeSet when using a change operation on an object.A single change result which was applied on an object.
Change operation
Result of a change operation.
The set of changes to apply for matches entries of the change operation
A Channel Entry is an entry in the Pivot Channels Table.
Serializer for Character.
Built in string sql function to calculate the length of the string, measured in characters.
ConcurrentSkipListMap doesn't throw a ClassCastException on the first key if it is not Comparable.
Replication packet that is used by a replication target to check if the source is still
considered as the source of that target
check the state of a xtn in the tm using callback Created by yechielf on 13/10/2015.
A circle, denoted by a center point and radius.
Provides a class annotation string for classes defined by a class loader that is an instance of
this interface.
Provides support to annotate classes required for dynamic class loading in RMI
Base class for serialize/deserialize of space EntryData fields Object array into a byte array
Request for a class definition, includes class name, classloader id and type of resource to retrieve (CLASS or RESOURCE file)
Response to a class definition request, holds the class bytes
Helper for setting/getting any public properties.
A class loaders cache, each class loader is associated with a long key value All the class loader
are kept as weak references and can be explicitly removed
This utility class which helps to load the desired class by the context ClassLoader for current
Thread.
Holds thread local per class loader, get and set method will operate on the thread local which is
associated to the context class loader.
This class provides useful utilities for creating and manipulating class loaders.
Created by tamirs
on 11/9/16.
Provides static methods for loading classes using
RMIClassLoader with optional
verification that the codebase URLs used to load classes provide content integrity (see Security.verifyCodebaseIntegrity).Maps Class to ServiceType/Base, Class to EntryClass/Base, and Class to Field[], with caching for
efficiency.
Utility class for scanning classpath using Spring's ClassPathScanningCandidateComponentProvider
Created by IntelliJ IDEA.
A parser to make a
ClassVisitor visit a ClassFile structure, as defined in the Java
Virtual Machine Specification (JVMS).Exception thrown when the constant pool of a class produced by a
ClassWriter is too
large.Miscellaneous class utility methods.
A visitor to visit a Java class.
A
ClassVisitor that generates a corresponding ClassFile structure, as defined in the Java
Virtual Machine Specification (JVMS).Created by boris on 12/30/2014.
Context for clear operation - accumulates operation exceptions
Thrown when a space clear operation fails.
Thrown when a clear space operations fails.
A
ClearModifiers factory bean.Provides modifiers to customize the behavior of clear operations.
Implements the client side of the
net.jini.discovery.plaintext discovery format.Represents a constraint on authentication of the client to the server.
Created by Barak Bar Orion 12/29/14.
A client side selector thread that handles Async remote calls.
A server context element that can supply the client host address for the remote call.
Represents the functions clients can perform on a log file.
A marker interface for a specific
LogEntryMatcher marking it as needed
to have extra processing step when it is received on the client side.Represents a constraint on the client, such that if the client authenticates itself, then it may
only authenticate itself as one or more of the specified principals.
Represents a constraint on the client, such that if the client authenticates itself, then it may
only authenticate itself as principals that are instances of one or more of the specified
classes.
Represents a constraint on the client, such that if the client authenticates itself, then it must
authenticate itself as at least all of the specified principals.
Represents a constraint on the client, such that if the client authenticates itself, then it must
authenticate itself such that, for each specified class, at least one authenticated principal is
an instance of that class.
ClientPeer extends Peer with client-specific operations.
Provides invocation handler of
ClientPeer.Holds cpeer watched objects
At any given moment, at most 1 object is being watched.
A server context element that can supply the client subject for the remote call.
Interface for approving or rejecting client subjects during unicast discovery and decoding of
multicast requests.
The java.sql.Clob implementation.
This writer sub class is used with the Clob implementation.
ClosedResourceException is thrown when operation is performed while space is closing its
resources.
This exception is thrown in case of cluster configuration issues.
This exception is thrown as a result from a cluster-related problem This exception is unique to
the storage adapter.
Monitors cluster members proxies and detects proxy disconnections.
Copyright (c) 2010 GigaSpaces Technologies Ltd.
Holds cluster related information.
Allows for beans implementing this interface to be injected with
ClusterInfo.Created by yuvalm on 23/04/2014.
A Spring
BeanPostProcessor that takes a ClusterInfo and injects it to all the
beans that implements ClusterInfoAware interface and to those that contain a field that
has the annotation ClusterInfoContext}.Allows for beans to be injected with
ClusterInfo.ClusterInfo parser that parses -cluster parameter and
transforms it into a cluster info.Provides the
ClusterInfo parameters as injected
properties that can be used within Spring application context.Copyright (c) 2010 GigaSpaces Technologies Ltd.
This lookup attributes providing registration space with cluster name class name.
Holds the cluster policy data.
Copyright (c) 2010 GigaSpaces Technologies Ltd.
The COALESCE function returns the first of its arguments that is not null.
Created by Barak Bar Orion A marker class.
Created by tamirs
on 11/8/16.
Created by tamirs
on 12/8/16.
A result for changing a collection property
TODO add Javadoc
Miscellaneous collection utility methods.
A data holder for a column data and metadata, used for both read and write operations.
A simple
ConcurrentMap based cache to store ColumnFamilyMetadata in-memory.A singleton instance of
ColumnFamilyMetadata for the column family used internally on
Cassandra to store all introduced types as ColumnFamilyMetadata blobs.An interface for converting type names to a matching Cassandra column family names.
A data holder for holding the row columns and the matching column family metadata.
Encapsulates information on a table's column.
A common interface for column based
TypeNode implementations.This is a column Node.
A simple command line parser transforming a list of string arguments into
CommandLineParser.Parameter arguments.A free-form comment about a service.
An implementation of a
Job which interacts with a set of
TransactionParticipants to inform them to roll forward changes associated with a
given Transaction.This class handles the COMMIT or ROLLBACK logic.
The CommonClassLoader implements
ComponentLoader interface and is
created by the RioServiceDescriptor or org.jini.rio.boot.RioActivatableServiceDescriptor when starting a Rio service and contains
common declared platform JARs to be made available to its children.Licensed to the Apache Software Foundation (ASF) under one or more
contributor license agreements.
A common basic implementation for comparable scalar comparison predicate implementations.
A compiled script cache.
Represnts a pool of compiled scripts that should work with a non thread safe compiled scripts in
conjuction with
CompiledScriptCache.A factory for
CompiledScriptPool instance.The ComponentLoader provides a mechanism for the ServiceBean to load classes and resources (such
as native libraries) making them (and the resources it uses) available to all services
CompositeRange indicates a result of a complex intersection that can't be translated to a single
range.
Recover from one of the given recovery groups.
A Composite space mode listener
A common basic implementation for composite space predicate implementations.
Provides a logical AND combination for a list of custom queries.
Scans the indexes and gets index with the least number of entries.
using a common root query for item in collection-contains.
Custom index for a multi-segments index compoused of other (not compound) indexes
A dump results that holds one or more Dump results.
a future implementation used to aggregate results from multiple Futures.
definition of a compound index meta data
Describes compound index
segment for a compound index structure
Holder for compound index value of > 2 segments
Holds a list of
LogEntries.Provides a logical OR combination for a list of custom queries.
Scans the indexes and gets the union of all indexed entries.
Compound processing unit container wraps several processing unit containers and allows to close
them.
This Object was created in order to implement GigaSpaces CompoundId logic
Extending this object will result in inherit all the capabilities of CompoundSpaceId
In order to use this, please implement your CompoundId pojo as explained:
use EmbeddedId hibernate annotation on your getter for the compoundId instance in your POJO that holds the conpoundId
use @Embeddable hibernate annotation on your class in order to use this in hivernate
Implement your empty constructor with call to super with the number of values you have in your compoundID
public MyCompoundSpaceId() {
super(2);
}
Defines a compound space index.
Defines multiple CompoundSpaceIndex annotations for a POJO.
Extension to
TypeNode to denote compound type nodes (POJOs, VirtualEntry)CompressedMarshObject extends MarshObject by keeping the byte array zipped by GZIP.
Notice! this implementation is not Thread safe and should be use in conjunction with
ResourcePool only.Built in string sql function to concatenate any number of given string arguments.
Concurrent bounded cache.
Provides a concurrent HashSet implementation.
note- concurrent LRU is not an "accurate" eviction policy in the sense that the number of
objects stored can be lower than the limit defined but new objects will be rejected.
A simple implementation wrapping several iterators and exposing them as concurrent iterator using
a fixed size thread pool.
TODO add Javadoc
Deprecated.
Since 10.1.0 - use ConcurrentBoundedSoftCache instead
Represents a constraint on the confidentiality of message contents.
Provides static methods for getting entries from a
Configuration.Parses multiple -config parameter by adding it to
ApplicationContextProcessingUnitContainerProvider.addConfigLocation(String).Defines an interface for obtaining objects needed to configure applications, such as
Exporter or ProxyPreparer instances, or other application-specific objects, from
configuration files, databases, or other sources.Thrown if a problem occurs when obtaining configuration information.
Thrown if a problem occurs when obtaining configuration information.
Supplies objects needed to configure applications, such as
Exporter or ProxyPreparer instances, or application-specific objects, constructed from data in a
configuration source and override options, as well as data supplied in the call to
getEntry.Class used to represent a syntax error encountered when parsing a configuration source or a
problem encountered when attempting to return an existing entry or the type of an existing
entry.
Thrown if a configuration source location specified when creating a
Configuration is
not found, including if null is specified for provider options and the
implementation does not provide default options.Provides a standard means for obtaining
Configuration instances, using a configurable
provider.A set of static convenience methods for use in configuration files.
A base class for gateway conflicts.
Defines which policy to use when replication conflicts with the target data.
A base class for a gateway replication Sink component conflict resolver.
Replication packet that is used to establish replication channels between a
IReplicationSourceGroup and a IReplicationTargetGroupRepresents a constraint on the absolute time by which a network connection must be established.
The context of the
GConnectionEncapsulates details about a connection end point.
ConnectionPool for reuse of LRMI Connections (an LRMI Connection is abstracted by a Client Peer).
Represents a constraint on the maximum amount of time to wait for a network connection to be
established.
An encapsulation of a ClientPeer resource
A
IResource representing a Connection.A
IResourceFactory for obtaining ConnectionResource instances.Provides means for generating connection url from its description and creating the descriptor
from the connection url in its string form.
Invocation Handler for a Dynamic Proxy wrapping a Connection Pool.
Specifies consistency level for a modifying (replicated) operation
User: Barak Bar Orion Date: 8/7/14
Thrown when an operation is rejected since the
ConsistencyLevel for that operation cannot
be maintained.Thrown when an operation is rejected since the
ConsistencyLevel for that operation cannot
be maintained.Deprecated.
Part of the legacy metrics reporter system driven by
metrics.xml.Deprecated.
Part of the legacy metrics reporter system driven by
metrics.xml.Consolidated distributed transaction meta data representation.
Logs given message to given logger.
Contains the data of a single participant within a consolidated distributed transaction
A constant whose value is computed at runtime, with a bootstrap method.
Authority string format constants.
This class contains all constants of GigaSpaces Platform.
A holder class for constants that pertain to the unicast and multicast discovery protocols.
EventLease subclass that supports constraints.
Constrainable sub-class of
LandlordLease.Constrainable sub-class of
LandlordLeaseMap.LookupLocator subclass which supports constraint operations through the RemoteMethodControl interface.Trust verifier for
ConstrainableLookupLocator instances.A collection of utility methods for use in implementing constrainable proxies.
Combines two or more constraint alternatives into a single overall constraint.
Trust verifier for instances of the constraint classes defined in the
net.jini.core.constraint package, and for the BasicMethodConstraints, X500Principal and KerberosPrincipal classes.This structure contains all information about container configuration.
ContainerConfigFactory
Container name attributes for registering to LookupService.
Copyright (c) 2010 GigaSpaces Technologies Ltd.
Collection contains composite range.
info for contains items intersection.
node holding a single item inside contains, or a hole expression pointed by value
a contains predicate cascading from a single item
node holding a root inside contains - points at a subtree of containItemNodes
a range for c collection imposede on single item rendered.
Built in sql function to check if a map field contains some key
An expression node for a contains argument.
Represents a contains predicate.
A matcher filter that will filter out all log entries that do not contain the provided string.
Represents a value range used by ContainsNode.
Interface for performing two-way encryption and decryption on objects.
Base class for Callable implementations which should run in a specific class loader.
Base class for Runnable implementations which should run in a specific class loader.
A bean definition builder for
SpaceModeContextLoader.Represents permissions used to express the access control policy for elements commonly found in
the context collections available from
ServerContext and ObjectStreamContext.Utility class that deals with context properties
A reusable matcher (not thread safe) which accepts a matcher that returns the log entries for the
first call, and for any other call, a
AfterEntryLogEntryMatcher will be used with the
last log entry returned.some helper methods to the SpaceApiController class
Open ended thread safe cache for XAP connections
Created by ester on 03/02/2016.
Error thrown when a numerical computation can not be performed because the numerical result
failed to converge to a finite value.
Created by Barak Bar Orion 12/30/14.
This class is a ConversionException if something went wrong while conversion.
Wraps an
ISpaceCopyReplicaState as a ISpaceSynchronizeReplicaState that the sync
is considered done after the copy stageProvides a ConcurrentMap implementation.
Provides a ConcurrentMap implementation.
Copy on update implementation of
ISafeArrayProvides a concurrent HashSet implementation.
A Spring name space handler for OpenSpaces core package.
Executes count/clear operation on the space
Hold the count info when count is called
A
CountModifiers factory bean.Provides modifiers to customize the behavior of count operations.
CPeer is the LRMI over NIO Client Peer.
Calculates the cpu percentage by dividing the total CPU values by delta time passed in
milliseconds.
Fluent API for creating a new
CpuPercentageTimeWindowStatisticsConfigurer objectA bean definition builder for
CpuRequirement.A CPU Utilization alert fired upon triggered CPU thresholds.
A CPU utilization alert configuration.
A CPU utilization alert configurer.
CQL query context for holding the properies map if this is a template based query or the
String query and the parameters array if this is a complex query.Exception thrown when a transaction cannot be joined because the participant's current crash
count is different from the crash count the manager received in a previous join by that
participant.
A CreateException is thrown if an attempt to create a new space fails.
This class handles the CREATE TABLE logic.
Returns current date formatted
Returns current time formatted
Get username for this session
Configures the Space to run in Custom mode.
A factory for creating
CustomCachePolicy instance.A base class for custom change operation implementations
Default implementation of the space custom index meta data
Custom index for a multi-value type collection/array NOTE- it is assumed that each element has
consistent hashCode() and value() methods
This class should be used by customers in order to implement their ServiceDetails
This class should be used by customers in order to implement their ServiceMonitors
Defines an annotation for defining custom space indexes.
This is used to specify custom lrmi tracking of a method.
Container for custom space indexes of given type - stores the actual indexes data structures
Variation on hector's type inferring serializer to also include support for big decimal type,
float type and double type, to avoid possible NullPointerException and to use the map based
SerializerProvider instead of hectors SerializerTypeInferer.Created by IntelliJ IDEA.
API for reading metadata from a database using JDBC.
Provides an interface for resolving data conflicts.
Provides an interface for handling a conflicting data operation.
Deprecated.
since 9.0.1 -
DataSyncOperationType.Signal a consume ok result
The common interface that is used when working with data events.
listeners can be registered using the addListener() methods and receive
an EventRegistration that will be used to unregister using the removeListener().
listeners can be registered using the addListener() methods and receive
an EventRegistration that will be used to unregister using the removeListener().
Factory class for creating data event sessions.
Factory that produces byte buffers, each corresponding to a separate datagram packet to be sent.
DataIterator iterates the data provided by the
and the
Data iterator is closed after use.
DataProvider and the
SQLDataProviderData iterator is closed after use.
A simple adapter from
Iterator to DataIteratorDeprecated.
since 9.5 - use
SpaceSynchronizationEndpoint instead.Deprecated.
since 9.5 - use
SpaceDataSource instead.Deprecated.
since 9.5 - use
SpaceDataSourceSplitter instead.A bean definition builder for
SpaceDriverManagerDataSource.DataSourceException thrown in case of an external data source failureRepresents a query by ID executed against a
SpaceDataSource implementation.Represents a query by IDs executed against a
SpaceDataSource implementation.Represents a query executed against a
SpaceDataSource implementation.Represents a parameterized SQL query of a
DataSourceQuery instance.Data Storage is a delegator over user defined data source-interface implementation.
Contains details for a
DataSyncOperation of type DataSyncOperationType.CHANGE.Represents a single data operation
Represents the data operation type.
A
ConflictCause implementation for a type introduction operation conflict.Adds a time/date interval to a date and then returns the date
Returns day name
Returns day of month
Returns day of week
Returns day of year
Supports single serializer and single deserializer
Deprecated.
Part of the legacy InfluxDB reporter infrastructure.
Configures a
DBSwapRedoLogFileConfigCreated by moran on 12/4/17.
A plain java object representing an alert issued by an alert bean or an alert provider.
Default container for async result
The default remote implementation used to retrieve class definition or resources from a remote
JVM.
A
ColumnFamilyNameConverter implementation that works as follows: If the type names
length does not exceed a 48 characters length, the dots in the type name will be replaced by
underscores.Default implementation for Sink conflict resolver.
The default exception translator.
position fifo requests for notify and non-notify templates background search and consume
A
FlattenedPropertiesFilter implementation that will return true for all
fixed properties and false for all dynamic properties.An implementation of the
GigaMap interface simplifying the work with JCache and Map
interface on top of the Space.Default implementation of
GigaSpace.Default implementation of
GigaSpaceTypeManager.A default network mapper based on a configuration file named "network_mapping" simply maps a
given address to the other as specified in the configuration file
This class performs 3 calculations on raw statistics: timeWindow, agentZones and instances
calculations in order to transform the raw statisticsId into the requested statisticsId
raw statisticsid read from pu instance (timestamp = now): ["mybean", "memory" ,
LastSampleTimeWindowStatisticsConfig, SingleInstanceStatisticsConfig("instance1"),
ExactZoneConfig("zone1")]
time calculated statisticsId (timestamp = now, but the calculator averaged the last 60 seconds):
["mybean", "memory" , AverageTimeWindowStatisticsConfig(60), SingleInstanceStatisticsConfig("instance1"),
ExactZoneConfig("zone1")]
zone calculated statisticsId (the zone is changed to reflect the requested statisticsId):
["mybean", "memory" , AverageTimeWindowStatisticsConfig(60), SingleInstanceStatisticsConfig("instance1"),
AtLeastOneZoneConfig("zone1")]
instances calculated statisticsId (the instances changed to reflect the average across all
instances) This is also the requested statisticId: ["mybean", "memory" ,
AverageTimeWindowStatisticsConfig(60), AverageInstancesStatisticsConfig ,
AtLeastOneZoneConfig("zone1")]
Deprecated.
Used only by the legacy
MetricManager.Default implementation for of
MarshalPivot providing a proxy replacement on the LUS.The default replication filter provider factory allowing to configure an input and output filter
of
IReplicationFilter.The default behavior that actually sends the response to the client.
A Default "server" side script executor.
The default
SpaceDocumentColumnFamilyMapper implementation.class helper to map from mongo document type to SpaceDocument and vice versa
Default implementation for building the SQLQuery.
Created by yechielf on 05/03/2015.
An implementation of an
ExecutorService that uses the executors
support implemented in GigaSpace.Default transaction provider works in conjunction with
JiniPlatformTransactionManager and one of its derived classes.Deprecated.
Use
DefaultCredentialsProvider instead.TODO add Javadoc
Interface implemented by classes which decode multicast announcement data and additionally
support delayed constraint checking.
Interface implemented by classes which decode multicast request data and additionally support
delayed constraint checking.
used in blobstore bulks + embedded list in order to perform replication after flush
used in blobstore bulks + embedded list in order to perform replication after flush
Created by yechielf on 08/12/2015.
used in blobstore bulks + embedded list in order to perform replication after flush
used in blobstore bulks + embedded list in order to perform replication after flush
A delegating task is a task that holds another task that will be executed.
Represents a constraint on delegation from the client to the server.
Represents a constraint on delegation, such that if delegation is permitted, it be permitted only
for a range of absolute times.
Represents a constraint on delegation, such that if delegation is permitted, it be permitted only
for a range of time measured relative to the start of the remote call.
A backup policy that deletes any file which is older than the specified period, but
keeps at least as many of the specified backup files.
This class handles the DELETE query logic.
Deployment status indicates a
ProcessingUnit deployment.Subinterface of
LeaseListener that clients must implement if they want to receive
desired expiration reached events in addition to renewal failure events.Admin interface for destroying a service.
A DestroyedFailedException is thrown if an attempt to destroy an existing space fails.
A DetailedUnusableEntryException is thrown when class version compatibility error, the space
server contains an older version of class.
Created by Kobi on 6/10/14.
A replication connection monitors for connection that are established with a direct connection
proxy.
Springs transaction manager (
PlatformTransactionManager
using directly injected Jini TransactionManager.A
DirectoryAccessDeniedException is thrown as a result of an access restriction when
calling SecurityManager.createDirectoryManager(UserDetails).internal space exception thrown from the engine's directory.
An interface for user and role management.
A helper class for managing the directory.
The actual i/o of DirectPersistencyOpInfo objects
The synchronizing direct-persistency list handler
The element of synchronizing a direct-persistency multiple uids(transaction result)
the list of elements overflowen when # in memory exceeds a defined minimum enables locating
groups of elements bwteen redokey values
the list segment where the ops list is overflowen to persistency
Created by yechielf on 05/03/2015.
helper functions in order to maintain direct-persistency recovery consistency
The element of synchronizing a direct-persistency uid
The synchronizing direct-persistency handler
The synchronizing direct-persistency handler
The synchronizing direct-persistency handler
A direct space factory bean, initialized with an existing
IJSpace and provides it as the
space.A discoverable component is a component that is found from the lookup service.
Class providing methods for participating in versions 1 and 2 of the discovery protocol.
Methods for controlling which groups a lookup service is a member of, and for controlling which
TCP port a lookup service uses for its lookup locator.
This interface must be implemented by entities that wish to receive notification of the following
events.
Class for processing constraints which apply to the discovery protocol:
DiscoveryProtocolVersion, MulticastMaxPacketSize, MulticastTimeToLive, UnicastSocketTimeout, ConnectionRelativeTime, ConnectionAbsoluteTime.Trust verifier for instances of the constraint classes defined in the
com.sun.jini.discovery package.Event object passed (via either the
DiscoveryListener interface or the
DiscoveryChangeListener) to indicate to interested parties that one or more
ServiceRegistrar objects have been discovered or discarded during the discovery
process.Interface implemented by all discovery format provider classes, which is used by the
Discovery class to identify format providers available via resource, as described in the
documentation for the Discovery.getProtocol2(ClassLoader) method.This interface defines methods and constants related to the management of the sets of lookup
services that are to be discovered using the multicast discovery protocol; that is, lookup
services that are discovered by way of group discovery.
This interface must be implemented by parties that wish to obtain notifications from a
LookupDiscovery object.
This interface defines methods related to the management of the set of lookup services that are
to be discovered using the unicast discovery protocol; that is, lookup services that are
discovered by way of locator discovery.
This interface defines methods related to the discovery event mechanism and discovery process
termination.
Permission for using LookupDiscovery.
Exception indicating a discovery protocol error, such as failure to interpret packet data, or
multicast request/announcement data that cannot fit within a given packet length.
Represents a constraint on the version of the discovery protocol used to contact lookup services.
Aggregator for fetching distinct entries - based on some fields.
A transaction manager that starts an embedded distributed mahalo transaction manager.
A simple configurer for
DistributedJiniTransactionManager.an extended SpaceTask that is being used in broadcast.
A distributed task is a
Task that is executed on several
space nodes, requiring to AsyncResultsReducer.reduce(java.util.List) the list of AsyncResults.A provider for a distributed Jini (embedded) transaction manager.
A bean definition parser for distributed transaction support configuration for mirror component.
A bean for configuring distributed transaction processing at Mirror component.
A bean definition builder for
DistributedJiniTransactionManager.Returns the the subtraction of two objects
This class provides method to convert POJO classes to
SpaceDocument and vice versa.An implementation of
Map optimized for usage with SpaceDocument.Wrapper class for old .NET StorageType enum.
Serializer for Double.
Permission that must be granted to the
CodeSource of a downloaded class in order for the
class to be defined using RMIClassLoader.Thrown when drop class operation failed.
The Drop table implementation.
A dump download listener allowing to track the downloading of dump result.
When generating dump across several components (dump providers) allows to be notified when a dump
was generated.
Elements in the admin API that support dump operations.
A results of a dump operation.
This exception is thrown when a write or update operation encounters a duplicate value for unique
index
A
TypeNode implementation representing a dynamic column for which no metadata exists on
the matching Cassandra column family.Marking a listener method with this annotation will result in its return value to be used as the
template for the event container.
A template provider allowing for custom implementations to provide a template used for matching
on events to receive.
Factory and utility methods for handling
DynamicThreadPoolExecutor.Interface implemented by security policy providers that may support dynamic granting of
permissions at run-time.
Security policy provider that supports dynamic granting of permissions at run-time.
a
Serializer implementation based which uses DynamicPropertyValueSerializerSerialized objects will contain a prefix denoting the type of the value and will be deserialized
appropriately based on this prefix.
Much like a
SynchronousQueue which acts as a rendezvous channel.This class represents dynamic smart stub of underlying transport protocol.
Holds a source group config which allows dynamic atomic updates to the group config and notify
listener once such a change is done.
An
ExecutorService that executes each submitted task using one of possibly several pooled
threads, normally configured using DynamicExecutors factory methods.Denotes that a
ProcessingUnitStatisticsId applies to all of the Processing Unit.A hash table supporting full concurrency of retrievals and adjustable expected concurrency for
updates.
ConcurrentHashMap list entry.
This exception thrown on attempt to access space with non clustered proxy while space
undergoing election process.
The synchronizing direct-persistency embedded list op info
Created by yechielf on 15/11/2015.
Embedded Sync- info regarding generation ids from which not all embedded info used surly
transferred to the sync list
Embedded Sync- info regarding generation ids from which not all embedded info used surly
transferred to the sync list
The synchronizing direct-persistency embedded list op info
The synchronizing direct-persistency embedded list handler
Embedded Sync- info regarding transferred records per segment
The synchronizing direct-persistency embedded segment handler
Embedded Sync- info regarding transferred records per segment
Embedded Sync- info regarding transferred records per segment used in order to avoid updating the
entry each time op was transferred to regular list
A
Configuration with no entries.Represents a CredentialsProvider with null UserDetails.
Represents an empty range - range that always translates to an empty query
A dummy implementation of the
StorageReadOnlyIterator that acts as an empty iteratorException indicating that a configuration for an already enabled bean can't be changed unless
first disabled.
Iterator for performing multicast encode operations on (potentially) multiple discovery format
providers.
All encoding related exceptions thrown while trying to encode/decode.
internal space exception thrown from the engine
Iterator for entries.
This class is the supertype of all entries that can be stored in a Jini(TM) Lookup service.
Wraps space EntryHolder and supplies seamless conversion
to used defined types
A
ConflictCause implementation for an entry already in space conflict.This exception is thrown when write operation is rejected when the entry (or another with same
UID) is already in space.
This exception is thrown when write operation is rejected when the entry (or another with same
UID) is already in space.
a factory for entry-arrived packets, which holds an inner bound pool which fills on-demand.
An EntryArrivedRemoteEvent is sent to a NotifyDelegator object when an entry that matches the
delegator's template enters a GigaSpace.
Copyright (c) 2010 GigaSpaces Technologies Ltd.
An EntryClass is a descriptor for an entry class, packaged up for transmission between
client-side proxies and the registrar server.
An EntryClass annotated with a codebase.
Indicates how entry data is stored.
This exception is thrown when the updated entry does not exist in space in optimistic locking
scenarios.
Copyright (c) 2010 GigaSpaces Technologies Ltd.
This class represents an entry in a GigaSpace.
Factory to create EntryHolder instances.
Entry with type table information.
Key in the EntryInfo table.
Thrown when an operation could not be completed because an entry was locked by another
transaction.
A
ConflictCause implementation for an entry locked under transaction conflict.A
ConflictCause implementation for an entry not in space conflict.This exception is thrown when update operation is rejected.
This exception is thrown when
update, readIfExist or
takeIfExist operations are rejected.This class represents a packet of information transmitted between a J-Space client and its
J-Space server (and vice versa).
EntryPacketDataConverter is a wrapper for the IPojoToEntryConverter .a factory for IEntryPacket that depends on the type of the request.
An EntryRep contains the fields of an Entry packaged up for transmission between client-side
proxies and the registrar server.
This RuntimeException thrown when failed to serialize or deserialize Entry field.
Thrown when failed to serialize or deserialize Entry field.
Entry snapshot class.
Copyright (c) 2010 GigaSpaces Technologies Ltd.
A bus packet that is used to search for override notify templates.
A
ConflictCause implementation for an entry version conflict.This exception is thrown when update/take operation is rejected as a result of optimistic locking
version conflict.
contains all the per-entry transaction information.
This class holds
key, value and Attributes that are
associated with the key.This is the equal operator Node.
An implementation of equals to comparison: This predicate returns true if and only if the
predicate's argument is equal to the expected value.
A placeholder for an undefined time window statistics configuration that respects window size in
its
AbstractConfig.hashCode() and AbstractConfig.equals(Object) method.Holds dynamically generated event containers.
A generic event container service details.
A generic event container service monitors.
The EventDescriptor describes an event that an EventProducer will advertise as part of it's
attribute set in a Jini Lookup Service.
A simple marker interface denoting a class to be event driven.
An annotation used to inject
EventDrivenSpaceRemotingProxyFactoryBean
into a field.A bean definition builder for
EventDrivenSpaceRemotingProxyFactoryBean.A Space remoting future implementation.
An annotation used to configure method level behaviour for event driven remoting proxies, which
are eventually configured through
EventDrivenSpaceRemotingProxyFactoryBean.A simple programmatic configurer creating a remote asyncronous proxy
Allows to inject a
ScriptingExecutor remoting proxy
using EventDrivenSpaceRemotingProxyFactoryBean.A simple programmatic configurer creating a remote event driven scripting proxy
Default implementation of a remoting entry that acts both as a remote invocation and a remote
result.
Default implementation of a remoting entry that acts both as a remote invocation and a remote
result.
A space event driven remoting proxy that forward the service execution to a remote service
with the space as the transport layer.
An exception handler to handle exception when invoking event listeners.
When a registrar (lookup service) grants a lease on an event registration on behalf of some
object (client), a proxy is employed to allow the client to interact with the lease; this class
is the implementation of that proxy.
Abstraction for managing renewal of event registration leases.
The EventProducer defines the support for an event consumer to register for events a service
produces
A utility class for use as a return value for event-interest registration methods.
Created by Barak Bar Orion 7/7/15.
a common interface for all EventSession types
a session is a stateful service used to register event listeners to the space
the state of the session contains a set of configuration parameters such as the communication protocol
used to convey the events and whether of not to use FIFO order
the session can be used to register multiple listeners that share the same configuration.
a session is a stateful service used to register event listeners to the space
the state of the session contains a set of configuration parameters such as the communication protocol
used to convey the events and whether of not to use FIFO order
the session can be used to register multiple listeners that share the same configuration.
this class is used to configure an EventSession.
Deprecated.
Since 9.7.0 - Use GigaSpace.newDataEventSession instead.
A simple class that can trace events with a predefined limited record length
Marking a listener method with this annotation will result in its return value to be used as the
template for the event container.
A template provider allowing for custom implementations to provide a template used for matching
on events to receive.
Encapsulates information about a server entry.
repository for replication markers - used in order to prevent eviction of entries that did not
reach the async replication target yet (currently mirror)
Deprecated.
Scans the index with the defined index name only for entries that match the exact index value
An exact value index scanner for compound index
An annotation marking a method as one that is responsible to return a
EventExceptionHandler to be used with event containers.Deprecated.
since 9.5 - use
PersistencyExceptionHandler instead.Translates a low level JavaSpaces/Jini exception into a
DataAccessException runtime
exception.Performs a single take usign
GigaSpace.asyncRead(Object) under
exclusive read lock.Performs single read operation using
GigaSpace.read(Object, long, ReadModifiers) under an exclusive read lock.represent a task wrapper used inside a filter.
Executor is an abstraction for a thread factory or thread pool for executing actions
asynchronously.
The executor builder allows to combine all the different types of executing tasks into a single
execution (of course, the execution itself, of all the tasks, is asynchronous).
A helper class allowing to extract meta data related to executors/tasks (such as routing
information).
An annotation used to inject
ExecutorSpaceRemotingProxyFactoryBean into a field.A bean definition builder for
ExecutorSpaceRemotingProxyFactoryBean.An annotation used to configure method level behaviour for executor remoting proxies.
A simple programmatic configurer creating a remote executor based proxy
A
Task that can be used to simulate remote invocation with
SpaceRemotingServiceExporter.A wrapper executor exception that holds more information on the exception, such as the
instance id.
A wrapper executor result that holds more information on the exception, such as the instance
id.
Created by Barak Bar Orion 19/08/14.
Allows to inject a
ScriptingExecutor remoting proxy
using ExecutorSpaceRemotingProxyFactoryBean.A simple programmatic configurer creating a remote executor scripting proxy.
A space executor remoting proxy that forward the service execution to a remote service
with the space as the transport layer.
Represents an holder for an existing Jini transaction, usually when propagating existing to space
task.
Marks an API (class, method, etc.) as experimental, i.e.
Wraps GResultSet when explain plan must be returned
Base class representing the format of ExplainPlan
ExplainPlan for the JDBC Driver V3
This is the main expression node.
An abstraction for exporting a single remote object such that it can receive remote method
invocations, and later for unexporting that same remote object.
Defines runtime permissions for
Exporter implementations.extention of answer-holder contains prev and current entry snapshot + extended error info.
Deprecated.
since 12.3 use OrderedIndex or EqualOrdered instead
Handles data manipulation of space extended index
prepare result returned when clusterd proxy is needed
additional apis for transaction manager
Deprecated.
since 9.5 - use
SpaceDataSource and SpaceSynchronizationEndpoint
instead.Deprecated.
Since 8.0 - This class has been deprecated and will be removed in future versions.
Represents an ExternalEntry as an IEntryPacket
Serializer for Externalizable.
the entry packet used to move
Externalizable object from the proxy to the server.Implements
ITemplatePacket for Externalizable classes.Tag for
TypeNode implementations that should be persisted to the internal cassandra
metadata column family.no Lock version of StoredList locks should be external to this class scanning after establishing
a starting position should be left lock free
Created by IntelliJ IDEA.
Extract function, implementation is in the xap-jdbc module, designed to run only with the Data Gateway
The result of a change operation of a specific entry that raised an exception
FailoverGroupRecovery defines how to recover in failover group
Copyright (c) 2010 GigaSpaces Technologies Ltd.
A
ClusterFailureDetector based implementation of the IConnectionMonitor
interface.A space predicate that always returns false.
A marker interface indicating that a thread is capable of performing
Thread.setContextClassLoader(ClassLoader) and fast (without the security overhead).The FaultDetectionHandler is loaded by client entities do determine whether a service is
reachable.
The FaultDetectionListener allows a client to be notified by a
FaultDetectionHandler that a service is unreachableFetch the endpoint replication details back to the caller
Interface representing a field.
Interface representing field elements.
Base class for recursive field processing
This exception is thrown when a field-value cannot be cloned.
A visitor to visit a Java field.
holds info for scanning waiting templates as a result from fifo operations both notify and
non-notify templates
this is an event listener wrapper that delivers FIFO notifications to the inner listener
the order is kept per source (space).
the order is kept per source (space).
a comparator for entries TreeMap, the objects are EntryHolders.
first-in first-out (as opposed to LIFO, last-in first-out) Items come out in the same order they
came in.
this exception is thrown when a searching entry or transaction is rejected in time of fifo
initial search
TODO add Javadoc
extentions for fifo-groups compound index
Handles extended index of fifo groups scans
Determines a Space index type For Fifo-groups usage.
extentions for fifo-groups main index
TODO add Javadoc
TODO add Javadoc
TODO add Javadoc
TODO add Javadoc
TODO add Javadoc
search for fifo-groups matching templates.
Helper class to map from binary fifo to tri-state fifo.
Parent exception class of all Fifo Exceptions.
search for fifo matching templates.
Determines FIFO operations support.
Serializable content to be written to a file.
A file based
DirectoryManager responsible for managing users and roles stored in a file.An encoding manager encapsulating the different encoders used by the file-system implementation.
Integrity verifier for FILE URLs.
A free port generator that uses file locks in order to obtain a port.
The possible file modes for log files.
Deprecated.
Part of the legacy metrics reporter system driven by
metrics.xml.Deprecated.
Part of the legacy metrics reporter system driven by
metrics.xml.A file based
RoleManager responsible for managing roles stored in a file.A File based
SecurityManager responsible for authenticating requests against users stored
in a file, and creating a FileDirectoryManager for managing the directory.Defines an interface for accessing
UserDetails and RoleDetails stored in a file.An internal accessor on top of a
FileService, holding a file-content cache, and the
encoding manager.Miscellaneous file system manipulation methods.
GS-14704
A patch for org.springframework.util.FileSystemUtils.copyRecursively method that from 5.0
the implementation no longer supports symbolic links
see pull request: https://github.com/spring-projects/spring-framework/pull/24823
Enum of type of file (class/resource) to be loaded by the class provider.
A file based
UserManager responsible for managing users stored in a file.A nested runtime exception wrapping a filter execution exception.
Copyright (c) 2010 GigaSpaces Technologies Ltd.
This class declares static fields for filter operation codes.
An
ISpaceFilter implementation that acts as an
adapter delegating the execution of the filter lifecycle methods and specific operation to
pluggable reflection based methods.A filter provider acts as a wrapper around an
ISpaceFilter
allowing to provide a an already instantiated filter using SpaceFinder with custom Properties.A filter provider factory is a bean responsible for creating / providing
FilterProvider implementation.This class contains all information about space filter configuration.
A FinderException is thrown if an attempt to find space or container fails.
A matcher that will be executed only on the first log file.
Simple implementation of
LeasePeriodPolicy that grants lease times based on a fixed
default and maximum lease.A swap based implementation of the
IRedoLogFile interface, A fixed number of packets can
be held in the memory and once this number is exceeded the other packets are stored in a provided
INonBatchRedoLogFileStorageConfigures a
FixedSizeSwapRedoLogFileConfigAn interface used to denote whether a given property should be flattened.
Serializer for Float.
Built in mathematical sql function to get the largest integer value not greater than the given
argument.
A handler for rejected tasks that adds the specified element to this queue, waiting if necessary
for space to become available.
A forward chunk that iterates over all the log files, from start to end.
Representation of a rational number.
Error thrown when a double value cannot be converted to a fraction in the allowed number of
iterations.
Representation of the fractional numbers field.
Formats a Fraction number in proper format or improper format.
Created by Kobi on 6/10/14.
A free port generator.
A handle to release a locked port and get the obtained port.
Created by Barak Bar Orion on 2/9/16.
ExecutorService limited to methods using Future.A factory for different types of special futures, such as compound ones.
A Garbage Collection duration alert, fired upon triggered GC thresholds.
A Garbage Collection pause alert configuration.
A Garbage Collection pause alert configurer.
This class clean hashtable of already taken entries or written entries under transactions.
A gateway is a composition of one or more of
GatewayProcessingUnits, and it is in charge
of replication between different Spaces.An event listener allowing to listen for
Gateway additions
(deployment).An event manager allowing to add and remove
GatewayAddedEventListeners.Holds gateway delegation settings.
A bean definition parser for a
GatewayDelegation.A gateway delegator is used to delegate outgoing replication packets to other gateways.
A bean definition parser for
GatewayDelegatorFactoryBean.A gateway delegator factory bean for creating a
ReplicationConnectionDelegatorContainer.Provide service details of
GatewayDelegatorFactoryBeanRepresents a single delegation target
An event listener supporting combining several listeners into one simple listener.
Holds information used for gateway lookup.
A bean definition parser for
GatewayLookup.A bean definition parser for
GatewayLookupsFactoryBean.A gateway lookups factory bean for constructing
ReplicationLookupParameters using the
GatewayLookupsFactoryBean.asReplicationLookupParameters() method.A spring namespace handler for the "gateway" namespace.
Specifies policy of a single replication gateway
A Gateway Processing unit is the building block of a
Gateway.An event listener allowing to listen for
GatewayProcessingUnit
additions (deployment).An event manager allowing to add and remove
GatewayProcessingUnitAddedEventListeners.An event listener supporting combining several listeners into one simple listener.
An event listener allowing to listen for
GatewayProcessingUnit
removal (undeployment).An event manager allowing to add and remove
GatewayProcessingUnitRemovedEventListeners.Holds one or more
GatewayProcessingUnits.An event listener allowing to listen for
Gateway removal
(undeployment).An event manager allowing to add and remove
GatewayRemovedEventListeners.Gateways holds all the different
Gateways that are currently discovered.Provide service details of a gateway
AbstractGatewayComponentFactoryBeanA sink is a
GatewayProcessingUnit component which handles incoming replication from other
gateways.A bean definition parser for
GatewaySinkFactoryBean.A bean definition parser for distributed transaction support configuration for gateway sink
component.
A bean for configuring distributed transaction processing at Sink component.
A sink factory bean for creating a
LocalClusterReplicationSink which represents a gateway
sink component.Provide service details of a
GatewaySinkFactoryBeanA sink source is the target end point of a remote
Gateway which is replicating into this
gateway's sink.A bean definition parser for
GatewaySinkSyncEndpointInterceptorFactoryBean.A factory bean used for configuring the Sink component synchronization endpoint interceptor
configuration.
Holds gateway source configuration.
A bean definition parser for a
GatewaySource.Specifies policy of replication gateways
Holds gateway target configuration.
A bean definition parser for
GatewayTargetsFactoryBean.A factory bean for creating a
GatewaysPolicy instance.Deprecated.
Use Micrometer's
Gauge instead.The connection implementation that connects to the QueryProcessor on the GigaSpaces server side.
The DatabaseMetaData implementation
GigaSpaces JDBC driver implementation.
A
ConflictCause implementation for a general conflict.General replication filter.
This class provides generic exporting of multiple remote objects such that it can receive remote
or local method invocations, and later for unexporting that same remote object.
A convenience class for retrieving the
boolean value of a system property as a
privileged action.Returns current date formatted
A convenience class for retrieving the
int value of a system property as a
privileged action.A convenience class for retrieving the
long value of a system property as a
privileged action.Created by tamirt on 19/05/16.
A convenience class for retrieving the string value of a system property as a privileged action.
Provides security-checked access to internal thread pools as a java.security.PrivilegedAction, to
be used conveniently with an AccessController.doPrivileged or Security.doPrivileged.
A bean definition builder for
GigaMapFactoryBean.A simple programmatic configurer for
GigaMap instance wrapping the GigaMapFactoryBean.Base server-side implementation of a lookup service, subclassed by TransientRegistrarImpl and
PersistentRegistrarImpl.
Provides a simpler interface of
IJSpace extension utilizing GigaSpaces extended and
simplified programming model.Annotation marking a field of type
GigaSpace allowing for SpaceEntriesAggregator to be injected with the space it is executed on.A bean definition builder for
GigaSpaceFactoryBean.A simple programmatic configurer for
GigaSpace instance wrapping the
GigaSpaceFactoryBean.Allows to directly inject a
GigaSpace implementation into a class field or setter
property.A bean definition builder for
GigaSpaceContextBeanPostProcessor.A Spring bean post processor allowing to use
GigaSpaceContext in order to inject GigaSpaceContext instances using annotations.Defines space-type tag parsing
A factory bean creating
GigaSpace implementation.Allows to directly inject a
GigaSpace implementation into a class
field or setter property.A bean definition builder for
GigaSpaceContextBeanPostProcessor.Provides support to determine the reachability of the GigaSpace service.
GigaSpaces Runtime
Interface encapsulating operations for getting and managing space type descriptors.
Builds
IReplicationGroupBacklog that each group has a global order that the packets must
be processed by the corresponding IReplicationTargetProcessLog.Can be used as a reliable async target process log for a source that is working in batches and
single threaded only
This is the PreparedStatement implementation.
An implementation for holding the prepared values & prepared values batch.
Loads Grafana configuration from metrics properties file.
Encapsulates the authorities granted to a specific user, to ease access control and authorization
decisions.
Permission required to dynamically grant permissions by security policy providers which implement
the
DynamicPolicy interface.An implementation of greater than or equals to comparison: This predicate returns true if and
only if the predicate's argument is greater than or equals to the expected value.
An implementation of greater than comparison: This predicate returns true if and only if the
predicate's argument is greater than the expected value.
The ResultSet implementation
This is the ResultSetMetaData implementation
Defines an Authority for managing grid services, with the specified privilege.
Defines managing services privileges
Grid Component is an element that can provide information on the machine it is running one, the
transport it uses, the Operating system it is running on, and the virtual machine that started
it.
Useful Grid Component utility method
A Grid Service Agent is a process manager allowing to start and stop (on the operating system
process level) processes (such as
GridServiceManager, GridServiceContainer and LookupService.An event listener to be notified when a grid service is added.
An event manager allowing to remove and add
GridServiceAgentAddedEventListeners.A simple lifecyle event listener that implements both the agent added and agent removed event
listeners.
An event listener to be notified when a grid service is removed.
An event manager allowing to remove and add
GridServiceAgentRemovedEventListeners.Grid Service Agents hold all the different
GridServiceAgent that are currently
discovered.A Grid Service Container is a container for
ProcessingUnitInstances
allocated to it through the GridServiceManager that manages it.An event listener to be notified when a grid service container is added.
An event manager allowing to remove and add
GridServiceContainerAddedEventListeners.A simple lifecyle event listener that implements both the container added and container removed
event listeners.
GridServiceContainer process options to be started by the GridServiceAgent.An event listener to be notified when a grid service container is removed.
An event manager allowing to remove and add
GridServiceContainerRemovedEventListeners.Grid Service Containers hold all the different
GridServiceContainers that are currently
discovered.A Grid Service Manager is a manager for
ProcessingUnit
deployments (acting either as primary or backups for a certain processing unit deployment).An event listener to be notified when a grid service manager is added.
An event manager allowing to remove and add
GridServiceManagerAddedEventListeners.A simple lifecyle event listener that implements both the container added and manager removed
event listeners.
GridServiceManager process options to be started by the GridServiceAgent.An event listener to be notified when a grid service manager is removed.
An event manager allowing to remove and add
GridServiceManagerRemovedEventListeners.Grid Service Containers hold all the different
GridServiceManagers that are currently
discovered.A generic process options.
Groovy local script executor.
Represents mapping of
IReplicationSourceGroups that is used to determine to which groups
to dispatch outgoing replicationThis class is an optimized porting of java.io.ByteArrayInputStream: a) All methods are not
synchronized.
This class is an optimized porting of java.io.ByteArrayOutputStream: a) All methods are not
synchronized.
A class responsible for forking a new GSC for the WAN Gateway, and relocating this PU instance
(the gateway) to the new container.
Created by yechielf on 05/03/2015.
GSKafkaConsumerStatus.status represent detailed information regarding the GSKafkaConsumerStatus.status
including error that occurred while querying the statusOrdinal ordered by priority, the highest ordinal means the highest priority
A light yaml parser, providing common yaml functionality with no external dependencies.
This class is a singletone that is responsible for reading and loading GS Log configuration.
This class provides an implementation to GigaSpaces IMap interface, for Distributed Caching using
Map API.Plugin interface for registering custom Micrometer backends (registries).
Indicates error in finding a GSM to deploy to.
Title: GSServerTransaction Description: Extends the ServerTransaction to hold Object id
should only be used as a key.
Print a brief summary of the LogRecord in a human readable messageFormat.
A yaml parser based on wrapping the SnakeYaml library.
The Statement implementation using a GConnection and a GResultSet
Base thread that should be used all across GigaSpaces code.
Thread factory to create
GSThread.Timer that should be used all across GigaSpaces code.
Local implementation of Xid to be store in Space
Provides gs.xml parsing services.
This is the greater-than-equal operator Node.
This is the greater-than operator Node.
A reference to a field or a method.
A stream handler for URLs with the HTTPMD protocol.
An LRMI handshake object
Hash-based simple index for entry packets.
hash-backed Read/Write Lock version of StoredList to be used with JDK 1.5+
TODO add Javadoc
Provides various hash functions.
Created by Barak Bar Orion
on 8/28/16.
Created by Barak Bar Orion
on 8/28/16.
A heap memory utilization alert, fired upon triggered JVM heap-memory thresholds.
A heap utilization alert configuration.
A heap utilization alert configurer.
Based on Java memory spec, and specifically https://github.com/jbellis/jamm/blob/master/src/org/github/jamm/MemoryLayoutSpecification.java
Utility class for analyzing heap dumps
A wrapper around the Cassandra Hector client library.
A configurer for creating
HectorCassandraClient instances.The hostName attributes for registering to LookupService.
A bean definition builder for
HostRequirement.Returns hour according to timestamp
Bean that will start an instance of an HSQL database.
Class which can be used to print a descriptive warning message if a codebase accessibility
problem is found.
Integrity verifier for HTTPMD URLs.
Provides utility methods for creating and using HTTPMD URLs.
Created by evgenyf on 10/21/2015.
Integrity verifier for HTTPS URLs.
This interface provides an acceptable decision for the proposed service candidate to
advance(acquire) the desired
The filter implementation invokes by
The state will be advanced by service only if
ActiveElectionState.State state.The filter implementation invokes by
ActiveElectionManager to identify whether the managed service
candidate is acceptable to advance current state to advanceState.The state will be advanced by service only if
IActiveElectionDecisionFilter.isAcceptable(ActiveElectionState.State, List)
returns true, otherwise the state stays without no change.This interface provides notifications by
ActiveElectionManager about new elected Active
service.Provide a capabilitiy for loading classes, used by
ServiceClassLoader to load classed
from the lrmi class loader holder.Wraps a repetitive executing runnable which is provided to a
IAsyncHandlerProvider.start(IAsyncCallable, long, String, boolean) invocation and controls its
life cycle.Provides
IAsyncHandler for repetitive execution of runnablesCreated by alon on 11/8/17.
Off heap interface for internal cache
extention of entry-holder for off-heap
The basic interface for a Blob-Store lock object.
The resident part of entry that resides off-heap (SSD)
BlobStore storage adapter interface
Provide an endless byte buffer like storage, which support single writer or multi readers
concurrently interacting with it
A factory for
IByteBufferStorageActs as a reader over a
IByteBufferStorageActs as a writer over a
IByteBufferStorageListen for class loader cache state changed
the remote interface used to retsrieve class definition or resources from a remote JVM.
Interface for all internal collections.
Holder for compound index value (multi segments value)
Monitors
AbstractProxyBasedReplicationMonitoredConnection stateProvides an abstraction over a constructor reflection.
A general interface for dispatching.
Represents a custom query related to a collection item in the space.
Represents a custom query interface.
A possible fix for a
IReplicationPacketDataConsumer#consume(String, IReplicationPacketData, com.gigaspaces.internal.cluster.manager.handlers.IReplicationInFacade)
invocation that returned an error result denoted by a IDataConsumeResult that its IDataConsumeResult.isFailed() is true.A facade used by
AbstractDataConsumeFix to fix errors in replicationConverts user objects to internal representations.
The actual i/o of DirectPersistencyOpInfo objects
Created by yechielf on 28/04/2015.
The synchronizing direct-persistency handler
A direct space proxy working on an actual space.
IdleConnectionTimeoutObserver monitors idle connections.
An object that is associated to a .NET AppDomain.
Class to encapsulate information of a query based on a Space ID.
Used for querying the space by a class + id.
A template packet used by readByIds operation.
Class to encapsulate information of a query based on multiple Space IDs.
A template packet used by readByIds operation.
Created by tamirt on 17/05/16.
TODO add Javadoc
Abstraction for getting and setting fields values on an entry.
this is the basic interface defining the proxy-space or space-space transport layer.
chain used for lru or fifo eviction
repository for replication markers - used in order to prevent eviction of entries that did not
reach the async replication target yet (currently mirror)
User: assafr Date: 26/06/2008 Time: 07:51:10
An extension of
IReplicationPacketData that can be self executed.Created by yechielf on 09/08/2015.
IOrderedIndexScan defines the interface for an ordered index scan.
TODO add Javadoc
Provides an abstraction over a field reflection.
IFifoGroupIterator for scanning in order to locate fifo-groups
a holder of fifo group list (simple or compound)
This interface is common to all the entries that are passed to any of the space filters.
An internal interface extending the
AsyncFuture.Represents a getter method
This class represents an
Entry in a GigaSpace.Logical holder for entries in EconpmyConcurrentHashMap
TODO add Javadoc
Handles incoming replication provided by a
IReplicationRouterExtends IRemoteJSpaceAdmin to include internal methods.
Notice: Since 7.0 this API is internal and subject to changes in future versions - Use
GigaSpace instead.Deprecated.
Since 8.0 - This interface is reserved for internal usage only.
Deprecated.
Since 8.0 - This interface is reserved for internal usage only.
Interface for callbacks on JSpace Proxies.
methods for storing-retrieving lease cache info of entry
Thrown to indicate that a method has been passed an illegal null argument.
Thrown when a class fails at readExternal because it does not support the version read from the
stream.
TODO add Javadoc
Invocation handler used by LRMI framework
Represents a remote proxy which uses lrmi for remote method invocation
Notice: since 7.0 this API is internal and might be subject to changes in future versions.
A wire form of
IMarker which can be serialized and deserializedThis interface should be implemented by all Marsh convectors.
Provides an abstraction over a member reflection.
Extension of
IResource that provides the amount of memory this resource consumes.Provides an abstraction over a method reflection.
Implemented by entry packet(s) not in the same hierarchy as IEntryHolder interface.
The basic interface for a MVCC lock object.
This exception thrown when attempting to access an inactive space which runs as a backup of
primary space.
Thrown when an operation is performed on an inactive transaction.
The
Each method of the
INamingService interface provides methods: For obtaining references to
remote services in a remote naming service.Each method of the
INamingService
takes as one of its arguments a ServiceTemplate to lookup the
desired service.Signal that the incoming replication is out of sync
Represents a change operation which correlate with a
ChangeSet.increment(String, int) or
ChangeSet.decrement(String, int) invocation.Part of the index choices of the partition
Encapsulates information on a table's index.
Single index choice detail
Allows storing index hits
Used to map network addresses
The synchronizing direct-persistency embedded initial load handler
cache-manager information about initial load performed
Represents an inner (sub) query in a WHERE clause condition.
The InNode.
Extends the
IRedoLogFileStorage interface by adding a non batch behavior of adding
packets to the end of the list.Deprecated.
This interface represents notify filter logic.
Represents an IN expression range
This class handles the INSERT query logic.
Represents an In predicate.
Represents the quiesce state of the all processing unit instances.
Aggregates samples from different instances using different functions defined by
InstancesStatisticsConfig that is stored in ProcessingUnitStatisticsIdsBuilt in string sql function to get the position of the first occurrence of a substring in a
string.
Serializer for integer.
The integrated processing unit container wraps Spring
ApplicationContext.An
IntegratedProcessingUnitContainer provider.Represents a constraint on the integrity of message contents, covering not only data transmitted
in band as part of the remote call itself, but also out-of-band downloaded code.
Defines a context element interface for determining if object integrity is being enforced on a
stream or a remote call.
Defines the interface for integrity verifiers used by
Security.verifyCodebaseIntegrity, allowing the URLs that provide content integrity to be
extended.Internal alert repository extension API.
Marks an API (class, method, etc.) as an internal, i.e.
An internal API extension to the default
Authority adding privilege associations.Internal API for
DataSourceIdsQuery operationsAn internal implementation of
DistributedSpaceTask that wraps the
actual Task to be executed.Deprecated.
Part of the legacy internal gauge hierarchy used by the deprecated
MetricSampler and process metric factories.An internal API of
GigaSpaceInternal space exception thrown from the engine when space is inactive.
Deprecated.
Internal implementation for the deprecated
MetricManager.An event listener allowing to listen for orphaned
ProcessingUnitInstance
removals.InternalProcessingUnitDependencies<T extends ProcessingUnitDependency,IT extends InternalProcessingUnitDependency>
InternalProcessingUnitDeploymentDependencies<T extends ProcessingUnitDependency,IT extends InternalProcessingUnitDependency>
InternalProcessingUnitDetailedDependencies<T extends ProcessingUnitDependency,IT extends InternalProcessingUnitDependency>
listener is called to sign that partition status has changed during the scale process
This exception denotes a problem with the local implementation of the
JavaSpace
interface.A wrapper for
InternalSpaceException.A wrapper class for the
InterruptedException.Common Thread subclass to handle potential loss of interrupted status.
Deprecated.
This exception is no longer thrown.
Deprecated.
This exception is no longer thrown.
A base class for invalid fifo operations exceptions.
This exception is thrown if read or take operations executed in FIFO mode, but the template class
FIFO mode already been set to non FIFO.
This exception is thrown if read or take operations executed in FIFO mode, but the template class
FIFO mode already been set to non FIFO.
This exception is thrown in case of invalid space name.
Thrown when an invalid transaction usage is performed.
Scans the index with the defined index name only for entries that match one of the values in the
index value set.
The marker interface used to identify constraints for method invocations.
An immutable aggregation of constraints into a set of requirements and a set of preferences.
This exception is thrown when an array serialization/deserialization fails on an IOException.
Information node in a StoredList
basic interface for space list/iterator
Interface for block type network filters.
Markup interface
Implementation of SSLFilter that use underline SUN SSLEngine.
A network filter to send compress messages between client and server.
Use this network filter factory to send compress messages between client and server.
Define interface to stream based netwrok filter A stream based netwrok filter is a network filter
that is not blocked based.
This class provides a set of static utility methods used for I/O manipulations (convert data to
streams, socket ports).
Similar to
Externalizable but expects MarshalOutputStreamProvide replication packet stream serializing capabilities
Provides an abstraction over a constructor with parameters reflection.
Deprecated.
Since 8.0 - Use
GigaSpace instead.Deprecated.
This interface is reserved for internal usage only.
Provides an abstraction over a method reflection.
Deprecated.
Use
Task or DistributedTask
instead.An interface for retrieving current JVM memory details & provides the ability to perform GC.
Represents a all properties accessor
Represents an index that can be provided in a
ICustomQuery and optimize the query run
time.Interface for query handling
Remote interface for the
QueryProcessor.Acts as the redo log packets storage
MemoryRedoLogFile Implementor should support concurrent
readers or a single writer, in other words, the implementor can assume access to this structure
are guarded with a reader writer lock according to the operation type
An exception is IRedoLogFile.getApproximateSize() method which should not assume a reader lock is
held.Provide statistics of a redo log file
Provide an external storage for a redo log file, Packets are stored as a single list, adding
packets are always appended at the end of the list, and removal of packets are always from the
start of the list
Implementor should support concurrent readers or a single writer, in other words, the implementor
can assume access to this structure are guarded with a reader writer lock according to the
operation type
An exception is
IRedoLogFileStorage.size() method which should not assume a reader lock is held.Provide statistics of a
IRedoLogFileStorageProvide statistics for a redo log
Interface for reflection enhancement factory.
Provides an interface to acquire a remote class provider, it also used as a place holder for a
context of a specific remote class loader for a single operation.
This interface contains all the administrative methods that GigaSpaces provides to control the
JavaSpaces service.
The GigaSpaces remote interface.
Builds a replication source backlog per
IReplicationSourceGroupListener for
IReplicationGroupBacklog eventsthis is the base interface for all replication channels.
Wraps a connection proxy as a service.
A replication filter is a special hook point inside the replication module.
Represents an entry instance passed to the
IReplicationFilter.Holds the replication backlog of a single
IReplicationSourceGroupHandles incoming replication in batch consumption mode
Handle incoming replication event of new data types
IReplicationNodeHandle incoming replication event of new data types
IReplicationNodeHandle incoming replication event of new index for data type
IReplicationNodeHandle incoming replication event of cancel entry lease
IReplicationNodeHandle incoming replication event of entry lease expired
IReplicationNodeHandle incoming replication event of extend lease
IReplicationNodeHandle incoming replication event of evict entry
IReplicationNodeBatch all the existing replication in handlers
IReplicationNodeHandle incoming replication event of notification sent
IReplicationNodeHandle incoming replication event of insert notify template
IReplicationNodeHandle incoming replication event of notify template lease expired
IReplicationNodeHandle incoming replication event of remove notify template
IReplicationNodeRepresents specific incoming operation statistics.
Statistics on operations executed on target replication space.
Handle incoming replication event of executed transaction
IReplicationNodeA lookup service that is used by replication to locate endpoint of
IReplicationConnectionProxyA lookup service that is used by replication to register endpoint of
IReplicationConnectionProxyA lookup service that is used by replication to locate endpoint of
IReplicationConnectionProxyThe interaction point between a single space instance and a cluster of spaces
Provide administration capabilities of an
IReplicationNodeBuilds all the components needs to construct a
ReplicationNodeA replication packet that has an order that specify a certain order of these packets that needs
to be kept when processed at the target
Interface for replication packets - SyncPacket and CompositeReplicationPacket
The replication packet data that is kept in side an
IReplicationOrderedPacket which
contains the data needed for the processing of the packetConsumes
IReplicationPacketData and delegate it to the corresponding replication in
handler.Convert logical operation to a representing
IReplicationPacketDataUsed to extract content from
IReplicationPacketEntryDataResponsible for synchronizing replication process logs multiple participants operations in a
reliable async target.
provides outgoing
IReplicationMonitoredConnection and in charge of keeping it connected.Administrator of a
IReplicationNodeA replication source group consists of one or more target members that shares the same data that
needs to be replicated, each member is being replicated to using a dedicated
IReplicationSourceChannel.Handle incoming replication event of evict entry
IReplicationNodeHandle incoming replication from one or more
IReplicationSourceGroupNote to implementers: The methods of this interface will be called under replication locks If A
listener wishes to shutdown the replication node, It is advised to spawn a new thread in order to
avoid possible deadlocks
A resource interface required by a
ResourcePool.IResourceFactory interface for allocating new resources out of the ResourcesPool.
base interface for resource pools.
Represent a response context that is passed by thread local using
ResponseContext for
callback invocationsdetermines ther behaviour of sending a callback to the client.
Defines an interface for a pool of reusable resources.
ISAdapterIterator is an interface that should be implemented by the iterators the Storage Adapter
produces.
Safe use "array", to use when
ArrayIndexOutOfBoundsException might accord.IScanListIterator defines the interface for the result of stored-lists/extended indexes matching
Listener interface for enhancing server type descriptor life cycle with custom code.
Represents a setter method
Listener for state change events of a
SharedDataIteratorSourceA simple lock implementation that supports only lock and unlock
This is the IS NULL operator Node.
Utility methods to handle conversions between different isolation level representations.
Base class for isolation level based space proxy operations modifiers.
Provide source data iterator that is used by
SharedDataIteratorSourceA space cache implementation provides local cache support such as local view and local cache.
Interface for classes that handle space components
Encapsulates information about an index segment of a compound index.
A filter is a special hook point inside the engine that enables integration with external systems
or implementation of user defined logic.
Represents an entry instance passed to the
ISpaceFilter. Encapsulates information about an index in a space type.
Extracts the replication groups an operation should be replicated to.
Defines a callback listener to be notified when a space mode is changed.
Represents a predicate to be executed in the space.
A space proxy that extends the
IJSpace interface.Represents a space query.
A single replica data that is generated by the
ISpaceReplicaDataProducer as part of a
space copy replica request, this replica data is passed to the ISpaceReplicaDataConsumer
as part of the replica process which is consumed in its turn to be translated to a replica
operationIn charge of consuming in coming data generated by a space replica request
Defines a set of constants that gives an information on the state of a JavaSpace.
Represents an abstraction of getting a value from a target object.
IStorageAdapter is an interface that should be implemented by the Storage adapter.
helper functions in order to maintain direct-recovery recovery consistency
A cursor holder of a StoredList for each scan.
Deprecated.
Since 8.0 - This class is reserved for internal usage only.
An object that is written and read into swap space (disk)
ISwapExternalizableAn Item contains the fields of a ServiceItem packaged up for transmission between client-side
proxies and the registrar server.
Extends IEntryPacket and provides an interface for templates.
Iterator over an
AbstractStoredList.Represent a resource which is used by one thread only
Interface to specify custom implementation of precise timer.
Contains all the data (mutable) fields of the entry.
TODO add Javadoc
Interace for a transaction manager provider.
TransactionManager types.
This interface defines the underline communication transport protocol configuration.
This is a super class of transport protocol provider with all related information to implemented
protocol.
Common interface for all the introspectors implementations.
clone index values for embedded ref protection
Deprecated.
This interface is reserved for internal usage only.
Hold result that can be either lease or Throwable.
This interface is implemented by servers that export a JavaSpaces(TM) technology service.
A namespace handler for
jdbc namespace.An extension to the
ApplicationContextProcessingUnitContainer
that can handle JEE processing units.An extension to the
ApplicationContextProcessingUnitContainerProvider
that can handle JEE processing units.A service that holds a jee container (such as jetty).
The type of the jee service
A generic holder that holds a Jetty server and controls its lifecycle.
An implementation of
JeeProcessingUnitContainerProvider
that can run web applications (war files) using Jetty.The actual container simply holding the jetty web application context, the application context,
and the
JettyHolder.A simple extension for Jetty WebApp class loader just to make it loggable in the Service Grid.
An jetty specific
ServletContextListener that is automatically loaded by
the BootstrapWebApplicationContextListener.Jini-based implementation of managing renewal of event registration leases.
An extension to Spring
PlatformTransactionManager that
holds the Jini transactional context.JiniServiceFactoryBean for Jini environments.
A Jini transaction holder responsible for holding the current running transaction.
Used as a means for a service to publish information about a JMX Connector.
Copyright (c) 2010 GigaSpaces Technologies Ltd.
Copyright (c) 2010 GigaSpaces Technologies Ltd.
Copyright (c) 2010 GigaSpaces Technologies Ltd.
Copyright (c) 2010 GigaSpaces Technologies Ltd.
Copyright (c) 2010 GigaSpaces Technologies Ltd.
A
Job manages the division of work for a problem whose solution is obtained by
assembling partial results to original problem.The methods in this interface are used to control a service's participation in the join protocol.
This class represents an entry that was constructed from a join between several tables.
Executes a join query.
A goal of any well-behaved service is to advertise the facilities and functions it provides by
requesting residency within at least one lookup service.
This is a
JProperties utility class that can be used by opening an input stream from
a XML property file using a URL path that receives as parameter in setURL()
function.JRuby local script executor.
Copyright (c) 2010 GigaSpaces Technologies Ltd.
Copyright (c) 2010 GigaSpaces Technologies Ltd.
JSpaceAttributes that contains all information per space.
A J-Space Server is a physical process (JVM) that has a J-Space Container instance.
Copyright (c) 2010 GigaSpaces Technologies Ltd.
Copyright (c) 2010 GigaSpaces Technologies Ltd.
Copyright (c) 2010 GigaSpaces Technologies Ltd.
Copyright (c) 2010 GigaSpaces Technologies Ltd.
This space filter should be provide a space statistics information.
JSpaceUtility class provides useful GigaSpaces utility functions.
Java 6 (JSR 223) script executor.
Deprecated.
Used only by the legacy
MetricManager.Deprecated.
Used only by the legacy
MetricManager.Deprecated.
Used only by the legacy
MetricManager.A convenient factory for handling secret keys.
A position in the bytecode of a method.
Interface that granters of leases must implement in order to work with the
LandlordLease implementation of the Lease interface.Simple class that holds return values of the
Landlord.renewAll
method.Basic implementation of
net.jini.core.lease.Lease that works with the the Landlord
protocol.Implementation of
LeaseMap for LandlordLease.This class defines a trust verifier for the proxies defined in the landlord package.
Static methods useful for implementing landlords.
Returns the last N log entries.
Holds last statistics and encapsulates lock mechanism
Created by moran on 12/9/17.
Deprecated.
Use
Timer for latency measurementsThe lazy loading remote invocation aspect wraps the actual remote invocation and adds support for
LazyLoadingScripts.Allows to define a lazy loading script which will not send the scipt contents during the
invocaiton if the scipt can be cached and compiled.
Deprecated.
Load balance GroupMember state.
Provides runtime primary/backup selection in cluster topologies.
The Lease interface defines a type of object that is returned to the lease holder and issued by
the lease grantor.
LeaseContext is a return-value encapsulation of a write operation.
An exception generated when a lease request or renewal is denied.
Server side representation of a lease
Generic superclass for specific lease exceptions.
Lease Mgr implementation that aggressively expires leases as they expiration times occur.
Interface that allows LeaseExpirationMgr to expire resources.
Factory for
LandlordLease instances.This utility class initializes LeaseProxy, set Remote/Local Space Reference
an internal space exception thrown from the leaseManager
The interface that receivers of
LeaseRenewalEvent instances must implement.Lease Manager handles operations that can be carried out on a lease: creation, renewal and
cancellation.
LeaseManager provides an interface for tracking lease status.An unsynchronized Map from Lease to Long (the duration to use when renewing the lease).
An exception generated when a LeaseMap renewAll or cancelAll call generates exceptions on one or
more leases in the map.
Interface for objects that define what policy to use when calculating lease grants and renewals.
Simple class that holds a pair of times, the new expiration and duration for a lease.
An instance of this class represents an entry/template lease or a lease of an event registration
results from an event registration.
Event generated when a
LeaseRenewalManager cannot renew a lease.Provides for the systematic renewal and overall management of a set of leases associated with one
or more remote entities on behalf of a local entity.
Returns a substring of a given string starting from the left
An implementation of less than or equals to comparison: This predicate returns true if and only
if the predicate's argument is less than or equals to the expected value.
An implementation of less than comparison: This predicate returns true if and only if the
predicate's argument is less than the expected value.
The heap LFUDA ( Least Frequently Used) policy keeps popular objects in cache regardless of their
size and thus optimizes byte hit rate at the expense of hit rate since one large, popular object
will prevent many smaller, slightly less popular objects from being cached.
The interface used to manage the lifecycle of shared, non-activatable services started by the
service starter.
This code was copied from org.apache.calcite.runtime.Like
refer to it if any future changes are needed
This is the LIKE operator Node.
Created by Barak Bar Orion 01/10/14.
Represents a listener execution failure.
This is the Literal node.
Indicates this operation should receive highest priority, which means it should happen even if
the regular lrmi thread pool is exausted and the
MonitoringPriority resources are
exausted.Built in mathematical sql function to perform ln operation.
LoadBalancingGroupRecovery defines how to recover in load balancing groupCopyright (c) 2010 GigaSpaces Technologies Ltd.
Security policy provider which handles permission queries and grants by delegating to different
policy providers depending on the class loader involved.
Garbage Collector Entry.
Encapsulates local cache details.
Base class for dcache async futures, it registers with a custom listener per implementation and
delegates the result to the user supplied listener when the operation is considered done (Up to
the custom listener)
A bean definition builder for
LocalCacheSpaceFactoryBean.A simple configurer helper to create
IJSpace local cache.In some cases, the memory capacity of an individual application is not capable of holding all the
information in the local application memory.
A bean holding local cache support (when using Map API) configuration.
The local implementation used to retrieve class definition or resources
In LRMI class loading, retrieval is invoked remotely by
DefaultClassProvider
In simple remote class loading, retrieval is invoked locally by SimpleClassProviderOperation executer for a partial update replication sink gateway operation against a local
cluster.
Operation executer for a remove replication sink gateway operation against a local cluster.
Operation executer for a remove replication sink gateway operation against a local cluster.
A handler for a write operation replicated to a gateway sink component.
A handler for a transactional set of operations replicated to a gateway sink component.
A handler for metadata events replicated to a gateway sink component.
Special replication router that exists inside a
LocalClusterReplicationSink that can
create a replication connection from one sink via another sink to a specific space memberOperation executor for an update operation by a gateway sink component against an
ISpaceProxy instance representing the local cluster.Operation executor for write operation by a gateway sink component against an
ISpaceProxy
instance representing the local cluster.A
FileService responsible for reading and writing to a file on the local file-system.Deprecated.
since 8.0 - use
DistributedJiniTxManagerConfigurer instead.Interface that defines the basic landlord primitives (renew and cancel) as local methods.
An SPI implementation for script executor ("on the server side") that can handle a specific
script type (or labguage).
This class provides local time.
This interface provides local time.
Deprecated.
Since 8.0 - Use JINI transactions instead.
Deprecated.
Deprecated.
The possible connection state of the local view
A listener interface, listening to the local view connection state.
Encapsulates local view details.
Provides a simple interface to the local view gigaspace.
A bean definition builder for
LocalViewSpaceFactoryBean.A simple configurer helper to create
IJSpace local view.The space local view proxy maintains a subset of the master space's data, allowing the client to
read distributed data without any remote operations.
A lock handle allowing to perform map operations when the key is locked.
The lock manager is built on top of
IMap and supports the ability to lock and unlock
certain keys within the map.Represents all of the functions which may be performed on a log file.
Built in mathematical sql function to perform log10 operation.
A collection of log entries, including meta information such as process id, host information.
Represents a log entry.
The type of the log entry.
A matcher allowing to control the traversal of the log file.
A base class for entry matchers that act as filters to a delegated matcher.
A set of static construction methods for
LogEntryMatchers.This class can be used to represent all exceptional conditions that occur during any logging
process.
A class loader that can provide a log name asspciated with it.
Server-side security auditing using the configuration given entirely by the LogManager
properties.
A LogHandler represents snapshots and update records as serializable objects.
GS-8802 , GS-9973 , GS-10078
A logging helper class used to avoid a deadlock situation when java.util.logging is initializing, while it is also being referenced by utility classes.
A logging helper class used to avoid a deadlock situation when java.util.logging is initializing, while it is also being referenced by utility classes.
This class extends the functionality of the java.io.InputStream class in order to provide an
input mechanism that can be used by processes that perform logging operations; in particular,
processes that store state in order to provide persistence.
Defines a
LogManager that insures that the Levels.FAILED and Level.FINE fields, instances of Level, have
been initialized, and that can periodically check for changes to the logging configuration file
and force it to be reread.Represents the functions performed by a log manager.
This class extends the functionality of the java.io.OutputStream class in order to provide an
output mechanism that can be used by processes that perform logging operations; in particular,
processes that store state in order to provide persistence.
The type of process that generated the log.
A grid component that can provide the ability to extract logging information.
Encapsulates a generic record which capable of being logged.
Describes the interface needed to be able to receive information from a
LogManagerBuilt in mathematical sql function to perform log operation.
Serializer for long.
Deprecated.
Use
AtomicLong with Micrometer Gauge,
or Counter for monotonic countersSome simple utilities for manipulating lookup service attributes.
The
LookupCache interface defines the methods provided by the object created and
returned by the ServiceDiscoveryManager
when a client-like entity invokes the createLookupCache method.This class is a helper utility class that encapsulates the functionality required of an entity
that wishes to employ multicast discovery to find lookup services located within the entity's
"multicast radius" (roughly, the number of hops beyond which neither the multicast requests from
the entity, nor the multicast announcements from the lookup service, will propagate).
This class is a helper utility class that organizes and manages all discovery-related activities
on behalf of a client or service.
A provider for a lookup distributed Jini transaction manager.
Deprecated.
Since 8.0 - This class is reserved for internal usage only.
Springs transaction manager (
PlatformTransactionManager
using Jini in order to lookup the transaction manager based on a name (can have null
value).A bean definition builder for
LookupJiniTransactionManager.A simple configurer for
LookupJiniTransactionManager.A utility class that performs unicast discovery, using version 1 of the unicast discovery
protocol.
This class encapsulates the functionality required of an entity that wishes to employ the unicast
discovery protocol to discover a lookup service.
Listener for locators change events.
This class
LookupManager provides : Registration forever of JSpaces and
JSpace containers with all discovered Lookup Services using registerForever()
method.The
LookupNamingService class provides methods for obtaining references to remote
services in a Jini LookupService.A lookup service acts a lookup server where different grid components register and maintain a
lease against.
An event listener to be notified when a lookup service is added.
An event manager allowing to remove and add
LookupServiceAddedEventListeners.Starts Lookup Registry
A simple lifecyle event listener that implements both the lookup service added and lookup service
removed event listeners.
LookupService process options to be started by the GridServiceAgent.An event listener to be notified when a lookup service is removed.
An event manager allowing to remove and add
LookupServiceRemovedEventListeners.Lookup Services hold all the different
LookupServices that are currently discovered.Holds lookup distributed transaction manager configuration properties.
A runtime exception used to signal a lost connection error.
Built in string sql function to change all characters of a given string to lowercase.
Notify delegator for batch notifications.
Created by Barak Bar Orion 12/30/14.
Acts as a local class loader that is connected to a remote class loader using LRMI to load new
classes.
Thrown when failed creating a LRMIClassLoader
acts as a classloader delegator to an IClassProvider based classloader that loads class
definitions from a specific source.
getches class definitions.
A future implementation used to hold delayed result coming from one target.
Monitoring details of inbound lrmi communication, e.g hosted services that are serving remote
invocation calls that are executed via remote proxies.
Represents thread local lrmi invocation context that is used for debug logging levels
Represents the stage of the lrmi invocation
Represents a trace of an lrmi invocation, this object is immutable and when updated a new copy is
created and should be used instead of the current instance.
LRMI Stub implementation of
IJSpaceContainer, IJSpaceContainerAdmin,
LifeCycle,Service interface.LRMI Stub implementation of
IJSpaceProxyListener interface.Manages Gigaspaces LRMI layer
This class provides LRMI method info constructed by
RemoteMethodCache.Holds LRMI method metadata.
Monitoring details of a specific method
Tracking details of a specific method
Monitoring details of the LRMI layer
A monitoring module use to monitor activity of remote lrmi method invocations.
A
LRMINoSuchObjectException is thrown if an attempt is made to invoke a method on an
object that no longer exists in the remote virtual machine using LRMI framework.NotifyDelegator stub to get notification via LRMI layer.
Monitoring details of outbound lrmi communication, e.g proxies invoking methods on remote
services.
Monitoring details of a single remote proxy.
A unique identifier for a specific remote lrmi class loader, holds a tuple of the lrmi runtime id
and the local class loader id inside that lrmi runtime class provider
Super class of all Notify stubs.
LRMI is the main LRMI class, from the developer's perspective.
Monitoring details of a single client on a specific service
Tracking details of a single client on a specific service
Monitoring id of a single client of a specific service
Tracking id of a single client on a specific service
Monitoring details of a single hosted service
Tracking details of a single hosted service
LRMI Stub implementation of
IRemoteJSpaceImpl interface.Deprecated.
Use
Exporter instead or GenericExportera version of dynamicThreadPool that can return an IFuture from a submit call.
A special exception which is not handled by the LRMI layer and its cause will be thrown to the
client
This utility class provides a common Transport Protocol utilities methods.
Configures the Space to run in LRU mode.
The LRU policies keep recently referenced objects.
An LRU cache that can handle compiled scripts that are not thread safe.
An LRU cache that can handle compiled scripts that are thread safe.
This is the less-than-equal operator Node.
This is the less-than operator Node.
Provides runtime primary/backup selection in cluster topologies.
Base class for replication components that are exported via the
IReplicationLookupService
This component can be a target of replication connection IReplicationConnectionProxyA replication router that uses a look up service in order to find replication connection proxies
A base class for a connection monitor that uses a scheduled thread pool for its monitoring tasks
A Machine is a logical entity identified by a host address.
An event listener to be notified when a machine is added.
An event manager allowing to remove and add
MachineAddedEventListeners.Allows to get the
Machine the component is running on.A simple lifecyle event listener that implements both the machine added and machine removed event
listeners.
An event listener to be notified when a machine is removed.
An event manager allowing to remove and add
MachineRemovedEventListeners.Machines hold all the different
Machines that are currently discovered.Represents permissions that can be used to express the access control policy for the Mahalo
server exported with a
net.jini.jeri.BasicJeriExporter.TODO add Javadoc
Deprecated.
since 9.5 - use
SpaceDataSource or SpaceSynchronizationEndpoint
instead.Deprecated.
since 9.5 - use
ManagedEntriesSpaceDataSource or ManagedEntriesSpaceSynchronizationEndpoint instead.An implementation of
SpaceDataSource that can provide a list of
all the given entries this space data source handles.An implementation of
com.gigaspaces.datasource.SpaceSynchronizationEndpoint that can
provide a list of all the given entries this synchronization endpoint interceptor handles.this interface allows the listener to receive an initialization event.
A Managed Runnable is a convenient superclass for Runnables that want to support graceful
shutdown of threads.
additional methods which relates to the underlying transaction manager
Encapsulates information about the cluster of managers in this grid
Enacpsulates information about a specific manager instance.
An event indicating that a managing GSM of a processing unit was changed.
An event listener allowing to register for
ManagingGridServiceManagerChangedEvents.An event manager allowing to add and remove
ManagingGridServiceManagerChangedEventListeners
in order to listen for ManagingGridServiceManagerChangedEvents.This class provides a lightweight implementation to GigaSpaces IMap interface (A JCache standard
extension), for Distributed Caching using java.util.Map API.
Result for changing a map property
Key in the MapVersionTable.
Base class for different
IMap factories.Map based CompoundTypeNode (currently, unused)Holds the version for each Object for optimistic locking.
Thrown when a marshaling error occurs due to that the class loader which the context belongs to
was cleared.
An extension of
AnnotatedObjectInputStream that provides local storage of already
resolved class descriptors, to optimize the marshaling.An extension of
ObjectInputStream that implements the dynamic class loading
semantics of Java(TM) Remote Method Invocation (Java RMI) argument and result unmarshalling
(using RMIClassLoader).A
MarshalledInstance contains an object in serialized form.Wrapper around
MarshalledInstance that samples the integrity setting (if any) of the
stream it is unmarshalled from, and uses that setting to determine whether or not to verify
codebase integrity when calling the get method of the
contained MarshalledInstance.a runtime exception that indicate a problem in serialization of user objects before sending it
over the wire.
An extension of
ObjectOutputStream that implements the dynamic class loading
semantics of RMI argument and result marshalling (using RMIClassLoader).An extension of
ObjectOutputStream that implements the dynamic class loading
semantics of Java(TM) Remote Method Invocation (Java RMI) argument and result marshalling (using
RMIClassLoader).Providing a lightweight replacement on the LUS.
Service that implements this interface will join the LUS using
MarshalPivot.MarshObject is similar to java.rmi.MarshalledObject.
Notice! this implementation is not Thread safe and should be use in conjuction with
ResourcePool only.A Matches contains the fields of a ServiceMatches packaged up for transmission between
client-side proxies and the registrar server.
matching entry to template can yield.
Base class for commons-math checked exceptions.
Base class for commons-math unchecked exceptions.
Some useful additions to the built-in functions in
Math.Picks the minimum of all cluster instances values.
Configurations that aggregate statistics from a time window by picking up the sample with the
highest value.
Creates a new
MaximumTimeWindowStatisticsConfig objectA default implementation of a reducer that returnt the maximum of
T.A max distrubuted task that accepts a
Task to delegate the
actual execution to and implements the MaxTask.reduce(java.util.List) operation.Created by IntelliJ IDEA.
Authority controlling access to MCP (Model Context Protocol) server operations.
Privileges for MCP server operations.
ServiceFactory implementation that launches the XAP MCP Server as an embedded
Spring Boot application inside an isolated classloader.
Uses
MessageDigest which provides applications the functionality of a message digest
algorithm, such as MD5.Encodes passwords using the MD5 algorithm.
A marker interface allowing beans to indicate the liveliness of a cluster member.
The member alive indicator allows to configure the SLA on how often a member will be checed to
see if a member is alive, and in case of failure, how many times to retry and how often.
Member alive indicator status is communicated by the Grid Service Manager when monitoring managed
processing unit instances.
A bean definition builder for
MemoryRequirement.An extension of the
ResourcePool which has memory boundaries, and it will not pool new
resources if the memory boundaries have reached.A memory only based implementation of the
IRedoLogFile interface.MemorySA is a mostly empty SA that is used for memory based space, it "implements"
IStorageAdapter interface.This Exception indicates that the space server process reached the predefined percentage usage
ratio.
Meta argument handler can control the meta data objects that will be used for the remote
invocation.
Wraps a
ILRMIInvocationHandler as a InvocationHandler with an internam RemoteMethodCache for fast transformation between regular method to LRMI method.Defines an immutable mapping from
Method to InvocationConstraints, used to
specify per-method constraints.The method event template provider adapter allows to configure the method name (using
MethodDynamicEventTemplateProviderAdapter.setMethodName(String) that the template request will be delegated to.The method event listener adapter allows to configure the method name (using
MethodEventListenerAdapter.setMethodName(String) that the event will be delegated to.A
FilterProvider factory that accepts a Pojo
filter with different operation callbacks that are marked using this factory.A default implementation of routing handler allowing to control the routing index of the remote
invocation based on the remote method parameters.
Exception thrown when the Code attribute of a method produced by a
ClassWriter is too
large.A visitor to visit a Java method.
Deprecated.
Use Micrometer metric types directly (io.micrometer.core.instrument.*)
Metric constants
Interface for metric flags state.
Deprecated.
Part of the legacy metrics system used by the deprecated
MetricRegistry.Deprecated.
Part of the legacy metrics reporter system.
Deprecated.
Use
MicrometerMetricManager instead.Deprecated.
Configuration class for the deprecated
MetricManager.Deprecated.
Part of the legacy metrics pattern matching used by the deprecated
MetricManager.Deprecated.
Part of the legacy metrics pattern matching used by the deprecated
MetricManager.Deprecated.
Part of the legacy metrics system used by the deprecated
MetricManager.Deprecated.
Part of the legacy metrics reporter system.
Deprecated.
Part of the legacy metrics reporter system driven by
metrics.xml.Deprecated.
Part of the legacy metrics reporter system driven by
metrics.xml.Deprecated.
Part of the legacy periodic sampling system used by the deprecated
MetricManager.Deprecated.
Configuration for the deprecated
MetricSampler.Loads metrics configuration from a properties file into system properties.
Deprecated.
Part of the legacy metrics tag system.
Deprecated.
Part of the legacy metrics reporter system.
Deprecated.
Unused legacy utility class.
Factory class for creating and managing Micrometer metrics (Timers, Counters, Gauges, etc.).
Micrometer-based implementation of metric management.
Adapter that bridges GigaSpaces MetricRegistrator API to Micrometer's MeterRegistry.
Builder for configuring MeterRegistry instances with various backends.
Utility methods for working with Micrometer meters.
Picks the minimum of all cluster instances values.
Configurations that aggregate statistics from a time window by picking up the sample with the
smallest value.
Creates a new
MinimumTimeWindowStatisticsConfig objectA default implementation of a reducer that return the minimum of
T.A min distrubuted task that accepts a
Task to delegate the
actual execution to and implements the MinTask.reduce(java.util.List) operation.Returns the the subtraction of two objects
Returns minute according to timestamp
Wraps a change operation as bulk item
Mirror space configuration.
A fix facade which resides in a mirror
Statistics on operations executed on mirror space.
Represents specific mirror operation statistics.
Statistics for single operation type
A Mirror persistency failure alert, triggered upon a failed replication from primary Space to
Mirror Space, due to an error (e.g.
A Mirror persistence failure alert configuration.
A Mirror persistence failure alert configurer.
Handles replicated transaction on mirror in batches.
Handles batch consumption event sent to the mirror.
Handles replicated entry operations on mirror
Handles incoming replicated operations on mirror
Handles replicated transaction on mirror.
mirror service configuration
A bean definition builder for mirror space
UrlSpaceFactoryBean. Interface for mirror operation statistics.
Default implementation of the mirror space statistics.
Thrown to indicate that the requested stub does not exists in the stub cache
Dictates which action to take when there are missing incoming replication packets
TODO add Javadoc
mock log manager for transient mahalo
Receives space mode change events and routs them to beans that use annotations to register as
listeners on those events.
Scans the bean's methods for the annotations
PreBackup, PostBackup, PrePrimary and PostPrimary and registers them in the ModeAnnotationRegistry.The Modifier class provides
static methods and constants to decode available
GigaSpaces types modifiers.Built in mathematical sql function to perform modulo operation.
A visitor to visit a Java module.
Parses <os-archive:mongo-archive-handler>
MongoDB driver client wrapper
Default spring bean factory implementation that can get external
MongoClientConnectorConfigurer as configurer otherwise create it own oneA
DocumentObjectConverter that does not fail if a type is missing during conversion.A MongoDB implementation of
SpaceDataSourceA MongoDB implementation of
SpaceSynchronizationEndpointA monitor bean.
A MonitorableService provides the semantics to determine if a service (which implements this
interface) is reachable.
Defines an Authority for monitoring a service, with the specified privilege.
Defines monitoring privileges
Should be put on operation or service that are required to have monitoring into the system, such
as UI, admin and so on.
Returns month name according to timestamp
Returns month according to timestamp
A map between a grid components uid to its statistics.
Class representing the values in a multicast announcement.
Interface implemented by classes which decode multicast announcement data according to discovery
protocol formats.
Interface implemented by classes which encode multicast announcement data according to discovery
protocol formats.
Represents a constraint on the size (in bytes) of multicast packets used in the multicast request
and multicast announcement discovery protocols.
Class representing the values in a multicast request.
Interface implemented by classes which decode multicast request data according to discovery
protocol formats.
Interface implemented by classes which encode multicast request data according to discovery
protocol formats.
Represents a constraint on the time to live (TTL) value set on outgoing multicast request and
multicast announcement packets.
A marker interface on top of the data source
DataIterator which
handles multiple data iterators.First tries and perform a
GigaSpace.readMultiple(Object, int, ReadModifiers)
using the provided template, configured maxEntries (defaults to 50) and the
configured fifoGroups (default to false).List of lists that should return result after intersection.
Utility class used by implementations which want to perform unicast discovery on possibly
multiple IP addresses for a given host name.
Callback interface for log files to remove themselves from this manager
Context for by ids operations .
A custom listener which is used to group all notification registrations from a space proxy using
a single listener.
Returns the the subtraction of two objects
First tries and perform a
GigaSpace.readMultiple(Object, int) using
the provided template and configured maxEntries (defaults to 50).A reliable async replication process log which merges multiple participants operations to a
single operation.
List of stored lists.
First tries and perform a
GigaSpace.takeMultiple(Object, int, TakeModifiers)
using the provided template, the configured maxEntries (defaults to 50) and the
configured fifoGroups (default to false).TODO add Javadoc
TODO add Javadoc
Represents a mutable server entry
Holds projection information per uid.
MVCC entry's metadata.
MVCC shell entry packet, built from
MVCCShellEntryCacheInfo,
is intended for space recovery with enabled mvcc.Iterator for mvcc shells
The name of a service as used by users.
Provides a thread safe name based lock interface for getting a shared lock instance based on its
name.
Utility class for calculating name of Admin instances
Utility class for calculating name of Admin instances
Utility class for loading native libraries in GigaSpaces.
Class implementing the
NestableTransaction interface, for use with transaction
participants that implement the default transaction semantics.Interface for classes representing nestable transactions returned by
NestableTransactionManager servers for use with transaction participants that
implement the default transaction semantics.Class that holds return values from create methods.
The interface used for managers of the two-phase commit protocol for nestable transactions.
A PrivilegedAction for creating a new thread conveniently with an AccessController.doPrivileged
or Security.doPrivileged.
This class provides configuration object of NIO communication transport protocol.
A general interface for services that can provide remote NIO information.
This class provides full information about physical connection to the remote object.
this exception is thrown when after update or RB of update the entry and template no more match
Class used to launch shared, non-activatable, in-process services.
Object returned by
NonActivatableServiceDescriptor.create() method that returns the proxy and implementation
references for the created service.No eviction strategy
A log entry matcher filter that matches on nothing.
A non reentrant implementation of
ISimpleLock The implementation intent is to save
memory, therefore the synchronization is done on the lock object it self, no user should
synchronize on the lock object it self as it may create deadlocks.A no op free port generator.
An exception indicating there are no results to reduce.
Thrown when an attempt to obtain an object from a
Configuration does not find a matching
entry.A NoSuchNameException is thrown when a lookup of an object by name is performed and the name is
not found.
Thrown when trying to retrieve a replication group from a
IIncomingReplicationFacade that
do not existsThis is the not-equal operator Node.
An implementation of not equals condition: This predicate returns true if and only if the
predicate's argument is not equal to the expected value.
Marks an event listener as polled event listener.
The filter is responsible to notify the backup space when all notification are sent to the user
An enum that specify a single notify action type such as write or update
and can also be used to composite a complex action type such as write OR update
and can also be used to composite a complex action type such as write OR update
NotifyActionType
updateOrWrite = NotifyActionType.NOTIFY_UPDATE.or(NotifyActionType.NOTIFY_WRITE); A
Notify annotation post processor.Holds a log of all the notifications that were received via replication from the primary.
Enables batching of notifications.
Holds a counter that indicates how many notifications are still not returned from the client.
Deprecated.
Use
DataEventSession instead.NotifyEvent is the object passed to filter when notify occurs
Notify container service details.
Notify container service monitors.
Holds a set of space.notify related parameters.
Deprecated.
Since 9.7 - event listener with custom lease or custom auto-renew is deprecated.
A failure to register a notify listener.
Deprecated.
use
NotifyActionTypethis class contains all the information relevant to a notify template.
Controls which type of notifications will be sent.
An extension of space event listener allowing the listener to control programmatically (without
the user having to configure it within the notify container) which notifications this listener
will be invoked on.
The NotInNode.
This is the NOT LIKE operator Node.
A predicate to test for non-null values.
Scans the index with the defined index name only for entries that don't match the given regular
expression.
Represents a negation of a regular expression range
An implementation of a logical unary NOT condition: This predicate returns true if and only if
the operand returns false.
A null backup policy which acts as a placeholder for a 'do-nothing' behavior.
Serializer for null.
This exception is thrown by an iterator constructor when there is no sufficient data in the
database to create the iterator.
Used for non-secured space
A predicate to test for null values.
Scans only the entries that have a null index value
A generic interface on top of a specific
Number implementation allowing to use it in a
generalized fashion.A factory allowing to create
NumberHelper implemenations
based on the provided Number type (such as Integer or Float).Utility for handling number functions
Serializer for Object.
Thrown when a conversion error occurred.
Copyright (c) 2010 GigaSpaces Technologies Ltd.
This exception is used in cases when a client tries to perform an action on a non existing space
object
The Object Registry contains information about exported remote objects.
Provides a collection of context information objects that are associated with an
ObjectOutputStream or ObjectInputStream instance that implements this
interface.Specifies object types.
Miscellaneous object utility methods.
Returns timestamp with time zone
A factory for creating
OffHeapBlobStoreHandler
instance.Off-Heap BlobStore statistics
This class provides repository of one-way remote methods.
If remote interface method doesn't have explicit
If remote interface method doesn't have explicit
OneWayRemoteCall annotation definition or OneWayRemoteCall
annotation can't be defined for Remote interface due the thirty party provider.This Annotation class provides one way remote method call by underlining communication
network protocol.
A callback method when the filter is closed.
A callback method when the filter is initialized.
The JVM opcodes, access flags and array type codes.
An operating system is a virtual entity that container information about the operating system one
or more grid components are running within.
A grid components that is operating system aware allows to get the
OperatingSystem that
it runs within.Operating System Details include static information (non-changeable) regarding the operating
system.
Machines hold all the different
OperatingSystems that are currently discovered.An aggregated view of all the currently discovered
OperatingSystemDetails.An aggregated statistics of all the different
OperatingSystemStatistics.An event indicating that
OperatingSystemsStatistics have changed.An event listener called when statistics have changed.
An event manager allowing to add and remove
OperatingSystemsStatisticsChangedEventListener.Statistics of a specific
OperatingSystem.An event indicating that
OperatingSystemStatistics have changed.An event listener called when statistics have changed.
An event manager allowing to add and remove
OperatingSystemStatisticsChangedEventListener.Global unique identifier of a client operation.
Indicates a priority on an interface which is used by LRMI layer to decide SLA for that method
invocation
A data of a batch of operations that is synchronized to a synchronization endpoint
OperationTimeoutException is thrown when a space operation timeouts after waiting
for a transactional proper matching entry.This class is an optimized porting of java.io.ByteArrayInputStream: a) All methods are not
synchronized.
This class is an optimized porting of java.io.ByteArrayOutputStream: a) All methods are not
synchronized.
Created by anna on 11/26/14.
Aggregator for order by operation.
Created by anna on 11/10/14.
Created by anna on 11/26/14.
This is the OR Node that represents an 'OR' between conditions
An implementation of a logical binary OR condition: This predicate returns true if and only if
either left or right operands return true.
Utility class for registering OSHI-based operating system metrics with Micrometer.
Supports single serializer multi concurrent deserializers
An NIO based implementation of LRMI Protocol Adapter
The basic design is as follows:
There will be a single 'pivot' object at the server side, that will act as a local proxy for all
server peers in the server JVM.
This exception is thrown when parse errors are encountered.
A
ParticipantTask is a general task which interacts with a participant.Represents the final selected indexes of a single partition along with its used tiers
All the index choices of specific partition
PartitionResultsMetadata is meta data attached to the multiple uids entry/template.
Since uids are just strings, they lose all the information about the space they came for.
PartitionResultsMetadata keeps this data so it can be used to route the uids to specific partition,
instead doing broadcast.
See
Since uids are just strings, they lose all the information about the space they came for.
PartitionResultsMetadata keeps this data so it can be used to route the uids to specific partition,
instead doing broadcast.
See
UidQueryPacketInterface for performing one-way encryption and authenticity validation on a password.
information about a path index segment of a compound index.
Info regarding a projection for a path
Performs paths projection on entry-packet data
Provides PBS services for writing/reading Entries to/from the space.
This class is an extension of a ByteArrayInputStream with PBS functionality.
an internal space exception thrown from the PBS system.
This class is an extension of a ByteArrayOutputStream with PBS functionality.
Holds PBS projection data.
Supply reused PbsStream buffers.
PbsTemplatePacket defines the template object for Pbs layer.
Peer is an abstraction for a connection endpoint, similar to a socket in the TCP/IP world.
this class is used for fifo templates such object is created for a non-uid-based fifo templates
in order to ensure that 1.
Picks the Nth percentile of cluster instance values.
Fluent API for creating a new
PercentileInstancesStatisticsConfig objectPicks the Nth percentile of time window instance values.
Fluent API for creating a new
PercentileTimeWindowStatisticsConfig objectGeneric persistency exception handler
PersistentGC thread.
an internal space exception thrown from the persistence mechanism
A system function that returns a decompiled source
code of a Postgres expression.
Filter that blocks phantom objects (already been removed) to reinsert by the replication.
The synchronizing direct-persistency embedded phantoms handler
A physical memory utilization alert, fired upon triggered machine physical memory thresholds.
A physical memory utilization alert configuration.
A physical memory utilization alert configurer.
Defines pipeline privileges
The Pivot is the center of the NIO Protocol Adapter server-side implementation.
A simple and generic implementation of the
AggregatedServiceDetails
interface.A plain wrapper around jetty.
A simple implementation of
ServiceDetails.A simple implementation of
ServiceMonitors.Provides utility methods for plaintext data operations.
Represents the logical version of the jar
Returns the the addition of two objects
A factory for creating
PmemBlobStoreHandler
instance.A Point with X and Y coordinates.
Defines default values used by both annotations and gs.xml.
Pojo introspector for all the pojo implementations.
helper class for fast reflection
A
FlattenedPropertiesFilter used internally to determine whether the given type is not
primitive or a common java type and if so, does this type have a default no-args constructors and
at lease 1 property with both getter and setter methods.POJO based
CompoundTypeNode.A policy controls the runtime action that should be taken when the monitor value associated with
this policy (using
Policy.setMonitor(String)) breaches the policy thresholds.Security policy provider that wraps the J2SE(TM) default
"PolicyFile" security policy provider distributed as part of the Java(TM) 2 Platform,
Standard Edition.
Exception indicating failed initialization of a security policy provider.
Marks an event listener as polled event listener.
A
Polling annotation post processor.Polling container service details.
Polling container service monitors.
A polygon, denoted by 3 or more points
An extension of Thread, PoolableThread instances know how to stay alive and wait in a pool
Used to create new resources by the
ThreadLocalPool.A role authority which holds all the authorities this role represents.
A port generator that accepts a basePort and a portOffest and simply adds them.
Allows a bean's method to be invoked after a space changes its mode to
SpaceMode.BACKUP.Allows a bean's method to be invoked after a space changes its mode to
SpaceMode.PRIMARY.Built in mathematical sql function to perform power operation.
Allows a bean's method to be invoked before a space changes its mode to
SpaceMode.BACKUP.A class loader that supports preferred classes.
An
RMIClassLoader provider that supports preferred classes.Internal data structure which holds preference information for a preferred class loader.
An implementation of a
Job which interacts with a set of
TransactionParticipants to inform them to vote and roll forward/back changes
associated with a given Transaction.2pc prepared xtns info
This is a Prepared node.
An implementation of a
com.sun.jini.mahalo.Job which interacts with a set of
net.jini.core.transaction.server.TransactionParticipants to inform them to vote.Allows a bean's method to be invoked before a space changes its mode to
SpaceMode.PRIMARY.Listeners for space stand by events.
PrimaryZoneController is a task that runs periodically and checks if primary-zone
definition is violated: 1.Used to keep hash table capacities prime numbers.
Utility class for testing wheter a given type is a primite type and to obtain reference to a
primitive type
Class instance by name.This election decision filter provides the condition to acquire desired space state on
NamingService.
An interface for all Privileges.
A delegating distrubuted task (with an optional filter) that runs under established access
control settings.
A delegating task that runs under established access control settings.
Cache for holding fast reflection based getters/setters/constructors.
A processing unit holds one or more
ProcessingUnitInstances.An event listener allowing to listen for
ProcessingUnit additions
(deployment).An event manager allowing to add and remove
ProcessingUnitAddedEventListeners.A processing unit container represents a currently running processing unit context.
Provides context for a processing unit container instance.
Allows for beans implementing this interface to be injected with
ProcessingUnitContainerContext.A general base class for processing unit container exceptions.
A processing unit container provider is responsible for creating
ProcessingUnitContainer.Same as Spring
ContextLoader.Excatly the same as
ContextLoaderListener excepts in
creating a {link ProcessingUnitContextLoader.Aggregates all of the processing unit lifecycle stages that can be postponed.
Defines dependency between an unspecified dependant processing unit and one required processing
unit.
A deployment of processing unit.
Defines a dependency that postpones the processing unit instance deployment.
A configurer (builder) object used to create a new
ProcessingUnitDeploymentDependenciesDefines dependency between one processing unit and multiple required processing units.
A processing unit instance is an actual running instance of a processing unit.
An event listener allowing to listen for
ProcessingUnitInstance
additions.An event manager allowing to add and remove
ProcessingUnitInstanceAddedEventListeners.A simple combination of a
ProcessingUnitInstance lifecycle
events.A processing unit instance fault-detection alert triggered when a Grid Service Manager fails to
monitor a processing unit instance.
A processing unit instance fault-detection configuration.
A processing unit instance fault-detection configurer.
An event raised when a processing unit instance
MemberAliveIndicatorStatus has changed.An event listener allowing to listen for
ProcessingUnitInstanceMemberAliveIndicatorStatusChangedEvents.An event manager allowing to add and remove
ProcessingUnitInstanceMemberAliveIndicatorStatusChangedEventListeners,
in order to listen to ProcessingUnitInstanceMemberAliveIndicatorStatusChangedEvents.A provision failure that occurred while trying to instantiate an instance on a grid service
container.
An event raised when a processing unit instance
ProvisionStatus has changed.An event listener allowing to listen for
ProcessingUnitInstanceProvisionStatusChangedEvents.An event manager allowing to add and remove
ProcessingUnitInstanceProvisionStatusChangedEventListeners,
in order to listen to ProcessingUnitInstanceProvisionStatusChangedEvents.An event listener allowing to listen for
ProcessingUnitInstance
removals.An event manager allowing to add and remove
ProcessingUnitInstanceRemovedEventListeners.Processing Unit Instance statistics provide statistics on services configured within the
processing unit.
An event indicating that a processing unit instance level statistics has changed.
An event listener called when statistics have changed.
An event manager allowing to add and remove
ProcessingUnitInstanceStatisticsChangedEventListener.An event listener supporting combining several listeners into one simple listener.
Failure to find a processing unit to deploy to.
A Space partition mainly make sense with partitioned topologies and holds all the
ProcessingUnitInstances that form the partition.Parses processing unit path
An event listener allowing to listen for
ProcessingUnit removal
(undeployment).An event manager allowing to add and remove
ProcessingUnitRemovedEventListeners.Holds one or more
ProcessingUnits.An event that indicates that an (embedded)
Space was correlated with the processing
unit.An event listener allowing to register for
ProcessingUnitSpaceCorrelatedEvents.An event manager allowing to add and remove
ProcessingUnitSpaceCorrelatedEventListeners
in order to listen for ProcessingUnitSpaceCorrelatedEvents.Provides an aggregation of the @{link
ProcessingUnitInstanceStatistics service monitorsIdentifies a processing unit statistics value, by specifying the monitoring source and the
statistics functions applied to it.
Provides fluent API for creating a new
ProcessingUnitStatisticsId object.An event raised when a Processing Unit
DeploymentStatus has
changed.An event listener allowing to register for
ProcessingUnitStatusChangedEvents.An event manager allowing to add and remove
ProcessingUnitStatusChangedEventListeners
in order to listen for ProcessingUnitStatusChangedEvents.An enumeration which specifies the type of the processing unit.
An interface allowing to be notified when a processing unit is undeploying.
Extends Spring
XmlWebApplicationContext allowing
to dynamically add (during construction) a BeanPostProcessor.Deprecated.
Used only by the legacy
MetricManager.An interface used with
Task allowing to return additional
objects to be processed on the node the task is executed.Main logic handler inside engine.
Holds projection template data
Formats a Fraction number in proper format.
Note that this is a technology preview feature may be changed in the future.
Queries an entry that matches all the given properties.
information about a property index segment of a compound index.
An interface used by
FlattenedPropertiesFilter to pass the current inspected property
introspection context.Represents an entry property.
Base class for adapting space properties values before storing them in space or after retrieving them.
An interface used for conversion of objects to/from
ByteBuffer.An adapter from
PropertyValueSerializer to hector's Serializer.Protective mode setup class, holds the current protective mode setup
Thrown when protective mode prevents from wrong usage of the system
ProtectiveModeSpecify protective mode different properties
A Protocol Adapter abstracts a specific communication protocol.
A
ProtocolException is thrown as a result of a remote method invocation while
unmarshalling the arguments to get request/reply packet.The ProtocolRegistry maps between LRMI Protocol names to Protocol Adapters.
A provision failure alert triggered when a processing unit has less actual instances than planned
instances.
A provision failure alert configuration.
A provision failure alert configurer.
The provision status of a processing unit instance.
Provides a means to obtain a proxy from an exported remote object.
Holds already created proxies.
Created by Barak Bar Orion 6/24/15.
an internal space exception thrown from the proxy.
InvocationHandler is the interface implemented by the invocation handler of a
proxy instance.Performs operations on a newly unmarshalled remote proxy to prepare it for use.
Essential proxy settings.
Defines a remote interface for obtaining a proxy trust verifier.
Contains the information necessary to export a remote object that has a proxy that will not
directly be considered trusted by clients, such that the proxy can be trusted by clients using
ProxyTrustVerifier.Invocation handler for remote objects, supporting proxy trust verification by clients using
ProxyTrustVerifier.Defines an iterator that produces objects from which a
TrustVerifier
might be obtained.Trust verifier for service proxies that use dynamically downloaded code.
PType mapping from <K:int, V:PType> as a resizable-array implementation.
A processing unit fault detection handler.
A specific pattern resolver that handles the following:
1.
listener is called to sign that partition status has changed during the scale process
Represents a change operation which correlate with a
ChangeSet.putInMap(String, java.io.Serializable, java.io.Serializable) invocation.Returns quarter according to timestamp
An interface that represents an SQL query.
Caches JDBC queries by their string representation
Executes queries against the space.
handler of foreign indexes and query-executers
Represents path's annotation
QueryHandler executes the JDBC statements set by the
GConnection.Factory for creating custom query index scanners
Manages SQLQuery execution on the proxy side
Deprecated.
since 7.1.
Deprecated.
since 7.1.
The QueryProcessor main class.
Configuration object for the QueryProcessor
Factory for QueryProcessor that creates the appropriate instance according to configuration
Smart stub for the
QueryProcessorSubAction that contains most Action parameters and implements ParamProxyAction for access.
Determines whether a query will return objects (a.k.a.
Indicates what type of result is expected when querying the space.
This is a wrapper class that holds the information relevant per session that the QueryHandler
should use.
Builds an external entry from
ExpNode The builder converts the expression tree to ranges.Created by tamirt on 23/08/16.
Used for telling PU instances that quiesce request was sent, the instances then will inform their
services (e.g space) about the quiesce request.
Represents the quiesce details of the processing unit.
This exception is thrown when any non-admin op' is issued to a non-backup space in quiesce mode
This exception is thrown when the quiesce request is rejected by the
GSMSuspend/Quiesce core functionality
A request which includes all needed information about the quiesce request (e.g reason for
entering to QUIESCE mode , the user name which triggered the operation, the time and date and so
on)
A result of triggering
ProcessingUnit.quiesce(QuiesceRequest) or
ProcessingUnit.unquiesce(QuiesceRequest) (QuiesceRequest)} The
result contains QuiesceToken and description about the
request.Represents an event which is fired to inform about quiesce state changed
A base interface for implementing QuiesceToken.
Convenient factory for creating QuiesceToken.
IByteBufferStorage implementation that is based on RandomAccessFileIByteBufferStorageFactory implementation that provides RAFByteBufferStorage
instancesBuilt in mathematical sql function to perform random operation.
Scans only the entries in the defined range via compound index
Scans only the entries in the defined range
A bean definition builder for
RangeRequirement.Created by boris on 12/30/2014.
Thrown when readByIds operation fails.
Thrown when readByIds operation fails.
Holds a ReadByIdsException result.
Determines the result type of a read by id operation result.
TODO add Javadoc
Holds iterable results of the
readByIds operation.A Reader is capable of reading Request Packets and Reply Packets from a Socket Channel.
An Object to control the concurrent state.
InterruptedException transformed to a runtime exception.
A
ReadModifiers factory bean.Provides modifiers to customize the behavior of read operations.
The
ReadModifiers class provides static methods and constants to decode Read
type modifiers.Context for readMultiple operation - accumulates operation results and exceptions
Thrown when a space readMultiple operation fails.
Thrown when a readMultiple space operations fails.
Acts as an
Iterator which supports only read operation, hence it does not contain the
remove operationHandle read events from selector.
Holds a read/takeByIds operation's exception result.
A base class for Read/TakeByIdsException
ReadByIds operation results holder.
Executed a single read or take operation on the space
A trigger operation handler that performs read based on the provided template and returns its
result.
Utility class used to prevent access to a service before it has completed its initialization or
after it starts to shutdown.
An annotation marking a method as one that is responsible to return a
ReceiveOperationHandler to be used with a polling
container.Perform the actual receive operations for
SimplePollingEventListenerContainer.keep info regarding recentDeletes- relevant for evictable entries
Created by yechielf on 01/02/2016.
keep info regarding recentUpdates- relevant for evictable entries
A visitor to visit a record component.
A DiscoveryListener that keeps a record of discovered and discarded ServiceRegistrar instances
Recovery super class
RecoveryManager is responsible for the memory recovery of the space
A rectangle, denoted by 2 points.
Thrown when the redo log reach its planned capacity and operations should be blocked until the
redolog size is reduced
This exeception indicates the redo log reached its planned capacity and operations should be
blocked until the redolog size is reduced
RedoLogCapacityExceededExceptionDictates which action to take when the redo log capacity is exceeded
Thrown when a redolog file integrity is compromised, such as unavailable storage or some error
which causes a corruption of the redolog
IRedoLogFile.validateIntegrity()Redo log statistics
Not serializable should go over the wire
Specifies the redo log swap storage type to use
Reentrant implementation of
ISimpleLock The implementation intent is to save memory,
therefore the synchronization is done on the lock object it self, no user should synchronize on
the lock object it self as it may create deadlocks.Defines an interface that allows a proxy for a resource to express the identity of that resource.
Convenience methods for working with proxies that implement
ReferentUuid.Simple utility class for handling reflection exceptions.
Callback interface invoked on each field in the hierarchy.
Callback optionally used to filter fields to be operated on by a field callback.
Action to take on each method
Callback optionally used to method fields to be operated on by a method callback.
A generic interface allowing to refresh context loader.
A bean definition builder for
SpaceModeContextLoader.Executes the refresh context mode operation using OpenSpaces sync remoting (allowing to use
broadcast mode).
Extension to SpaceModeContextLoader allowing for the context loader to be refreshable and load
new code.
Holds a cache of already compiled regular expressions.
Scans the index with the defined index name only for entries that match the given regular
expression.
A log entry matcher filter that will match on log entries which match on the given regular
expression.
Represents a regular expression range
Class to hold basic information for a discovered/discarded reggie
A task that registers a dynamically added event container in a distributed manner.
Executes notify operation on the space
An interface for resolving data conflicts caused by a register type descriptor operation.
Registrar defines the private protocol between the various client-side proxies and the registrar
server.
Concrete implementation class for abstract ServiceEvent.
An instance contains a name (also referred to as a "target name") but no actions list; you either
have the named permission or you don't.
Scans the index using an external index using one of the relation that the external index is know
to handle.
Created by Barak Bar Orion 8/24/15.
Created by Barak Bar Orion 8/24/15.
ITimeProvider implementation specifying a precise timer, which is not
influenced by motions of the wall-clock time.
Implemented by constraints that are expressed in terms of relative time, to support conversion to
absolute time constraints.
A process log builder that creates a processing log according to the given target group config
process log configuration
If the keeper is in lru with central data source, it will convert update operations to remove, we
need to send the update partial with the previous state of the entry if we have view targets
This class is a simple implementation of a reliable Log.
Relocation policy will cause a processing unit instance to relocate when the policy associated
monitor breaches its threshold values.
A bean definition builder for
RelocationPolicy.A thread local class that keeps the context of the remote class loader
Created by tamirs
on 11/14/16.
Wraps
RemoteException that is thrown from the Space.The base class or superclass for remote events.
This utility class serves to access to the package/protected methods of EntryArrivedRemoteEvent
from other packages.
A RemoteEventBatchBusPacket represents a batch of remote events that should be sent to a remote
listener.
A RemoteEventBusPacket represents a remote event that should be sent to a remote listener.
The RemoteEventListener interface needs to be implemented by any object that wants to receive a
notification of a remote event from some other object.
A remoting aspect allows to wrap the remote invocation with specific "user" logic, for example,
to add retry in case of a failure, security, or something similar.
This class contains a sorted method-map of exported Remote Object with fast method search by
IdentityHashMap.
Defines an interface to proxies for setting constraints to control remote method calls.
A remoting result reducer (ala Map Reduce) used when working with
ExecutorSpaceRemotingProxyFactoryBean in broadcast mode in order to
reduce the broadcast results into a "client side" result value.A general interface allowing for pluggable computation of the remoting invocation routing field.
Internal remote method calls to a secured service.
The
RemoteStub class is the common superclass to client stubs and provides the
framework to support a wide range of remote reference semantics.A Space remoting exception caused by a timeout waiting for a result.
A bean definition builder for
RemotingAnnotationBeanPostProcessor.Interface representing a remote invocation.
A set of common code shared between different remoting proxies.
A generic remoting service details.
A generic event container service monitors.
Represents a change operation which correlate with a
ChangeSet.removeFromCollection(String, java.io.Serializable) invocation.Represents a change operation which correlate with a
ChangeSet.removeFromMap(String, java.io.Serializable) invocation.The set of changes to apply for matches entries of the change operation
This bus packet is created for asynchronous handling of waiting for templates when an entry is
removed in
removeEntrySA().Concats a string to itself n times
Using replaceInFile function you need make instance of
ReplaceInFileUtils class.Built in string sql function to replace matching subtring with other argument
Thrown when replica process has no progress for predefined timeout configuration and therefore
the replica is aborted and failed.
If using a replicated space controls if the listener will be replicated between all the
replicated cluster members.
A replication channel disconnection alert, fired upon a disconnected channel between a source
(primary Space) and it's target (backup Space or Mirror).
A replication channel disconnection alert configuration.
A replication channel disconnection alert configurer.
Delegates incoming replication to a different replication connection The source of this
connection proxy "thinks" he is working directly with the delegated target
A container of replication connection delegators
Created by niv on 5/15/2016.
Configuration for a replication target routing via delegator
Contains replication endpoint details
IEntryHolder implementation which holds the entry's previous version in space before
update operation.ReplicationException is the super-class exception for all replication exceptions.
Wraps a new
IReplicationPacketEntryData that has an inner entry and esposes it self as a
replication filter entryThis exception thrown back into the client when there is problem at the
For exception details call ReplicationFilterException.getCause().
IReplicationFilter.process()
implementation.For exception details call ReplicationFilterException.getCause().
Replication Filter Manager.
An
IReplicationFilter provider for both input and output
replication filteres.Responsible for creating
ReplicationFilterProvider.Wrapper for the
IReplicationFilterReplicationGroupRecovery defines how to recover in replication group
Handles exceptions on consuming replication packets.
an internal space exception thrown from the replication system.
Created by Barak Bar Orion 12/08/14.
Replication lookup finder service used for finding exported replication services.
Replication lookup registration service used for registering replication services with a
possibility to start an embedded Jini LUS.
The implementation of the
IReplicationNode interfaceAdministrator of a
ReplicationNodeProvides configuration needed in order to construct a
ReplicationNodeA components inside
ReplicationNode that holds all the replication groupsA component that belongs to the
ReplicationNode that implements the IReplicationInFacadeInner component of the
ReplicationNode that is in charge of handling incoming replica
requestsRepresents all the possible operation types that can be replicated.
Thrown when trying to execute an illegal conversion of
IReplicationPacketEntryData using
IReplicationPacketEntryDataContentExtractor#convertSingleEntryData(IReplicationPacketData, ReplicationEntryDataConversionMetadata, PlatformLogicalVersion)Replication policy description for every member.
Specifies the replication processing type
GigaSpaces replication service.
A replication redo-log overflow to disk alert, fired when the redo-log exceeds the defined
redo-log memory capacity and overflows to disk.
A replication redo log overflow to disk alert configuration.
A replication redo log overflow to disk alert configurer.
A replication redo-log size alert, fired upon redo-log increase, indicating that packets are not
being sent from a source Space to it's target Space (backup or mirror).
A replication redo log size alert configuration.
A replication redo log size alert configurer.
Represents replication operation type, used internally by the
ReplicationNodeActs as a sink for incoming replication
ReplicationStartupManager handles the space startup state in persistent replicated cluster.
Represents the current state of the replication module
Specifies the current channel state
Expose outgoing replication channel statistics
Specifies the replication channel current operating mode.
The replication status from one
SpaceInstance to its
replication target.An event indicating that the replication status was changed from a
SpaceInstance to its
ReplicationTarget.An event listener allowing to register for
ReplicationStatusChangedEvents.An event manager allowing to add and remove
ReplicationStatusChangedEventListeners
in order to listen for ReplicationStatusChangedEvents.Represents a replication target from one
SpaceInstance to the
other.Specified the replication target type
This class describes the transmission policy from source space to a target space.
A Reply Packet is constructed by the NIO server and sent back to the client peer.
A Request Packet is constructed by the NIO client peer and sent to the server.
The RequestPacket class.
On top of
RequestTimeoutObserver behaviour, The request response timeout observer also
sends a monitor request to the corresponding server and checks whether the corresponding channel
entry in currently in progress.A simple statistics filter that counts the total processed and failed (i.e.
RequestTimeoutObserver handles NIO connection timeouts on the client side.
Converts
RequiredDependencies to command-line parameters (GSM Operational String)
Currently supported are only dependencies that are required before a ProcessingUnit instance is
deployed on a GSC.An
RMIClassLoader provider that supports preferred classes and enforces DownloadPermission.A base class for PU zones
A marker interface for requirements.
Resources should extend this class and implement all abstract methods.
A Spring
ApplicationContext implementation that works with
Spring Resource for config locations.Thrown when a resource usage is exceeding its capacity
MemoryShortageException RedoLogCapacityExceededExceptionThis exception indicates that a resource usage on the server is exceeding its capacity
SpaceMemoryShortageException RedoLogCapacityExceededException ResourceCapacityExceededExceptionA resource lazy loading script is a lazy loading script that uses Spring abstraction on top of
resources on top of a resource.
The class is responsible on loading the product resources such as space/container/cluster schema
xsl files, static cluster xml files, custom properties files, DCache config files etc.
This class encapsulates schema file properties: InputStream, and full path ( including host
IP or name )
A Bound Pool of Resource objects.
A generic abstract class to handle a finite set of resources
Exception to indicate that there are no available resources that became available during the
specified wait time.
This is a thread local based context that is used to send response back to the client not in the
current stack, but rather from a different thread that will use a stored context in the memory.
The ResponsePacket class.
This is the result from which a ResultSet will be constructed in response to a SELECT query.
Fix a problem of extend notify template lease that do not exists anymore in the target (long
disconnection ,recovery).
A streaming log entry matcher that allows to traverse the log entries in a streaming manner in a
reverse order.
Returns a substring of a given string starting from the right
The RioServiceDescriptor class is a utility that conforms to the Jini technology ServiceStarter
framework, and will start a service using the
CommonClassLoader as a
shared, non-activatable, in-process service.This is the an operator that is used for java regular expression matching
Copyright (c) 2010 GigaSpaces Technologies Ltd.
Created by Barak Bar Orion 6/24/15.
A simple configurer helper to create
RocksDBBlobStoreHandler instances.A factory for creating
RocksDBBlobStoreHandler
instance.Created by kobi on 3/8/15.
Rocks DB BlobStore statistics
Creates an iterator that can be used to exhaustively for retrieving data from RocksDB.
see BlobStoreSegmentedParallelIterator
Models role details retrieved by
RoleManager.Thrown if an
RoleManager implementation encounters a non unique user.Defines an association of a role by-name.
Empty placeholder for Role privilege (part of authority format)
Implements
UserDetailsService and populates privileged authorities.Thrown if an
RoleManager implementation cannot access a user record.Role details to store role information accessed by the
RoleManager and SecurityManager.The main interface for managing role details.
Thrown if an
RoleManager implementation cannot locate a role by its role-nameA RollbackBusPacket represents a transaction rollback.
Rolling based logging
Handler.A configurer for known properties which their generated values can be overridden.
Built in mathematical sql function to round the argument to nearest Integer.
A method parameter annotation allowing to control the routing of a certain remote invocation
using an annotation.
This node represents the rownum command.
Decorates a runnable with the property that the execution of the runnable will be made with the
specified class loader
An adapter allowing to execute a
Runnable in a distributed fashion.An adapter allowing to execute a
Runnable using Space task executors.Space runtime state holds the state of the space instace, for example, primary backup and
replication status.
Holds runtime statistics counters.
Maintains a pool of ReadWriteLock lockers, used by SLs in order to avoid creating an expensive
lock per SL (i.e.- index value) used by classes like RwlSegmentedStoredList or RwlStoredList in
order to reduce memory footprint.
Deprecated.
SAException is a class that wraps exception that are thrown at the storage adapter.
Safe use "array", to use when
ArrayIndexOutOfBoundsException might accord.This is the base class of all cache iterators.
A log entry matcher filter that matches on logs that only exists within the same log file.
A delegate allowing for a proxy registered with the LUS to provide a version handle that will be
used to check if it is the same veresion as another service.
Created by Barak Bar Orion on 3/20/16.
A common basic implementation for scalar comparison predicate implementations.
Scale up policy will cause a processing unit instance to be created when the policy associated
monitor breaches its threshold values.
A bean definition builder for
ScaleUpPolicy.manages the vertical scale for partition/multi partitions/service.
No index - just scan all the entries and find matches
TODO add Javadoc
TODO add Javadoc
TODO add Javadoc
ScheduledRunner is a single daemon thread that wakes up at fixed intervals, to run a single
Runnable task.
Holds the statics monitor future and lock mechanism.
Scheduled thread pool based implementation for
IAsyncHandlerProviderA script that will be excuted.
An exception indicating a sctipt compilation error.
An exception indicating failure to execute the script.
A general scripting exception.
Scripting executor allows to execute
Script using remoting.A remoting routing handler that uses
Script.getRouting() in order to computer the routing
index.An exception indicating that a script was executed without its script content not loaded.
Returns seconds according to timestamp
Secured PU JMX MBean implementation
Secured PU JMX MBean interface restricting access to the default MBean
ServiceBeanAdapterMBean.An interface indicating the service is secured.
Provides methods for executing actions with privileges enabled, for snapshotting security
contexts, for verifying trust in proxies, for verifying codebase integrity, and for dynamically
granting permissions.
Thrown for a failed operation on a secured service, due to either failed authentication or access
denial.
Security auditing interface
A factory for creating
SecurityAudit implementation
Created by moran on 4/11/16.A configuration object allowing to configure security context (username, password) when working
with the Space.
Created by evgeny on 4/24/16.
Security context passed between proxy and server.
Deprecated.
Interface implemented by objects representing security contexts, returned from the
getContext method of the Security class, which in turn may obtain
them from a security manager or policy provider implementing the SecurityContextSource interface.Accessor method for setting Security Context attributes which their setter method should not be
directly exposed.
Interface that a security manager or policy provider can optionally implement in order to support
the saving and restoring of custom security context state.
Base class for all security related exceptions.
A factory for creating an
SecurityManager and locating of security properties file by
name.Server-side security interceptor, responsible for authentication against the underlying
SecurityManager, handing of authentication tokens to authenticated users, and intercepting any
access to resources.Interface for authentication and creating of the directory manager.
Helper class for resolving if security is enabled.
Used to intercept a trusted security context.
Provides a segmented counter while the get() returns an accurate result.
A segmented implementation of ReentrantReadWriteLock, providing better concurrency.
Defines a range of objects.
This class represents a column in a select query.
Event queue for I/O events raised by a selector.
This class handles the SELECT query logic.
Specifies types of select.
Holds a weak key for each value and make sure each value will be cleaned when key is weakly
held.
Holds a weak reference for each value and make sure each value will be cleaned when is weakly
held.
handle sequenceNumbers creation/getting/updates
Make javacc Token serializable by extending this class
Such exception thrown when the serialization fails
A utility that provides a way to serialize and deserialize an entry field
A map based
Serializer provider inspired by hector's SerializerTypeInfererA simple implementation wrapping several iterators and exposing them as a single (serial)
iterator.
Implements the server side of the
net.jini.discovery.plaintext discovery format.A holder for remote LRMI server address
Represents a constraint on authentication of the server to the client.
The
ServerContext class contains static methods to execute some action within an
appropriate server context for the current thread and to obtain the server context for the
current thread.Defines the interface for server context providers, which are consulted by
ServerContext.getServerContext() if no server context has been explicitly associated with the
current thread via a previous call to ServerContext.doWithServerContext(java.lang.Runnable, java.util.Collection).Represents an entry stored in the space.
Represents a constraint on the server, such that if the server authenticates itself, then it must
authenticate itself as at least all of the specified principals.
ServerPeer extends Peer with server-specific operations.
Defines a local interface to obtain a proxy trust verifier.
Class implementing the
Transaction interface, for use with transaction participants
that implement the default transaction semantics.Copyright (c) 2010 GigaSpaces Technologies Ltd.
A simple service-provider lookup mechanism.
The Service interface provides an aggregating mechanism, putting requisite interfaces together to
represent the remote semantics of a core Service in the architecture
A
SecurityManager wrapper that adds service-account JWT authentication
on top of any legacy SecurityManager (File-based or Spring-based).Copyright (c) 2010 GigaSpaces Technologies Ltd.
Copyright (c) 2010 GigaSpaces Technologies Ltd.
Copyright (c) 2010 GigaSpaces Technologies Ltd.
Defines service privileges
The ServiceClassLoader overrides getURLs(), ensuring all classes that need to be annotated with
specific location(s) are returned appropriately
Holds the
LRMIClassLoaders that associate to a specific service class loaderServiceConfigLoader
Utility class for loading services.config configuration and exporter.
Error thrown when something goes wrong while looking up service providers.
This interface indicates that an Entry class is created and modified by the service with which it
is associated.
Interface that all service description objects must implement.
A generic service that exists within a processing unit.
A provider of one or more
ServiceDetails.The
ServiceDiscoveryEvent class encapsulates the service discovery information made
available by the event mechanism of the LookupCache.The
ServiceDiscoveryListener interface defines the methods used by objects such as a
LookupCache to notify an entity that events of interest
related to the elements of the cache have occurred.The
ServiceDiscoveryManager class is a helper utility class that any client-like
entity can use to "discover" services registered with any number of lookup services of interest.This class is used for remote events sent by the lookup service.
A service execution callback allows to wrap the execution of "server side" service.
A wrapper for method invocation.
A universally unique identifier (UUID) for registered services.
Interface used by a service that does not yet have a service ID, for callback from the
JoinManager when a service ID is assigned.
Generic information about a service.
Items are stored in and retrieved from the lookup service using instances of this class.
The
ServiceItemFilter interface defines the methods used by an object such as the
ServiceDiscoveryManager or the LookupCache to apply additional selection criteria when searching
for services in which an entity has registered interest.An instance of this class is used for the return value when looking up multiple items in the
lookup service.
Merges together a set of ServiceItems extracted from a ServiceMatches result.
A generic service that exists within a processing unit.
A provider of one or more
ServiceMonitors.Provides a means to obtain a client-side proxy from a "base" service object.
A service reference (the reference is generally the Spring bean id).
Defines the interface to the lookup service.
A registered service item is manipulated using an instance of this class.
This class provides the main routine for starting shared groups, non-activatable services, and
activatable services.
A Service state, defined by one of org.jini.rio.core.jsb.ServiceBeanState .
Items in the lookup service are matched using instance of this class.
Human-oriented information about the "type" of a service.
A ServiceType annotated with a codebase.
Thrown when attempting to invoke a remote method using LRMI on a service which does not support
this method
A holder for session details at server-side.
Represents a unique identifier for an established session.
Represents a change operation which correlate with a
ChangeSet.set(String, java.io.Serializable) invocation.Created by Barak Bar Orion 19/08/14.
A
SettlerTask is scheduled task, which causes an unsettled transaction to settle.Created by Tamir on 1/7/16.
shadowEntry is an entry version under pending update- it contains the original entry values note
that shadow and master are connected via a mutual reference
Markup interface to serve as base for all spatial shapes supported by XAP.
Factory class for creating spatial shapes.
Encapsulates Shape formats supported by XAP GeoSpatial API
Permission class used by the service starter package.A helper to construct web context path.
Shared iterator shares a single
DataIterator among several instances, each instance gives
the impression of a separate data iterator.Used to create
SharedDataIterator over a single DataIterator, the iterator source
is in charge of mediating between the shared iterators, always only one shared iterator is
accessing the actual iteratorThrown when an operation on a
SharedDataIteratorSource is executed when it is closed and
it cannot accept itThrown when an operation on a
SharedDataIteratorSource is executed when it has expired
and it cannot accept itA helper allowing to share and return cached LDM and SDM.
Deprecated.
A cache to share async handler providers within the same context (service class loader/processing
unit instance)
Decorates a
SpaceDataSource with additional property, concurrent request for an iterator
which is based on the same query will only open one underlying iterator against the decorates
provider, this iterator will be shared amont the concurrent requests as if each of them has its
own iterator.Decorates a
SQLDataProvider with additional property, concurrent request for an iterator
which is based on the same query will only open one underlying iterator against the decorates
provider, this iterator will be shared amont the concurrent requests as if each of them has its
own iterator.A shared jetty holder that keeps upon first construction will store a static jetty instance and
will reused it from then on.
A singleton instance of Jini
LeaseRenewalManager configured using ServiceConfigLoader.getConfiguration().Statically hold different class loaders per jee container
A Jetty
ThreadPool that shares a single instance of a thread pool.Serializer for short.
A simplified programmatic configuration that for
SimpleAsyncPollingEventListenerContainer.Async polling event container uses the space async operation capabilities (such as
GigaSpace.asyncTake(Object) in order to simulate events (optionally
transactional).An implementation of interface CharStream, where the stream is assumed to
contain only ASCII characters (without unicode processing).
A simple, non LRMI, implementation of IClassProvider.
Holder for simple compound index value of 2 segments
A simple implementation of delegating distributed task that accepts the task to delegate to.
A simple implementation of delegating task that accepts the task to delegate to.
Read/Write Lock version of StoredList to be used with JDK 1.5+
An implementation of a re-usable
Log.A simplified programmatic configuration that for
SimpleNotifyEventListenerContainer.A simple notification based container allowing to register a
SpaceDataEventListener that will be triggered by notifications.A simplified programmatic configuration that for
SimplePollingEventListenerContainer.Event listener container variant that uses plain Space take API, specifically a loop of
GigaSpace.take(Object, long) calls that also allow for transactional
reception of messages.A simulation of a shared lock, which is not really shared...
An unmodifiable
List holding a single element.A
DataIterator for single entry or empty result sets.Defines that statistics are not aggregated but for a specific instance.
Fluent API for creating a new
SingleInstanceStatisticsConfig objectPerforms a single take usign
GigaSpace.asyncRead(Object).Performs single read operation using
GigaSpace.read(Object, long).Performs a single take usign
GigaSpace.asyncTake(Object).Performs single take operation using
GigaSpace.take(Object, long, TakeModifiers).A simple
ProxyTrustIterator that produces a single object as the only element of the
iteration.A bean definition parser for
SinkErrorHandlingFactoryBean.A factory bean used for configuring the Sink component error handling configuration.
Extends ConcurrentHashMap, keeping AtomicInteger as size counter.
First try to evict the biggest object.
A matcher that returns only stores the last N entries but does not break (basically, will return
the last N elements processed).
Flat sizeof() for java Objects.
A rolling policy based on file size limit.
A set of definitions controlling the nature of a processing unit deployment on the Service Grid.
A bean definition builder for
SLA.A namespace handler for
sla namespace.SlowConsumerExceptions is thrown when slow consumer is disconnected.
A smart buffer caching based on soft reference
Externalizable markup extension for GigaSpaces enhanced serialization.
A smart length based caching based on soft reference
Delegates synchronization issues to the source in order to get a solution
A space is composed of several
SpaceInstances the form a
topology.An event listener allowing to listen for
Space additions.An event manager allowing to add and remove
SpaceAddedEventListeners.Enables beans implementing this interface to get notified after a space changes its mode to
SpaceMode.BACKUP.Enables beans implementing this interface to get notified after a space changes its mode to
SpaceMode.PRIMARY.This exception is thrown in case where there is an attempt to perform any space operation such as
write, read or take when space is paused.
Copyright (c) 2010 GigaSpaces Technologies Ltd.
This exception is thrown in case where there is an attempt to stop already stopped space.
Spring MVC controller for the RESTful Space API
Defines an Authority for operating on Space (stored) data, with the specified privilege.
Class filter accepting only the defined class-name.
interface for data access filtering.
Class filter accepting only classes not of the defined class-name.
interface for restrictive data access filtering.
Package filter accepting only packages not of the defined package.
Negate a regular expression filter.
Package filter accepting only the defined package
Regular expression filter, using a regular expression as a pattern of characters that
describes a set of strings.
Defines operation privileges
Convert a wildcard expression to a filter instance.
Enables beans implementing this interface to get notified before a space changes its mode to
SpaceMode.BACKUP.Enables beans implementing this interface to get notified before a space changes its mode to
SpaceMode.PRIMARY.BroadcastNotifyTemplateReplicaProducer creates a replica of the space broadcast
notifications.Thrown when a local cache/view initialization fails.
A runtime exception for cassandra data source related runtime exceptions
Base runtime exception class for all cassandra related exceptions.
A runtime exception for exceptions that occur during queries or during iteration over a result
set.
A runtime exception for Cassandra schema update related exceptions Contains an isRetryable field
denoting wheter this is an exception which might be resolved by retrying the operation.
A runtime exception to denote exceptions that serialization/deserialization of object to/from
Cassandra.
A runtime exception for cassandra data synchonization related runtime exceptions
A runtime exception to denote exceptions that occured during reflection based type introspection
SpaceCfg
Defines a class annotation of Entry/POJO
objects.
Indicates that entries of this class will be stored in-memory in a packed binary format.
Specifies that the annotated constructor should be used to read the class properties and to
instantiate new instances.
This exception is thrown in case where there is an attempt to perform another space operation
such as write, read or take while "clean" is still in progress.
Thrown when operation is performed while space is closing its resources.
An index for a path containing a collection ("[*]").
SpaceComponentManager handles SpaceInternal components.
The manager handles all space mode transitions and changes the components state according to the space state.
The manager handles all space mode transitions and changes the components state according to the space state.
SpaceComponentsInitializeException thrown when one of the space components fails to initialize.
This structure contains all information about space configuration.
This exception is thrown in case of space configuration issues.
A generic interface for space configurers.
Aggregated connection details of all the currently discovered
SpaceInstances.An event that indicates that space was connected
An interface for objects that need to be notified about space connect/disconnect events
The SpaceContext class defines context info passed from the proxy to the space.
Retrieve space copy replica data, can have multiple instances of this class running concurrently
to retrieve the replica data
Contains all information about space copy operation.
A space data event annotation allowing to mark methods as delegates to be executed when an event
occurs.
A Space data event listener interface allowing for reception of events triggered by different
container types.
Control NotifyStatus status.
A
SpaceDataSource is used for reading data into the Space upon a request from the Space
or on Space initialization.Thrown when a
SpaceDataSource invocation causes a fails.An exception handler that delegates
SpaceDataSource execution
and calls the provided PersistencyExceptionHandler in
case of exceptions on query methods.A space data source that redirects the query operations to the given data source that can handle
the given type.
A deployment of a pure
Space processing unit (comes built in
under [GS ROOT]/deploy/templates/datagrid).Represents a document which can be stored and retrieved from the space.
An interface for mapping types to column families and for mapping space documents to column
family rows.
A
ColumnFamilyRowMapper implementation.Determines behavior when an object is converted to/from a
SpaceDocument.A
SpaceDocument based implementation of TopLevelTypeNode.A
VirtualEntry based implementation of CompoundTypeNode.This class connects to a GigaSpace cluster and extracts all objects types and generates wrapper classes.
A simple Jdbc
DataSource based on a space.Indicates that the annotated property will be used to store and retrieve dynamic properties.
Embedded space remote operations router.
why is entry removed.
why is entry removed.
XTN CONFLICT CHECK INDICATOR.
Extracts collection values for the provided collection index path.
A space value getter for getting a compound index value from a space entry.
A space value getter for getting a path from a space entry.
A space value getter for getting a space entry property value.
Provides services with which an
SpaceEvictionStrategy implementation can evict entries
from the space.Base class for space eviction strategy implementations.
Encapsulates configuration settings for space eviction strategy.
Excludes a property from the space when using
SpaceClass.includeProperties()
set to SpaceClass.IncludeProperties.IMPLICIT.
Defines a space fifo grouping index.
Defines a space fifo grouping property.
Retrieves the data from the IEntryHolder, used by the space filters.
A
FilterProvider factory that accepts a concrete
ISpaceFilter implementation in addition to all the
operation codes it will listen to.Deprecated.
Use
UrlSpaceConfigurer instead.The default implementation of the
ISpaceProxyProvider, uses space finder to locate a
proxyGets type descriptor by type name.
Represents a space health status
To designate a property as the entity's primary key.
Defines a space index.
Encapsulates information about an index of a space type.
Super class for space indexes
Defines multiple @SpaceIndex annotation for a single object property.
Factory which provides methods to create space indexes.
Determines a Space index type.
Used to specify that thread is the space initializer.
op' rejected-space in quiesce mode
A Space Instance is a single instance of a space running as a part of a
Space.An event listener allowing to listen for
SpaceInstance
additions.An event manager allowing to add and remove
SpaceInstanceAddedEventListeners.Connection details of the current
SpaceInstance.A simple lifecyle event listener that implements both the Space Instance added and Space Instance
removed event listeners.
Created by tamirs
on 11/14/16.
An event listener allowing to listen for
SpaceInstance
removals.An event manager allowing to add and remove
SpaceInstanceRemovedEventListeners.API for accessing Space runtime details - classes, templates, count, etc.
Returns
SpaceInstance level statistics.An event indicating that a Space Instance level statistics has changed.
An event listener called when statistics have changed.
An event manager allowing to add and remove
SpaceInstanceStatisticsChangedEventListener.Transaction details of the current
SpaceInstance.Exception class that is thrown when BlobStore crossed the designated memory threshold .
Indicates an interrupted exception that is thrown from the Space.
Configuration class for
SpaceIteratorEnum of
SpaceIterator implementation typesIndicates the property that holds the entity lease expiration.
A LeaseMap implementation using a space proxy to batch update leases.
A simple lifecyle event listener that implements both the Space added and Space removed event
listeners.
This Exception indicates that the space server process reached the predefined percentage usage
ratio.
Thrown when a metadata error is detected.
Thrown to indicate an invalid metadata on a user object.
This enum provides the current space mode.
An event indicating that a
SpaceInstance mode was changed (for
example, from primary to backup).An event listener allowing to register for
SpaceModeChangedEvents.An event manager allowing to add and remove
SpaceModeChangedEventListeners in order to
listen for SpaceModeChangedEvents.A Space mode based Spring context loader allows to load Spring application context if the Space
is in
PRIMARY mode.Base runtime exception class for all mongo related exceptions.
Parses space name
A convenience class for constants.
Coordinates execution of Concurrent and Critical space operations: - While a critical operation
is executing, any other incoming operation is blocked until the critical operation is finished.
This exception is thrown when update/take/change/clear operation is rejected as a result of
optimistic locking version conflict.
A Space partition mainly make sense with partitioned topologies and holds all the
SpaceInstances that form the partition.A Space partition split-brain alert triggered when two primaries are detected in the same
partition.
A Space partition split-brain alert configuration.
A Space partition split-brain alert configurer.
This type is intended for internal usage and should not be used directly.
Indicate if the instance is persist.
Provides methods to easier usage of built-in space predicates.
Defines a method annotation type with full meta-data of POJO fields.
Deprecated.
Encapsulates information about a property of a space type.
This type is intended for internal usage and should not be used directly.
Provides the functionality of clustered proxy.
This class is only used by the engine to verify that the proxy is alive.
A bean definition parser for xxxxx-modifier elements defined in a giga-space element.
Base class for space proxy operations modifiers.
An implementation of the
IReplicationRouter interface that uses a space proxy to locate a
replication connection proxy as its communication facadeSecured proxy manager implementation for a secured space using the new security model.
Manages EntryPacket construction and TypeDescription
Provides methods to create various space queries.
Encapsulates space query details.
Interface that defines how space recovers its data on start up
Registers type descriptors.
Base class for space remote events.
An extension for
ExecutionException holding both the remoteInvocation and the remoteResult remote
result.Deprecated.
since 8.0
Represents a remote invocation.
A remote invocation result holding either an exception (that occurred during the execution of
remote service) or the actual result data.
Exports a list of services (beans) as remote services with the Space as the transport layer.
An event listener allowing to listen for
Space removals.An event manager allowing to add and remove
SpaceRemovedEventListeners.A bean definition parser for
DefaultReplicationFilterProviderFactory.Encapsulates initialization of replication-related components.
Encapsulates space replication configuration and components.
A replication manager for a single
Space.Indicate which the member of the POJO is the routing index for partial.
Aggregated runtime details of all the currently discovered
SpaceInstances.
This class describes the content of the space,
on
com.j_spaces.core.admin.IRemoteJSpaceAdmin.getRuntimeInfo() call.Spaces holds all the currently discovered
Spaces.Deprecated.
Designate a property as a sequence number .
A Space service defined within a processing unit.
Port of Jetty's SessionData class adapted for space.
SpaceSettings is a set of properties passed from the space to its proxy
Created by Tamir on 3/6/16.
An aggregated statistics of all the currently discovered
SpaceInstances.An event indicating that a Space level statistics has changed.
An event listener called when statistics have changed.
An event manager allowing to add and remove
SpaceStatisticsChangedEventListener.Allows a bean's method to be invoked when space suspend type or space mode changes
The target invocation method may have a single parameter of type
SpaceStatusChangedEvent.Receives space suspend type and space mode change events and routs them to beans that use annotations to register as
listeners on those events using the
SpaceStatusChanged annotation
When the application starts beans that has one or more of the annotation SpaceStatusChanged
are registered in this bean, and when
events arrive they are routed to the registered beans' methods.Scans the bean's methods for the annotations
SpaceStatusChanged and registers them in the SpaceStatusChangedAnnotationRegistry.Interface receiving events when a space
SuspendType or SpaceMode changeThis exception is thrown in case when an attempt to perform any operations on stopped space.
An event indicating that a
SpaceInstance suspend type was changed (for example, from none to quiesced)An event listener allowing to register for
SpaceSuspendTypeChangedEvents.An event manager allowing to add and remove
SpaceSuspendTypeChangedEventListeners in order to
listen for SpaceSuspendTypeChangedEvents.A space synchronization endpoint used to intercept incoming replication events which were
originated from a space and do custom behavior when this events occur.
Thrown when a
SpaceSynchronizationEndpoint invocation fails.An exception handler that delegates
SpaceSynchronizationEndpoint
execution and calls the provided PersistencyExceptionHandler
in case of exceptions on synchronization methods.A
SpaceSynchronizationEndpoint that implements the synchronization methods.Indicates that the decorated class is an internal system class.
the basic interface for the execution service
Define cache rules that determine which entries will be available in RAM for faster access.
A general timeout operation exception
Aggregated transaction details of all the currently discovered
SpaceInstances.A transaction provider for space proxy.
The type of a space.
Encapsulates information about a space type.
A builder class for creating
SpaceTypeDescriptor instances.A
SpaceTypeDescriptor holder which serializes/deserializes its underlying SpaceTypeDescriptor In a version compatible manner.Provided utility methods to serialize/deserialize space type descriptors.
SpaceTypeReplicaDataProducer creates a replica of the space types.This exception is thrown in case when space is unavailable.
This exception is thrown in case when space is unavailable.
Thrown when a space is considered unhealthy
Deprecated.
Created by tamirt on 12/04/16.
Copyright (c) 2010 GigaSpaces Technologies Ltd.
Copyright (c) 2010 GigaSpaces Technologies Ltd.
Copyright (c) 2010 GigaSpaces Technologies Ltd.
A set of
IJSpace utilites.Indicates the property that holds the optimistic locking version.
A helper interface for converting XAP shapes to Spatial4j shapes.
SPeer is the LRMI over NIO Server Peer.
This class provides control for split-brain behavior.
Created by moran on 4/12/15.
Created by moran on 4/12/15.
A Spring security bridge over the GigaSpaces
SecurityManager interface.SqlConstants - defines constant values and keywords used in SqlParser
Deprecated.
since 9.5 - use
SpaceDataSource instead.Deprecated.
since 9.5 - use
SpaceDataSourceExceptionHandler instead.Deprecated.
since 9.5 - use
SpaceDataSourceSplitter instead.Defines a routine, to be use in SQLQuery context, that accepts arguments and performs an action
on the stored object, such as a complex calculation.
Created by Tamir on 3/6/16.
Defines the arguments to be passed to an SqlFunction, generated for sqlFunction invocations.
Created by Barak Bar Orion on 1/20/16.
Token literal values and constants.
Token Manager.
The SQLQuery class is used to query the space using the SQL syntax.
A bean definition builder for
SQLQueryFactoryBean.Interface for building an
SQLQuery object from space templateSQLQueryException is thrown when space operation with
For example illegal SQL syntax, semantic error.
SQLQuery fails.For example illegal SQL syntax, semantic error.
A helper factory beans for
SQLQuery so namespace based
configuration will be simpler.The parser manager is responsible for handling statements and calling the SqlParser for parsing
and creating Query objects.
A wrapper for the SQLQuery - gives it a facade of ITemplatePacket
SQLUtil defines utility methods for the SQL query classes
A factory class used to load SSL network filter
Simple implementation of Stack data structure.
A standalone container runnable allowing to start a Spring based application context based on the
provided parameters (
BeanLevelProperties, ClusterInfo, and a list of config locations).A
StandaloneProcessingUnitContainer provider.A
StandaloneProcessingUnitContainer provider.Standalone details for a Processing Unit instance which is un-managed by the Service Grid.
Provides a wrapper over the standard constructor reflection
A wrapper over the
Field class.Default implementation of IProperties based on Java Fields reflection.
Provides a wrapper over the standard getter method reflection
Provides a wrapper over the standard method reflection
Provides a wrapper over the standard parameter constructor reflection
Provides a wrapper over the standard method reflection
Default implementation of IProperties based on Java Methods reflection.
Provides a wrapper over the standard setter method reflection
The State entry represents the current service state.A static script that uses Spring
Resource and ResourceLoader to load a given
script (for example, from the classpath).A script that holds the actual script as a String.
Provides a space statistics API.
Representation of an operation statistics object.
Allows to postpone statistics listener registration.
Components implement this interface indicating that they can be monitored for statistics.
This exception is thrown in case when space statistics are not available.
A List of Objects that supports min,max,percentile operations if the Objects implement Comparable
and supports average operation if the Objects implement Number
A helper interface for extracting values from
StatisticsObjectList in a polymorphic wayA cyclic array holding statistics (double) values.
The base class from which other status-related entry classes may be derived.
Information pertaining to the severity of a Status object.
This class holds a
MarshalledObject that can be stored persistently.Thrown when an error occurred at the
IRedoLogFileStorageThrown when attemp to add data to a full storage
An iterator which support read only operation over a
IRedoLogFileStorageA single segment inside a
ByteBufferRedoLogFileStorageDeprecated.
Since 9.0.0 - This class is intended for internal usage only; Use
StorageType instead.TODO add Javadoc
StoredListFactory returns a
IStoredList implementation, according to the Java version the
sources were compiled.Iterates the data in the StoredList
A marker interface indicating that a log entry matcher can be used for streaming (i.e.
Serializer for String.
Miscellaneous string utility methods.
Returns the position of the character where the first occurrence of the substring appears in a string.
A global cache for dynamic smart stubs
A unique identifier for an exported stub
Returns a substring of a given string
Returns a substring of a given string
A default implementation of a reducer that sums all types
T into a result
R.A sum distrubuted task that accepts a
Task to delegate the
actual execution to and implements the SumTask.reduce(java.util.List) operation.Sums values of paths of matching entries, when no non null values are applied zero is returned instead of null
returns the same type as the path.
Sums scalar value, when no non null values are applied zero is returned instead of null
returns the same type as the value.
Mark a class for code change
Created by tamirs
on 11/8/16.
An exception where the stack trace is suppressed.
Represents current suspend state of the space.
This enum provides the current space suspend type.
Internal listener interface for receiving events when a space change its suspendType
A replication packet stream serializer that serializes packets that implements
ISwapExternalizableA synchronization endpoint interceptor used to intercept incoming replication events and do
custom behavior when this events occur.
Describe a synchronization source details
SynchronizationEndpointInterceptor SpaceSynchronizationEndpointUsed when the source replication backlog is missing packets that are in the target backlog, and
it requests from the target to complete its missing packets.
SynchronizeReplicaDataProducer copies all the entries in space and all the notifications
This policy checks whether a group of replication members defined to operate in synchronous mode
are currently operating in synchrnous mode
IReplicationTargetGroup that supports only multiple active source that is replicating to
it (i.e active active sync replication)This class contains all configuration information about Synchronize Replication.
IReplicationTargetGroup that supports only one active source that is replicating to it
(i.e primary backup topology, supports any number of backup)Returns date and time
Defines an Authority for managing of users and roles.
Defines monitoring privileges
Provides bootstrapping support for the GigaSpaces Service Grid.
An RMI Loader Handler cleaner that cleans weak referneces holding exported objects.
Provides system configuration support.
Initialize RMI Registry and JMX Platform MBeanServer
This Class includes system properties used by the product.
A bean definition builder for
SystemRequirement.A static system time wrapper, which will call the underlying
ITimeProvider
implementation.Overrided
FixedLeasePeriodPolicy.currentTime() by using SystemTime#timeMills()Encapsulates information on a table's identity.
Encapsulates information on a table.
Encapsulates details for filtering tables when querying the database.
Thrown when takeByIds operation fails.
Thrown when takeByIds operation fails.
Holds a TakeByIdsException result.
Determines the result type of a take by id operation result.
Holds iterable results of the
takeByIds operation.User: Barak Bar Orion Date: 8/7/14
A
TakeModifiers factory bean.Provides modifiers to customize the behavior of take operations.
The
TakeModifiers class provides static methods and constants to decode Take
type modifiers.Context for takeMultiple operation - accumulates operation results and exceptions
Thrown when a space takeMultiple operation fails.
Thrown when a takeMultiple space operations fails.
A task executed on a space node (processing unit) that returns a result and may throw an
exception.
An adapter that delegates the execution of a
SpaceDataEventListener
to Spring TaskExecutor implementation (usually to be executed in a different thread).An extended interface to
ExecutorService.Task can implement this method to be injected with the Space
they are executed on.A task manager manages a single queue of tasks, and some number of worker threads.
The interface that tasks must implement
Controls the
Task routing.A Template contains the fields of a ServiceTemplate packaged up for transmission between
client-side proxies and the registrar server.
a time based service that is responsible of sending back an empty response back to the client
when the template timeout is reached and no answer is found.
This class represents a template in a J-Space.
Factory to create TemplateHolder instances.
Implements IGSTemplate
Used to hold a template info.
Deprecated.
Since 8.0 - Use
SQLQuery instead.This class represents a packet of information transmitted between a J-Space client and its
J-Space server .
Created by IntelliJ IDEA.
handles data manipulation of space extended index
Holds all the counters for specific type of notify templates
Created by IntelliJ IDEA.
contanis information regarding terminatiing transactions which have fifo entries - the seq number
of last terminating xtn and info regarding terminating entries
Base class for hashtables that use open addressing to resolve collisions.
An implementation of the Map interface which uses an open addressed hash table to store its
contents.
A utility for generating thread dumps.
ThreadLocal based resource pool.
A resource pool to handle a pool of threads
Permission to use internal thread pools (see GetThreadPoolAction).
ThresholdValues provides attributes for thresholds which can be applied to a Watch
Deprecated.
Use
Counter with monitoring system rate queriesCalculates the throughput (requests per second)by taking total request count and dividing by
time
Fluent API for creating a new
ThroughputTimeWindowStatisticsConfig objectVarious constants useful in processing exceptions
base for an operation to execute as part of a bulk on tiered storage
result an operation executed as part of a bulk on tiered storage
Thrown when a tiered storage metadata error is detected.
Thrown when a tiered storage metadata error is detected.
abstract class- infra' for time-based eviction strategy
Various constants useful in calculating times.
A handler for rejected tasks that inserts the specified element into this queue, waiting if
necessary up to the specified wait time for space to become available.
Exception thrown when a transaction timeout has expired.
A timeout mechanism on top of an executor service.
A rolling policy based on time.
Helper class that converts time interval property to milliseconds long value, according to the
given time unit format ms - milliseconds s - seconds m - minutes h - hours
Aggregates samples from a certain time window using different functions defined by
TimeWindowStatisticsConfig that is stored in ProcessingUnitStatisticsIdsMarks configurations that aggregate statistics from time samples.
A resizable, array-backed list of int primitives.
Interface for functions that accept and return one int primitive.
An open addressed hashing implementation for int primitives.
Interface to support pluggable hashing strategies in maps and sets.
An open addressed set implementation for int primitives.
Iterator for int collections.
An open addressed Map implementation for int keys and Object values.
Iterator for maps of type int and Object.
Interface for procedures that take two parameters of type int and Object.
Interface for procedures with one int parameter.
Interface for functions that accept and return one long primitive.
An open addressed hashing implementation for long primitives.
Interface to support pluggable hashing strategies in maps and sets.
An open addressed Map implementation for long keys and Object values.
Iterator for maps of type long and Object.
Interface for procedures that take two parameters of type long and Object.
Interface for procedures with one long parameter.
Created by Barak Bar Orion on 11/26/15.
Interface for functions that accept and return one Object reference.
An open addressed hashing implementation for Object types.
Interface to support pluggable hashing strategies in maps and sets.
An open addressed Map implementation for Object keys and int values.
Iterator for maps of type Object and int.
Interface for procedures that take two parameters of type Object and int.
An open addressed Map implementation for Object keys and long values.
Iterator for maps of type Object and long.
Interface for procedures that take two parameters of type Object and long.
Interface for procedures that take two Object parameters.
Interface for procedures with one Object parameter.
An open addressed Map implementation for Object keys and short values.
Iterator for maps of type Object and short.
Interface for procedures that take two parameters of type Object and short.
Built in conversion sql function to convert Date or Number types to chars.
Emulates Oracle's TO_CHAR function.
Describes the input token stream.
Token Manager Error.
Built in conversion sql function to convert string type to Number.
A
CompoundTypeNode denoting a top level element.The base class for hashtables of primitive values.
A resource that can be traced back to it's allocation point.
Interface for classes representing transactions returned by
TransactionManager
servers for use with transaction participants that implement the default transaction semantics.Class that holds return values from create methods.
Replication packet representing transaction abort
Extends the future listener, resulting in calling the
TransactionalAsyncFutureListener.onTransactionalResult(com.gigaspaces.async.AsyncResult, org.springframework.transaction.TransactionStatus) after the AsyncFutureListener.onResult(com.gigaspaces.async.AsyncResult).Replication packet representing transaction commit
A TransactionConflictException is thrown when a template operation is performed on an entry which
is locked under a conflicting transaction.
Constants common to transaction managers and participants.
A data of a transaction that is synchronized to a synchronization endpoint
An exception occurred during a space operation that has to do with transactional semantics.
Base class for exceptions thrown during a transaction.
Factory methods for creating top-level transactions.
Handle engine transactions
Transaction information.
The Transactions types.
Allows to configure transactions to be renewed automatically when using
AbstractJiniTransactionManager and its different sub-classes.The interface used for managers of the two-phase commit protocol for top-level transactions.
Class that holds return values from create methods.
Holds transaction manager configuration properties.
A transaction manager factory used for creating a local/distributed/lookup transaction manager
provider.
A transaction managers Map which maps a SpaceProxy instance to its equivalent transaction
manager.
A TransactionNotActiveException is thrown when some transaction related operation is performed
but the transaction is not active.
Replication packet representing a one phase commit transaction
The interface used for participants of the two-phase commit protocol.
Deprecated.
since 9.0.1 - see
TransactionParticipantMetaData.Contains ServerTransaction meta data for distributed transactions that have more than 1
participant.
Represents a transaction meta data for a specific transaction participant.
Replication packet representing transaction prepare
A transaction provider is used to support declarative transactions.
Deprecated.
since 9.0.0 - see
TransactionOnePhaseReplicationPacketDataRepresents a transaction unique id constructed from the transaction manager which created the
transaction
Uuid and the transaction id.An implementation of a non-persistent
Log.Convenience class intended for use with the
ServiceStarter framework
to start a transient (non-activatable, non-persistent) implementation of Mahalo.A transport holds information on the communication layer that is used by a grid component.
A grid component implements this interface if it can provide information regarding the transport
it is using.
Details (non changeable information) of a single transport.
Provide low level monitoring capabilities of the transport layer
The Transport Protocol utility class.
This class provides runtime monitoring of transport protocol infrastructure.
This interface provides runtime monitoring of transport communication protocol.
Transports hold all the different
Transports that are
currently siscovered.An aggregated view of all
TransportDetails.An aggregated view of
TransportStatistics.An event indicating that an aggregated transports level statistics has changed.
An event listener called when statistics have changed.
An event manager allowing to add and remove
TransportsStatisticsChangedEventListener.A transport level statistics.
An event indicating that a transport level statistics has changed.
An event listener called when statistics have changed.
An event manager allowing to add and remove
TransportStatisticsChangedEventListener.An annotation marking a method as one that is responsible to return a
TriggerOperationHandler to be used with a polling
container.If using a replicated space controls if the listener that are replicated to cluster members will
raise notifications.
Allows to perform a trigger receive operation which control if the active receive operation will
be performed in a polling event container.
A space predicate that always returns true.
Defines an interface for checking that an object (that is not yet known to be trusted) is
equivalent in trust, content, and function to a known trusted object.
Created by Barak Bar Orion 2/2/15.
Defines the interface for trust verifiers used by
Security.verifyObjectTrust, allowing the objects that are trusted to be extended.Defines the context for trust verification used by
TrustVerifier instances and Security.verifyObjectTrust.A resizable, array-backed list of short primitives.
Interface for functions that accept and return one short primitive.
An open addressed hashing implementation for short primitives.
Interface to support pluggable hashing strategies in maps and sets.
An open addressed Map implementation for short keys and long values.
Iterator for maps of type short and long.
Interface for procedures that take two parameters of type short and long.
An open addressed Map implementation for short keys and Object values.
Iterator for maps of type short and Object.
Interface for procedures that take two parameters of type short and Object.
Interface for procedures with one short parameter.
Names for constants common to transaction managers and participants.
Encapsulates the interface of an implementation of a
TransactionManager.An implementation of the Jini(TM) Transaction Specification.
A
TxnMgrProxy is a proxy for the transaction manager service.A Java field or method type.
modes of updating an index.
A
TypeNode implementations for representing a typed column.An extension of a script to be executed which is also aware of the static parameter types.
An interface to describe a property's metadata that is part of a type hierarcy.
Context used during type introspection and during read/write operations
This exception is used in cases when a client tries to perform an write/update operation on a
type that is not registered in space
The path to a type argument, wildcard bound, array element type, or static inner type within an
enclosing type.
Represents path and associated with it
QueryExtensionPathInfo.Represents namespace and associated with it
TypeQueryExtensionA reference to a type appearing in a class, field or method declaration, or on an instruction.
A
UIDGen represents an identifier that is unique over time with respect to the host
it is generated on, or one of 216 "well-known" identifiers.Used for querying the space by a uid / uids.
Scans the entries according to the supplied uids
Represents a set of uids to match against the candidates
Permission that is specially intepreted by
PolicyFileProvider as shorthand for a GrantPermission covering all permissions authorized to a given protection
domain.A common basic implementation for unary composite space predicate implementations.
A GigaSpace based data access exception that could not be translated to one of Spring
DataAccessException subclasses or one of our own subclasses.UnderTxnLockedObject holds the details on Objects that are locked by a specific transaction.
Iterator for entries locked under a Xtn.
Iterator for templates locked under Xtn.
A fix that states that the error could not be fixed by the source
Interface implemented by classes which perform the client (discovering) side of unicast
discovery.
Interface implemented by classes which handle the server (lookup service) side of unicast
discovery.
Class representing the values obtained as the result of unicast discovery.
Represents a constraint on the timeout set on sockets used for unicast discovery.
A replication router that has both SpaceProxyReplicationRouter and LusReplicationRouter and
delegate the request according to the lookup name
Represents query that is translated to several template packets The result is the union of all
results
Violation of unique constraint exception
A consumption error result that is caused when trying to extend entry lease and that lease do no
exists in the space.
An exception thrown when the recipient of a RemoteEvent does not recognize the combination of the
event identifier and the event source as something in which it is interested.
A fix that is returned as a fix of two errors
UnknownEntryLeaseConsumeResult, UnknownNotifyTemplateLeaseConsumeResult.An exception used to indicate that a lease is not known to the grantor of the lease.
A consumption error result that is caused when trying to extend notify template lease and that
lease do no exists in the space.
Exception thrown when a transaction is not recognized as a valid or known transaction.
A consume error result caused due to
UnknownTypeException thrown during consumptionAn UnknownTypeException is thrown when a space receives an entry/template of type that is not in
his type table, and the EntryPacket does not contain full type information.
An UnknownTypeException is thrown when a space receives an entry/template of type that is not in
his type table, and the EntryPacket does not contain full type information.
thrown whenever an IOException is thrown during the unmarshalling process of request/response
from the wire.
A task that unregisters (stops and disposes it) a dynamically added event container in a
distributed manner.
Represents a change operation which correlate with a
ChangeSet.unset(String) invocation.Typically used as the nested exception of a
ConnectIOException if the
constraints for a remote call cannot be satisfied.An implementation of a function that is not supported by
the backend.
A trust verifier context element that provides a security context to use to restrict privileges
when invoking methods on untrusted objects.
Thrown when one tries to get an
Entry from a service, but the entry is unusable (due
to serialization or other errors).Thrown when one tries to get an Entry from a service, but the entry is unusable (due to
serialization or other errors).
Represents an SQL UPDATE query column.
The Modifier class provides
static methods and constants to decode update types
modifiers.Context for update multiple operations.
An internal class for combining the matched and re-matched notifications context.
Thrown when a space update operation timeouts after waiting for a transactional proper matching
entry.
a bus packet that will be processed by the processor and resubmit an update/write request to the
engine in a callback mode.
a place holder for or the params used in update or write.
Context for updateOrW multiple operations.
Built in string sql function to change all characters of a given string to uppercase.
A
FileService responsible for reading from a URL.A bean definition builder for
UrlSpaceFactoryBean.A simple configurer helper to create
IJSpace instances.A space factory bean that creates a space (
IJSpace) based on a url.Models user details retrieved by a
UserManager.Thrown if an
UserManager implementation encounters a non unique user.Thrown if an
UserManager implementation cannot access a user record.User details to store user information accessed by the
UserManager and SecurityManager.Deprecated.
Use
CredentialsProvider instead.The main interface for managing user details.
Thrown if an
UserManager implementation cannot locate a user by its username.When marks a remote method, any stub that is passed as one of its argument will work with the
stub cache mechanism
Created by kobi on 3/26/14.
A 128-bit value to serve as a universally unique identifier.
Provides static methods for creating
Uuid instances.Class for generating
Uuid instances.Helper class to deal with validators that hector doesn't take into consideration
This is a parent class for the ColumnNode and the LiteralNodes.
A
ProxyPreparer for verifying that proxies are trusted, dynamically granting
permissions to trusted proxies, and optionally setting the client constraints on trusted
proxies.Interface that holds the version string for the current release
Holds the an Entry version for optimistic locking.
Helper class for optimizing scanning entry data.
A virtual machine is a JVM that runs grid components.
An event listener to be notified when a virtual machine is added.
An event manager allowing to remove and add
VirtualMachineAddedEventListeners.A grid component implements this interface allowing to get the
VirtualMachine it is
running within.Details (non changeable information) of a single virtual machine.
A simple lifecyle event listener that implements both the virtual machine added and virtual
machine removed event listeners.
An event listener to be notified when a virtual machine is removed.
An event manager allowing to remove and add
VirtualMachineRemovedEventListeners.Virtual Machines hold all the different
VirtualMachines that are currently discovered.An aggregated details of all the currently discovered virtual machines.
An aggregated statistics view of all the different virtual machines currently discovered.
An event indicating that an aggregated virtual machines level statistics has changed.
An event listener called when statistics have changed.
An event manager allowing to add and remove
VirtualMachinesStatisticsChangedEventListener.Statistics on a single virtual machine level.
An event indicating that a virtual machine level statistics has changed.
An event listener called when statistics have changed.
An event manager allowing to add and remove
VirtualMachineStatisticsChangedEventListener.A listener that can be used to set on several execution and then wait for all the results (using
WaitForAllListener.waitForResult().A listener that can be used to set on several execution and then wait for any of the results
(using
WaitForAnyListener.waitForResult().A Queue of timed tasks.
Description of a future thread.
A ticket that can be used for cancelling a future task.
This interface is used to fetch WatchDataSource instances that have been created and registered
The WatchDataSource interface defines the semantics for a Watch to store Calculable records
Watchdog for network failure detection and handling idle threads.
Groups indices
Object watched by the Watchdog - WatchedObject is used to watch NIO connections
Used in order to weakly hold batch listeners by the Notify delegator.
Used in order to weakly hold listeners by the
LookupDiscoveryManager.This classes uses
WeakReference so that contained objects can be collected
by the GC.Identity-based weak hash map.
A weak reference to a key in a table.
Used in order to weakly hold listeners by the LeaseRenewalManager.
Used in order to weakly hold listeners by the Notify delegator.
This class is designed to allow weakly held keys to weakly held objects.
Handler for clients that need to know when a key is removed from the table because it has
been collected.
Statistics monitor information for JEE servlet requests.
Webster is a HTTP server which can serve code from multiple codebases.
Not an actual file.
A webster resource which holds a url to an actual content stored on GSM webster.
Returns week according to timestamp
This class provides Windows Registry services.
Deprecated.
use
EventDriven containers insteadDeprecated.
Deprecated.
This class abstracts a group of cooperating objects that together offer asynchronous message
delivery to consumers.
Created by Barak Bar Orion 12/30/14.
User: Barak Bar Orion Date: 8/7/14
A
WriteModifiers factory bean.Provides modifiers to customize the behavior of write operations.
Thrown when writeMultiple operation fails.
Thrown when writeMultiple operation fails.
Deprecated.
since 7.1.
Deprecated.
since 7.1.
A Writer is capable of writing Request Packets and Reply Packets to a Socket Channel.
selector thread that deals with server side writes that could not complete in one go.
Thrown when the message digest for data retrieved from an HTTPMD URL does not match the value
specified in the URL.
An instance of this class represents a XAResource implementation
Creates new transaction for XA transactions.
A simple XML alert configuration parser.
Copyright (c) 2010 GigaSpaces Technologies Ltd.
Provides XML services.
Experimental Nio (xnio) server to execute operations more efficently than the lrmi execution.
An implementation of a logical binary XOR condition: This predicate returns true if and only if
left or right operands return true, but not both.
Class holds the commonly used XPath constants for the container and space overrides.
Utility Class that provides methods for DOM <--> XML <--> XSL conversions/transformations.
Stores gateway information relevant for transaction commit from gateway.
A Constants class for status of a transaction in the transactions table.
Abstraction for Yaml parsing
Factory for obtaining a yaml parser.
Yaml utilities
Returns year according to timestamp
Adapter for compressing properties using standard zip compression and storing them in space in binary form.
An event listener to be notified when a zone is added.
An event manager allowing to remove and add
ZoneAddedEventListeners.A simple life-cycle event listener that implements both the zone added and zone removed event
listeners.
An event listener to be notified when a zone is removed.
An event manager allowing to remove and add
ZoneRemovedEventListeners.A bean definition builder for
ZoneRequirement.Created by tamirs
on 5/9/17.