Modifier and Type | Method and Description |
---|---|
SpaceContext |
SpaceOperationRequest.getSpaceContext() |
Modifier and Type | Method and Description |
---|---|
void |
SpaceOperationRequest.setSpaceContext(SpaceContext spaceContext) |
Modifier and Type | Method and Description |
---|---|
SpaceContext |
SpaceProxyRouter.getDefaultSpaceContext() |
Constructor and Description |
---|
NotificationDynamicSourceGroupMemberLifeCycle(SpaceImpl space,
FilterManager filterManager,
SpaceContext spaceContext) |
Modifier and Type | Method and Description |
---|---|
SpaceContext |
SpaceCopyReplicaParameters.getSpaceContext() |
Modifier and Type | Method and Description |
---|---|
void |
SpaceCopyReplicaParameters.setSpaceContext(SpaceContext spaceContext) |
Modifier and Type | Method and Description |
---|---|
SpaceContext |
WaitForDataDrainRequest.getSpaceContext() |
Modifier and Type | Method and Description |
---|---|
void |
WaitForDataDrainRequest.setSpaceContext(SpaceContext spaceContext) |
Modifier and Type | Method and Description |
---|---|
void |
LRMISpaceImpl.demote(long maxSuspendTime,
TimeUnit unit,
SpaceContext sc) |
void |
LRMISpaceImpl.dropClass(String className,
SpaceContext sc) |
void |
LRMISpaceImpl.snapshot(ITemplatePacket e,
SpaceContext sc) |
SpaceCopyStatus |
LRMISpaceImpl.spaceCopy(IRemoteSpace remoteProxy,
String remoteSpaceUrl,
String remoteSpaceName,
ITemplatePacket template,
boolean includeNotifyTemplates,
int chunkSize,
SpaceContext spaceContext,
SpaceContext remoteSpaceContext) |
SpaceCopyStatus |
LRMISpaceImpl.spaceCopy(String remoteUrl,
ITemplatePacket template,
boolean includeNotifyTemplates,
int chunkSize,
SpaceContext sc) |
Modifier and Type | Method and Description |
---|---|
SpaceContext |
RemoteOperationRequest.getSpaceContext() |
Modifier and Type | Method and Description |
---|---|
AnswerHolder |
SpaceEngine.aggregate(ITemplatePacket queryPacket,
List<SpaceEntriesAggregator> aggregators,
int readModifiers,
SpaceContext sc) |
void |
SpaceImpl.assertAuthorizedForPrivilege(Privilege privilege,
SpaceContext spaceContext) |
void |
SpaceImpl.assertAuthorizedForType(String typeName,
SpaceAuthority.SpacePrivilege privilege,
SpaceContext spaceContext) |
Object |
SpaceImpl.asyncRead(ITemplatePacket template,
Transaction txn,
long timeout,
boolean ifExists,
boolean take,
IJSpaceProxyListener listener,
SpaceContext sc,
boolean returnOnlyUid,
int modifiers,
IFuture result) |
protected void |
SpaceEngine.attachFromGatewayStateToTransactionIfNeeded(SpaceContext sc,
XtnEntry txnEntry) |
void |
SpaceImpl.beforeOperation(boolean isCheckForStandBy,
boolean checkQuiesceMode,
SpaceContext sc) |
void |
SpaceImpl.beforeTypeOperation(boolean isCheckForStandBy,
SpaceContext sc,
Privilege privilege,
String className) |
void |
SpaceImpl.beginPacketOperation(boolean isCheckForStandBy,
SpaceContext sc,
Privilege privilege,
ITransportPacket packet) |
ExtendedAnswerHolder |
SpaceEngine.change(ITemplatePacket template,
Transaction txn,
long lease,
long timeout,
SpaceContext sc,
boolean fromReplication,
boolean origin,
Collection<SpaceEntryMutator> mutators,
int operationModifiers,
boolean returnOnlyUid)
perform an update in place using mutators
|
void |
SpaceImpl.checkPacketAccessPrivileges(SpaceContext sc,
Privilege privilege,
ITransportPacket packet)
Check if a user's has sufficient privileges to perform this operation.
|
Pair<Integer,SingleExplainPlan> |
SpaceImpl.clear(ITemplatePacket template,
Transaction txn,
int modifiers,
SpaceContext sc) |
Pair<Integer,SingleExplainPlan> |
SpaceEngine.clear(ITemplatePacket template,
Transaction txn,
SpaceContext sc,
int operationModifiers) |
Pair<Integer,SingleExplainPlan> |
SpaceEngine.count(ITemplatePacket template,
Transaction txn,
SpaceContext sc,
int operationModifiers) |
Pair<Integer,SingleExplainPlan> |
SpaceImpl.count(ITemplatePacket template,
Transaction txn,
SpaceContext sc,
int modifiers) |
void |
IRemoteSpace.demote(long maxSuspendTime,
TimeUnit unit,
SpaceContext sc)
Demote leadership and become a backup Space, in the specified operation timeout.
|
void |
SpaceImpl.demote(long maxSuspendTime,
TimeUnit unit,
SpaceContext sc) |
void |
SpaceImpl.dropClass(String className,
SpaceContext sc)
Drop all Class entries and all its templates from the space.
|
Object |
SpaceImpl.executeTask(SpaceTask task,
Transaction tx,
SpaceContext sc,
boolean newRouter) |
void |
SpaceEngine.getAdmin(SpaceContext sc)
check authority to get admin.
|
ServerIteratorAnswerHolder |
SpaceImpl.getNextBatchFromServerIterator(ITemplatePacket template,
SpaceContext sc,
int modifiers,
ServerIteratorRequestInfo serverIteratorRequestInfo) |
void |
SpaceEngine.invokeFilters(SpaceContext sc,
int operationCode,
Object subject) |
AnswerHolder |
SpaceEngine.newAdaptUpdateMultiple(IEntryPacket[] entries,
Transaction txn,
long lease,
long[] leases,
SpaceContext sc,
long timeout,
int modifiers) |
AnswerHolder |
SpaceEngine.newUpdateMultiple(IEntryPacket[] entries,
Transaction txn,
long[] leases,
SpaceContext sc,
long timeout,
int operationModifiers)
perform update of multiple entries.
|
GSEventRegistration |
SpaceEngine.notify(ITemplatePacket template,
long lease,
boolean fromReplication,
String templateUid,
SpaceContext sc,
NotifyInfo info) |
GSEventRegistration |
SpaceImpl.notify(ITemplatePacket template,
Transaction txn,
long lease,
SpaceContext sc,
NotifyInfo info) |
WriteEntriesResult |
SpaceEngine.oldAdaptUpdateMultiple(IEntryPacket[] entries,
Transaction txn,
long lease,
long[] leases,
SpaceContext sc,
int modifiers,
boolean newRouter) |
AnswerPacket |
SpaceImpl.read(ITemplatePacket template,
Transaction txn,
long timeout,
boolean ifExists,
boolean take,
IJSpaceProxyListener listener,
SpaceContext sc,
boolean returnOnlyUid,
int modifiers) |
AnswerHolder |
SpaceEngine.read(ITemplatePacket template,
Transaction txn,
long timeout,
boolean ifExists,
boolean take,
SpaceContext sc,
boolean returnOnlyUid,
boolean fromReplication,
boolean origin,
int operationModifiers) |
IEntryPacket[] |
SpaceImpl.readByIds(ITemplatePacket template,
Transaction txn,
boolean take,
SpaceContext spaceContext,
int modifiers) |
IEntryPacket[] |
SpaceImpl.readMultiple(ITemplatePacket template,
Transaction txn,
boolean take,
int maxEntries,
SpaceContext sc,
boolean returnOnlyUid,
int modifiers) |
AnswerHolder |
SpaceImpl.readMultiple(ITemplatePacket template,
Transaction txn,
boolean take,
int maxEntries,
SpaceContext sc,
boolean returnOnlyUid,
int modifiers,
int minEntries,
long timeout,
boolean isIfExist) |
AnswerHolder |
SpaceEngine.readMultiple(ITemplatePacket template,
Transaction txn,
long timeout,
boolean ifExists,
boolean take,
SpaceContext sc,
boolean returnOnlyUid,
int operationModifiers,
BatchQueryOperationContext batchOperationContext,
List<SpaceEntriesAggregator> aggregators,
ServerIteratorRequestInfo serverIteratorRequestInfo) |
AnswerHolder |
SpaceImpl.readNew(ITemplatePacket template,
Transaction txn,
long timeout,
boolean ifExists,
boolean take,
IJSpaceProxyListener listener,
SpaceContext sc,
boolean returnOnlyUid,
int modifiers) |
void |
SpaceEngine.registerLocalView(ITemplatePacket[] queryPackets,
Collection<SpaceQueryDetails> queryDescriptions,
RouterStubHolder viewStub,
int batchSize,
long batchTimeout,
SpaceContext spaceContext) |
void |
IRemoteSpace.snapshot(ITemplatePacket e,
SpaceContext sc) |
void |
SpaceImpl.snapshot(ITemplatePacket template,
SpaceContext sc) |
SpaceCopyStatus |
SpaceImpl.spaceCopy(IRemoteSpace remoteProxy,
String remoteSpaceUrl,
String remoteSpaceName,
ITemplatePacket template,
boolean includeNotifyTemplates,
int chunkSize,
SpaceContext sc,
SpaceContext remoteSpaceContext) |
SpaceCopyStatus |
SpaceImpl.spaceCopy(String remoteUrl,
ITemplatePacket template,
boolean includeNotifyTemplates,
int chunkSize,
SpaceContext sc) |
ISpaceCopyReplicaState |
SpaceEngine.spaceCopyReplica(SpaceURL sourceRemoteUrl,
String sourceMemberName,
IRemoteSpace remoteJSpace,
ITemplatePacket templPacket,
boolean includeNotifyTemplates,
int chunkSize,
SpaceContext sc,
SpaceContext remoteSpaceContext) |
ExtendedAnswerHolder |
SpaceEngine.update(IEntryPacket updated_entry,
Transaction txn,
long lease,
long timeout,
SpaceContext sc,
boolean fromReplication,
boolean origin,
boolean newRouter,
int modifiers)
perform an update operation- make it atomic NOTE- returnonlyUID is ignored
|
ExtendedAnswerHolder |
SpaceEngine.update(IEntryPacket updated_entry,
Transaction txn,
long lease,
long timeout,
SpaceContext sc,
boolean fromReplication,
boolean origin,
boolean newRouter,
int modifiers,
MultipleIdsContext multipleIdsContext) |
AnswerPacket |
SpaceImpl.update(IEntryPacket entry,
Transaction txn,
long lease,
long timeout,
SpaceContext sc,
int modifiers,
boolean newRouter) |
Object[] |
SpaceEngine.updateMultiple(IEntryPacket[] entries,
Transaction txn,
long[] leases,
SpaceContext sc,
int operationModifiers,
boolean newRouter)
perform update of multiple entries.
|
WriteEntriesResult |
SpaceEngine.write(IEntryPacket[] entryPackets,
Transaction txn,
long lease,
long[] leases,
int modifiers,
SpaceContext sc,
long timeout,
boolean newRouter)
Creates IEntryHolder objects from the specified entry packets and inserts them into all
relevant engine tables.
|
WriteEntriesResult |
SpaceImpl.write(IEntryPacket[] entries,
Transaction txn,
long lease,
long[] leases,
SpaceContext sc,
long timeout,
int modifiers,
boolean newRouter) |
WriteEntryResult |
SpaceEngine.write(IEntryPacket entryPacket,
Transaction txn,
long lease,
int modifiers,
boolean fromReplication,
boolean origin,
SpaceContext sc)
Creates an IEntryHolder object from the specified entry packet and inserts it into all
relevant engine tables.
|
WriteEntryResult |
SpaceImpl.write(IEntryPacket entry,
Transaction txn,
long lease,
int modifiers,
boolean fromReplication,
SpaceContext sc) |
LeaseContext<?>[] |
SpaceImpl.writeOld(IEntryPacket[] entries,
Transaction txn,
long lease,
long[] leases,
SpaceContext sc,
int modifiers) |
Modifier and Type | Method and Description |
---|---|
SpaceContext |
CopyChunksRequestInfo.getSpaceContext() |
SpaceContext |
DrainRequestInfo.getSpaceContext() |
SpaceContext |
DeleteChunksRequestInfo.getSpaceContext() |
Modifier and Type | Method and Description |
---|---|
void |
CopyChunksRequestInfo.setSpaceContext(SpaceContext spaceContext) |
void |
DrainRequestInfo.setSpaceContext(SpaceContext spaceContext) |
void |
DeleteChunksRequestInfo.setSpaceContext(SpaceContext spaceContext) |
Modifier and Type | Method and Description |
---|---|
SpaceContext |
TemplateHolder.getSpaceContext() |
SpaceContext |
ITemplateHolder.getSpaceContext() |
Modifier and Type | Method and Description |
---|---|
void |
TemplateHolder.setForAfterOperationFilter(int afterOpFilterCode,
SpaceContext sc,
FilterManager fm,
IEntryPacket updateOperationEntry) |
void |
ITemplateHolder.setForAfterOperationFilter(int afterOpFilterCode,
SpaceContext sc,
FilterManager fm,
IEntryPacket updateOperationEntry) |
Modifier and Type | Method and Description |
---|---|
SpaceContext |
AbstractSpaceActionInfo.getSpaceContext() |
Modifier and Type | Method and Description |
---|---|
void |
AbstractSpaceActionInfo.setSpaceContext(SpaceContext spaceContext) |
Modifier and Type | Method and Description |
---|---|
SpaceContext |
AbstractSpaceRequestInfo.getSpaceContext() |
SpaceContext |
SpaceRequestInfo.getSpaceContext() |
SpaceContext |
GSMessageRequestInfo.getSpaceContext() |
Modifier and Type | Method and Description |
---|---|
void |
AbstractSpaceRequestInfo.setSpaceContext(SpaceContext spaceContext) |
void |
SpaceRequestInfo.setSpaceContext(SpaceContext spaceContext) |
void |
GSMessageRequestInfo.setSpaceContext(SpaceContext spaceContext) |
Modifier and Type | Method and Description |
---|---|
SpaceContext |
SecurityInterceptor.trustContext(SpaceContext spaceContext)
Extract the original security context and create a trusted security context wrapper.
|
Modifier and Type | Method and Description |
---|---|
SpaceContext |
SecurityInterceptor.trustContext(SpaceContext spaceContext)
Extract the original security context and create a trusted security context wrapper.
|
Modifier and Type | Method and Description |
---|---|
void |
SecurityFilter.process(SpaceContext context,
ISpaceFilterEntry[] entries,
int operationCode) |
void |
SecurityFilter.process(SpaceContext context,
ISpaceFilterEntry entry,
int operationCode) |
Modifier and Type | Method and Description |
---|---|
void |
NotifyAcknowledgeFilter.process(SpaceContext context,
ISpaceFilterEntry[] entries,
int operationCode) |
void |
NotifyAcknowledgeFilter.process(SpaceContext context,
ISpaceFilterEntry entry,
int operationCode) |
Modifier and Type | Field and Description |
---|---|
SpaceContext |
UpdateOrWriteContext.sc |
Modifier and Type | Method and Description |
---|---|
SpaceContext |
SpaceContext.createCopy(SecurityContext newSecurityContext) |
Modifier and Type | Method and Description |
---|---|
void |
XtnEntry.applyMVCCGenerationStateFromContext(SpaceContext sc) |
static SecurityContext |
SpaceContextHelper.getSecurityContext(SpaceContext spaceContext)
Helper method to extract a non-null security context from a space context.
|
Constructor and Description |
---|
UpdateOrWriteContext(IEntryPacket packet,
long lease,
long timeout,
Transaction tx,
SpaceContext sc,
int operationModifiers,
boolean fromUpdateMultiple,
boolean updateOperation,
boolean fromWriteMultiple) |
UpdateOrWriteContext(IEntryPacket packet,
long lease,
long timeout,
Transaction tx,
SpaceContext sc,
int operationModifiers,
boolean fromUpdateMultiple,
boolean updateOperation,
boolean fromWriteMultiple,
ITemplateHolder concentratingTemplate,
int ordinalInMultipleIdsContext) |
Modifier and Type | Method and Description |
---|---|
void |
JSpaceAdminProxy.dropClass(String className,
SpaceContext sc) |
void |
JSpaceAdminImpl.dropClass(String className,
SpaceContext sc) |
void |
IRemoteJSpaceAdmin.dropClass(String className,
SpaceContext sc)
Deprecated.
Since 16.2 - use GigaSpaceTypeManager#unregisterTypeDescriptor method instead
|
SpaceCopyStatus |
IInternalRemoteJSpaceAdmin.spaceCopy(IRemoteSpace remoteProxy,
String remoteSpaceUrl,
String remoteSpaceName,
ITemplatePacket template,
boolean includeNotifyTemplates,
int chunkSize,
SpaceContext spaceContext,
SpaceContext remoteSpaceContext)
Given ISpaceInternal of a remote space, Copy all entries/notify templates from the space.
|
SpaceCopyStatus |
JSpaceAdminProxy.spaceCopy(IRemoteSpace remoteProxy,
String remoteSpaceUrl,
String remoteSpaceName,
ITemplatePacket template,
boolean includeNotifyTemplates,
int chunkSize,
SpaceContext spaceContext,
SpaceContext remoteSpaceContext) |
SpaceCopyStatus |
JSpaceAdminImpl.spaceCopy(IRemoteSpace remoteProxy,
String remoteSpaceUrl,
String remoteSpaceName,
ITemplatePacket template,
boolean includeNotifyTemplates,
int chunkSize,
SpaceContext sc,
SpaceContext remoteSpaceContext) |
SpaceCopyStatus |
IInternalRemoteJSpaceAdmin.spaceCopy(String remoteUrl,
ITemplatePacket template,
boolean includeNotifyTemplates,
int chunkSize,
SpaceContext sc)
Given Url of a remote space, Copy all entries/notify templates from the space.
|
SpaceCopyStatus |
JSpaceAdminProxy.spaceCopy(String remoteUrl,
ITemplatePacket template,
boolean includeNotifyTemplates,
int chunkSize,
SpaceContext sc) |
SpaceCopyStatus |
JSpaceAdminImpl.spaceCopy(String remoteUrl,
ITemplatePacket template,
boolean includeNotifyTemplates,
int chunkSize,
SpaceContext sc) |
Modifier and Type | Method and Description |
---|---|
void |
Context.applyMVCCGenerationsState(boolean mvccEnabled,
XtnEntry xtnEntry,
SpaceContext sc) |
void |
Context.applyOperationContext(SpaceContext sc) |
Modifier and Type | Method and Description |
---|---|
SpaceContext |
SpaceProxySecurityManager.acquireContext(IRemoteSpace rj) |
SpaceContext |
NullProxySecurityManager.acquireContext(IRemoteSpace rj) |
SpaceContext |
IProxySecurityManager.acquireContext(IRemoteSpace rj) |
SpaceContext |
SpaceProxySecurityManager.acquireContext(IRemoteSpace rs,
CredentialsProvider cp)
Acquire context with the provided credentials without caching the result at the proxy.
|
SpaceContext |
NullProxySecurityManager.acquireContext(IRemoteSpace remoteSpace,
CredentialsProvider credentialsProvider) |
SpaceContext |
IProxySecurityManager.acquireContext(IRemoteSpace remoteSpace,
CredentialsProvider credentialsProvider) |
SpaceContext |
SpaceProxySecurityManager.getThreadSpaceContext() |
SpaceContext |
NullProxySecurityManager.getThreadSpaceContext() |
SpaceContext |
IProxySecurityManager.getThreadSpaceContext() |
SpaceContext |
SpaceProxySecurityManager.setThreadSpaceContext(SpaceContext sc) |
SpaceContext |
NullProxySecurityManager.setThreadSpaceContext(SpaceContext sc) |
SpaceContext |
IProxySecurityManager.setThreadSpaceContext(SpaceContext sc) |
Modifier and Type | Method and Description |
---|---|
SpaceContext |
SpaceProxySecurityManager.setThreadSpaceContext(SpaceContext sc) |
SpaceContext |
NullProxySecurityManager.setThreadSpaceContext(SpaceContext sc) |
SpaceContext |
IProxySecurityManager.setThreadSpaceContext(SpaceContext sc) |
Modifier and Type | Method and Description |
---|---|
void |
FilterManager.invokeFilters(int operationCode,
SpaceContext sc,
Object subject) |
void |
FilterManager.invokeFilters(int operationCode,
SpaceContext sc,
Object subject,
boolean fromReplicas) |
void |
JSpaceStatistics.process(SpaceContext context,
ISpaceFilterEntry[] entries,
int operationCode) |
void |
ISpaceFilter.process(SpaceContext context,
ISpaceFilterEntry[] entries,
int operationCode)
This method is called by the engine when an event matching this filter's operation code
occurs in the engine.
|
void |
JSpaceStatistics.process(SpaceContext context,
ISpaceFilterEntry subject,
int operationCode) |
void |
ISpaceFilter.process(SpaceContext context,
ISpaceFilterEntry entry,
int operationCode)
This method is called by the engine when an event matching this filter's
operation code occurs in the space engine.
|
Modifier and Type | Method and Description |
---|---|
SpaceContext |
ConnectionContext.getSpaceContext() |
Modifier and Type | Method and Description |
---|---|
void |
ConnectionContext.setSpaceContext(SpaceContext spaceContext) |
Modifier and Type | Method and Description |
---|---|
void |
ExecutorSpaceFilter.process(SpaceContext context,
ISpaceFilterEntry[] entries,
int operationCode) |
void |
ExecutorSpaceFilter.process(SpaceContext context,
ISpaceFilterEntry entry,
int operationCode) |
Modifier and Type | Method and Description |
---|---|
void |
FilterOperationDelegate.process(SpaceContext context,
ISpaceFilterEntry[] entries,
int operationCode)
Fetch a
FilterOperationDelegateInvoker based on the
operation code. |
void |
FilterOperationDelegate.process(SpaceContext context,
ISpaceFilterEntry entry,
int operationCode)
Fetch a
FilterOperationDelegateInvoker based on the
operation code. |
Copyright © GigaSpaces.