Constructor and Description |
---|
LocalViewReplicationEntryEventHandler(SpaceEngine engine) |
LocalViewReplicationEntryLeaseEventHandler(SpaceEngine engine) |
LocalViewReplicationMetadataEventHandler(SpaceTypeManager typeManager,
SpaceEngine spaceEngine) |
LocalViewReplicationTransactionEventHandler(SpaceEngine engine,
AbstractReplicationEntryEventHandler entryHandler) |
Modifier and Type | Method and Description |
---|---|
SpaceEngine |
IDirectPersistencySyncHandler.getSpaceEngine() |
SpaceEngine |
DirectPersistencySyncHandler.getSpaceEngine() |
Constructor and Description |
---|
DirectPersistencySyncHandler(SpaceEngine engine) |
Modifier and Type | Field and Description |
---|---|
protected SpaceEngine |
SpaceReplicationEntryLeaseEventHandler._engine |
protected SpaceEngine |
AbstractSpaceReplicationEntryEventHandler._engine |
Constructor and Description |
---|
AbstractSpaceReplicationEntryEventHandler(SpaceEngine engine,
ReplicationInExceptionHandler exceptionHandler) |
ActiveActiveSpaceReplicationEntryEventHandler(SpaceEngine engine,
boolean isCentralAndExternalDB) |
BlobstorePrimaryBackupSpaceReplicationEntryEventHandler(SpaceEngine engine,
boolean isCentralAndExternalDB) |
PrimaryBackupSpaceReplicationEntryEventHandler(SpaceEngine engine,
boolean isCentralAndExternalDB) |
PrimaryBackupSpaceReplicationEvictionProtectionEntryEventHandler(SpaceEngine engine,
boolean isCentralAndExternalDB) |
SpaceReplicationEntryLeaseEventHandler(SpaceEngine engine) |
SpaceReplicationMetadataEventHandler(SpaceTypeManager typeManager,
SpaceEngine spaceEngine) |
SpaceReplicationTemplateEventHandler(SpaceEngine engine) |
SpaceReplicationTransactionEventHandler(SpaceEngine spaceEngine,
AbstractReplicationEntryEventHandler entryHandler) |
Modifier and Type | Method and Description |
---|---|
abstract AbstractDataConsumeFix |
AbstractDataConsumeErrorResult.createFix(SpaceEngine spaceEngine,
ReplicationPacketDataProducer producer,
IExecutableReplicationPacketData errorData) |
Constructor and Description |
---|
BlobstoreReplicationPacketDataProducer(SpaceEngine spaceEngine,
boolean replicateToTargetWithExternalDatasource,
boolean replicateFullTake,
ReplicationPacketDataMediator packetDataMediator) |
ReplicationPacketDataProducer(SpaceEngine spaceEngine,
boolean replicateToTargetWithExternalDatasource,
boolean replicateFullTake,
ReplicationPacketDataMediator packetDataMediator) |
SpaceEngineFixFacade(SpaceEngine spaceEngine) |
Modifier and Type | Field and Description |
---|---|
protected SpaceEngine |
AbstractMultiSpaceReplicaDataProducer._engine |
protected SpaceEngine |
EntryReplicaProducer._engine
keeps already recovered UIDs
|
Modifier and Type | Method and Description |
---|---|
SpaceEngine |
EntryReplicaProducer.getEngine() |
SpaceEngine |
SpaceReplicaDataProducerBuilder.getSpaceEngine() |
Modifier and Type | Method and Description |
---|---|
static IStorageAdapter |
EDSAdapter.create(SpaceEngine spaceEngine,
JSpaceAttributes spaceAttributes) |
Constructor and Description |
---|
EDSAdapterSynchronizationEndpoint(SpaceEngine spaceEngine,
DataStorage<Object> dataStorage) |
Modifier and Type | Method and Description |
---|---|
SpaceEngine |
MultipleIdsContext.getEngine() |
SpaceEngine |
SpaceImpl.getEngine() |
Constructor and Description |
---|
FifoGroupsHandler(SpaceEngine spaceEngine) |
MultipleIdsContext(ITemplateHolder concentratingTemplate,
int numToAnswer,
int operationModifiers,
long timeout,
SpaceEngine engine,
XtnEntry xtnEntry) |
SpaceEngineReplicaConsumerFacade(SpaceEngine spaceEngine) |
SpaceEngineReplicaDirectPersistencySyncConsumerFacade(SpaceEngine spaceEngine) |
TemplateScanner(SpaceTypeManager typeManager,
CacheManager cacheManager,
SpaceDataEventManager dataEventManager,
SpaceEngine engine) |
UpdateMultipleContext(ITemplateHolder concentratingTemplate,
IEntryPacket[] entries,
long[] leases,
int operationModifiers,
long timeout,
SpaceEngine engine,
XtnEntry xtnEntry) |
UpdateOrWriteMultipleContext(ITemplateHolder concentratingTemplate,
IEntryPacket[] entries,
long[] leases,
int operationModifiers,
long timeout,
SpaceEngine engine,
XtnEntry xtnEntry) |
Modifier and Type | Method and Description |
---|---|
static MVCCEntryMetaData |
MVCCUtils.getMVCCDirtyEntryUnderTransaction(SpaceEngine engine,
String typeName,
Object id,
long transactionId) |
static ArrayList<MVCCEntryMetaData> |
MVCCUtils.getMVCCEntryMetaData(SpaceEngine engine,
String typeName,
Object id) |
Constructor and Description |
---|
MVCCSpaceEngineHandler(SpaceEngine spaceEngine) |
Constructor and Description |
---|
ReplicationNodeStateListener(SpaceEngine spaceEngine) |
SpaceReplicationChannelDataFilterBuilder(SpaceEngine spaceEngine) |
SpaceReplicationInitializer(SpaceConfigReader configReader,
SpaceImpl spaceImpl,
SpaceTypeManager typeManager,
IStorageAdapter storageAdapter,
SpaceEngine spaceEngine) |
SpaceReplicationLifeCycleBuilder(SpaceEngine spaceEngine) |
Modifier and Type | Method and Description |
---|---|
static Map<Object,EntryTieredMetaData> |
TieredStorageUtils.getEntriesTieredMetaDataByIds(SpaceEngine space,
String typeName,
Object[] ids) |
void |
TieredStorageManagerImpl.initializeInternalRDBMS(SpaceEngine engine) |
void |
TieredStorageManager.initializeInternalRDBMS(SpaceEngine engine) |
void |
InternalRDBMS.initialLoad(Context context,
SpaceEngine engine,
InitialLoadInfo initialLoadInfo) |
Constructor and Description |
---|
TieredStorageSA(InternalRDBMS internalRDBMS,
SpaceEngine engine) |
Modifier and Type | Method and Description |
---|---|
static ITemplateHolder |
TemplateHolderFactory.createEmptyTemplateHolder(SpaceEngine engine,
String uid,
long expirationTime,
boolean isFifo) |
boolean |
TemplateHolder.isActiveRead(SpaceEngine engine,
Context context) |
boolean |
ITemplateHolder.isActiveRead(SpaceEngine engine,
Context context) |
boolean |
TemplateHolder.isHistoricalRead(SpaceEngine engine,
Context context) |
boolean |
ITemplateHolder.isHistoricalRead(SpaceEngine engine,
Context context) |
Constructor and Description |
---|
SynchronizationStorageAdapter(SpaceEngine engine,
SpaceDataSource spaceDataSource,
SpaceSynchronizationEndpoint synchronizationEndpointInterceptor) |
Constructor and Description |
---|
NotifyAcknowledgeFilter(SpaceEngine engine) |
Constructor and Description |
---|
LeaseManager(SpaceEngine engine,
String spaceName,
Processor coreProcessor) |
Modifier and Type | Method and Description |
---|---|
SpaceEngine |
CacheManager.getEngine() |
Modifier and Type | Method and Description |
---|---|
static IEntryCacheInfo |
EntryCacheInfoFactory.createEntryCacheInfo(IEntryHolder entryHolder,
int backRefsSize,
boolean pin,
SpaceEngine engine) |
static IEntryCacheInfo |
EntryCacheInfoFactory.createEntryCacheInfo(IEntryHolder entryHolder,
SpaceEngine engine) |
Constructor and Description |
---|
CacheManager(SpaceConfigReader configReader,
ClusterPolicy clusterPolicy,
SpaceTypeManager typeManager,
IReplicationNode replicationNode,
IStorageAdapter sa,
SpaceEngine engine,
Properties customProperties) |
Constructor and Description |
---|
BlobStoreInternalCacheFilter(SpaceEngine spaceEngine,
List<SQLQuery> sqlQueries) |
BlobStoreReplicaConsumeHelper(SpaceEngine engine) |
BlobStoreReplicationBulkConsumeHelper(SpaceEngine engine) |
Modifier and Type | Method and Description |
---|---|
static boolean |
BlobStoreOperationOptimizations.isConsiderOptimizedForBlobstore(SpaceEngine spaceEngine,
Context context,
ITemplateHolder template,
IEntryCacheInfo pEntry) |
Constructor and Description |
---|
BlobStoreInitialLoadDataIterator(SpaceEngine engine) |
BlobStoreMetaDataIterator(SpaceEngine engine) |
BlobStoreStorageAdapter(SpaceEngine engine,
boolean persistentBlobStore) |
BlobStoreStorageAdapter(SpaceEngine engine,
boolean persistentBlobStore,
IStorageAdapter recoverySA) |
Modifier and Type | Method and Description |
---|---|
protected FifoWorkerThread |
DefaultFifoBackgroundDispatcher.createFifoWorkerThread(int num,
boolean isNotify,
CacheManager cacheManager,
SpaceEngine engine) |
protected abstract FifoWorkerThread |
FifoBackgroundDispatcher.createFifoWorkerThread(int num,
boolean isNotify,
CacheManager cacheManager,
SpaceEngine engine) |
Constructor and Description |
---|
DefaultFifoBackgroundDispatcher(int numNotifyFifoThreads,
int numNonNotifyFifoThreads,
CacheManager cacheManager,
SpaceEngine engine) |
FifoBackgroundDispatcher(int numNotifyFifoThreads,
int numNonNotifyFifoThreads,
CacheManager cacheManager,
SpaceEngine engine) |
FifoWorkerThread(int num,
boolean isNotify,
String workerType,
CacheManager cacheManager,
SpaceEngine engine) |
Modifier and Type | Method and Description |
---|---|
void |
FilterManager.init(SpaceEngine engine)
init the filter manager.
|
Constructor and Description |
---|
FilterManager(SpaceTypeManager typeManager,
IJSpace space,
SpaceEngine engine) |
Constructor and Description |
---|
Processor(SpaceEngine engine) |
Modifier and Type | Method and Description |
---|---|
boolean |
Prepared2PCXtnInfo.extendIfPossible(SpaceEngine engine) |
Constructor and Description |
---|
TransactionHandler(SpaceConfigReader configReader,
SpaceEngine engine) |
Copyright © GigaSpaces.