Constructor and Description |
---|
AtomicLongProxy(ClientContext context,
RaftGroupId groupId,
String proxyName,
String objectName) |
Constructor and Description |
---|
AtomicRefProxy(ClientContext context,
RaftGroupId groupId,
String proxyName,
String objectName) |
Constructor and Description |
---|
CountDownLatchProxy(ClientContext context,
RaftGroupId groupId,
String proxyName,
String objectName) |
Constructor and Description |
---|
FencedLockProxy(ClientContext context,
RaftGroupId groupId,
String proxyName,
String objectName) |
Constructor and Description |
---|
SessionAwareSemaphoreProxy(ClientContext context,
RaftGroupId groupId,
String proxyName,
String objectName) |
SessionlessSemaphoreProxy(ClientContext context,
RaftGroupId groupId,
String proxyName,
String objectName) |
Modifier and Type | Method and Description |
---|---|
protected InternalCompletableFuture<Object> |
ClientProxySessionManager.closeSession(RaftGroupId groupId,
Long sessionId) |
protected long |
ClientProxySessionManager.generateThreadId(RaftGroupId groupId) |
protected InternalCompletableFuture<Object> |
ClientProxySessionManager.heartbeat(RaftGroupId groupId,
long sessionId) |
protected SessionResponse |
ClientProxySessionManager.requestNewSession(RaftGroupId groupId) |
Modifier and Type | Field and Description |
---|---|
RaftGroupId |
CountDownLatchGetCountCodec.RequestParameters.groupId
CP group id of this CountDownLatch instance
|
RaftGroupId |
CPGroupDestroyCPObjectCodec.RequestParameters.groupId
CP group id of this distributed object
|
RaftGroupId |
CountDownLatchCountDownCodec.RequestParameters.groupId
CP group id of this CountDownLatch instance
|
RaftGroupId |
AtomicLongGetAndSetCodec.RequestParameters.groupId
CP group id of this IAtomicLong instance.
|
RaftGroupId |
SemaphoreAvailablePermitsCodec.RequestParameters.groupId
CP group id of this ISemaphore instance
|
RaftGroupId |
CountDownLatchGetRoundCodec.RequestParameters.groupId
CP group id of this CountDownLatch instance
|
RaftGroupId |
AtomicLongAddAndGetCodec.RequestParameters.groupId
CP group id of this IAtomicLong instance.
|
RaftGroupId |
AtomicRefSetCodec.RequestParameters.groupId
CP group id of this IAtomicReference instance.
|
RaftGroupId |
FencedLockLockCodec.RequestParameters.groupId
CP group id of this FencedLock instance
|
RaftGroupId |
FencedLockGetLockOwnershipCodec.RequestParameters.groupId
CP group id of this FencedLock instance
|
RaftGroupId |
AtomicRefGetCodec.RequestParameters.groupId
CP group id of this IAtomicReference instance.
|
RaftGroupId |
AtomicRefContainsCodec.RequestParameters.groupId
CP group id of this IAtomicReference instance.
|
RaftGroupId |
SemaphoreChangeCodec.RequestParameters.groupId
CP group id of this ISemaphore instance
|
RaftGroupId |
FencedLockUnlockCodec.RequestParameters.groupId
CP group id of this FencedLock instance
|
RaftGroupId |
CPSessionGenerateThreadIdCodec.RequestParameters.groupId
ID of the CP group
|
RaftGroupId |
SemaphoreAcquireCodec.RequestParameters.groupId
CP group id of this ISemaphore instance
|
RaftGroupId |
CPSessionCreateSessionCodec.RequestParameters.groupId
ID of the CP group
|
RaftGroupId |
CPGroupCreateCPGroupCodec.ResponseParameters.groupId
ID of the CP group that contains the CP object
|
RaftGroupId |
AtomicLongGetAndAddCodec.RequestParameters.groupId
CP group id of this IAtomicLong instance.
|
RaftGroupId |
CountDownLatchAwaitCodec.RequestParameters.groupId
CP group id of this CountDownLatch instance
|
RaftGroupId |
AtomicLongAlterCodec.RequestParameters.groupId
CP group id of this IAtomicLong instance.
|
RaftGroupId |
AtomicRefCompareAndSetCodec.RequestParameters.groupId
CP group id of this IAtomicReference instance.
|
RaftGroupId |
AtomicLongGetCodec.RequestParameters.groupId
CP group id of this IAtomicLong instance.
|
RaftGroupId |
SemaphoreReleaseCodec.RequestParameters.groupId
CP group id of this ISemaphore instance
|
RaftGroupId |
SemaphoreInitCodec.RequestParameters.groupId
CP group id of this ISemaphore instance
|
RaftGroupId |
CPSessionCloseSessionCodec.RequestParameters.groupId
ID of the CP group
|
RaftGroupId |
CPSessionHeartbeatSessionCodec.RequestParameters.groupId
ID of the CP group
|
RaftGroupId |
SemaphoreDrainCodec.RequestParameters.groupId
CP group id of this ISemaphore instance
|
RaftGroupId |
AtomicRefApplyCodec.RequestParameters.groupId
CP group id of this IAtomicReference instance.
|
RaftGroupId |
AtomicLongCompareAndSetCodec.RequestParameters.groupId
CP group id of this IAtomicLong instance.
|
RaftGroupId |
AtomicLongApplyCodec.RequestParameters.groupId
CP group id of this IAtomicLong instance.
|
RaftGroupId |
CountDownLatchTrySetCountCodec.RequestParameters.groupId
CP group id of this CountDownLatch instance
|
RaftGroupId |
FencedLockTryLockCodec.RequestParameters.groupId
CP group id of this FencedLock instance
|
Modifier and Type | Method and Description |
---|---|
static ClientMessage |
CPSessionGenerateThreadIdCodec.encodeRequest(RaftGroupId groupId) |
static ClientMessage |
CPSessionCloseSessionCodec.encodeRequest(RaftGroupId groupId,
long sessionId) |
static ClientMessage |
CPSessionHeartbeatSessionCodec.encodeRequest(RaftGroupId groupId,
long sessionId) |
static ClientMessage |
CountDownLatchGetCountCodec.encodeRequest(RaftGroupId groupId,
String name) |
static ClientMessage |
SemaphoreAvailablePermitsCodec.encodeRequest(RaftGroupId groupId,
String name) |
static ClientMessage |
CountDownLatchGetRoundCodec.encodeRequest(RaftGroupId groupId,
String name) |
static ClientMessage |
FencedLockGetLockOwnershipCodec.encodeRequest(RaftGroupId groupId,
String name) |
static ClientMessage |
AtomicRefGetCodec.encodeRequest(RaftGroupId groupId,
String name) |
static ClientMessage |
CPSessionCreateSessionCodec.encodeRequest(RaftGroupId groupId,
String endpointName) |
static ClientMessage |
AtomicLongGetCodec.encodeRequest(RaftGroupId groupId,
String name) |
static ClientMessage |
AtomicRefContainsCodec.encodeRequest(RaftGroupId groupId,
String name,
Data value) |
static ClientMessage |
AtomicLongApplyCodec.encodeRequest(RaftGroupId groupId,
String name,
Data function) |
static ClientMessage |
AtomicRefSetCodec.encodeRequest(RaftGroupId groupId,
String name,
Data newValue,
boolean returnOldValue) |
static ClientMessage |
AtomicRefCompareAndSetCodec.encodeRequest(RaftGroupId groupId,
String name,
Data oldValue,
Data newValue) |
static ClientMessage |
AtomicLongAlterCodec.encodeRequest(RaftGroupId groupId,
String name,
Data function,
int returnValueType) |
static ClientMessage |
AtomicRefApplyCodec.encodeRequest(RaftGroupId groupId,
String name,
Data function,
int returnValueType,
boolean alter) |
static ClientMessage |
SemaphoreInitCodec.encodeRequest(RaftGroupId groupId,
String name,
int permits) |
static ClientMessage |
CountDownLatchTrySetCountCodec.encodeRequest(RaftGroupId groupId,
String name,
int count) |
static ClientMessage |
AtomicLongGetAndSetCodec.encodeRequest(RaftGroupId groupId,
String name,
long newValue) |
static ClientMessage |
AtomicLongAddAndGetCodec.encodeRequest(RaftGroupId groupId,
String name,
long delta) |
static ClientMessage |
AtomicLongGetAndAddCodec.encodeRequest(RaftGroupId groupId,
String name,
long delta) |
static ClientMessage |
AtomicLongCompareAndSetCodec.encodeRequest(RaftGroupId groupId,
String name,
long expected,
long updated) |
static ClientMessage |
FencedLockLockCodec.encodeRequest(RaftGroupId groupId,
String name,
long sessionId,
long threadId,
UUID invocationUid) |
static ClientMessage |
FencedLockUnlockCodec.encodeRequest(RaftGroupId groupId,
String name,
long sessionId,
long threadId,
UUID invocationUid) |
static ClientMessage |
SemaphoreDrainCodec.encodeRequest(RaftGroupId groupId,
String name,
long sessionId,
long threadId,
UUID invocationUid) |
static ClientMessage |
SemaphoreChangeCodec.encodeRequest(RaftGroupId groupId,
String name,
long sessionId,
long threadId,
UUID invocationUid,
int permits) |
static ClientMessage |
SemaphoreReleaseCodec.encodeRequest(RaftGroupId groupId,
String name,
long sessionId,
long threadId,
UUID invocationUid,
int permits) |
static ClientMessage |
SemaphoreAcquireCodec.encodeRequest(RaftGroupId groupId,
String name,
long sessionId,
long threadId,
UUID invocationUid,
int permits,
long timeoutMs) |
static ClientMessage |
FencedLockTryLockCodec.encodeRequest(RaftGroupId groupId,
String name,
long sessionId,
long threadId,
UUID invocationUid,
long timeoutMs) |
static ClientMessage |
CPGroupDestroyCPObjectCodec.encodeRequest(RaftGroupId groupId,
String serviceName,
String objectName) |
static ClientMessage |
CountDownLatchCountDownCodec.encodeRequest(RaftGroupId groupId,
String name,
UUID invocationUid,
int expectedRound) |
static ClientMessage |
CountDownLatchAwaitCodec.encodeRequest(RaftGroupId groupId,
String name,
UUID invocationUid,
long timeoutMs) |
static ClientMessage |
CPGroupCreateCPGroupCodec.encodeResponse(RaftGroupId groupId) |
Modifier and Type | Method and Description |
---|---|
static RaftGroupId |
RaftGroupIdCodec.decode(ClientMessage.ForwardFrameIterator iterator) |
Modifier and Type | Method and Description |
---|---|
static void |
RaftGroupIdCodec.encode(ClientMessage clientMessage,
RaftGroupId raftGroupId) |
Modifier and Type | Field and Description |
---|---|
static RaftGroupId |
MetadataRaftGroupManager.INITIAL_METADATA_GROUP_ID |
Modifier and Type | Method and Description |
---|---|
RaftGroupId |
RaftService.createRaftGroupForProxy(String name) |
RaftGroupId |
MetadataRaftGroupManager.getMetadataGroupId() |
RaftGroupId |
RaftService.getMetadataGroupId() |
RaftGroupId |
CPGroupInfo.id() |
Modifier and Type | Method and Description |
---|---|
InternalCompletableFuture<RaftGroupId> |
RaftInvocationManager.createRaftGroup(String groupName) |
InternalCompletableFuture<RaftGroupId> |
RaftInvocationManager.createRaftGroup(String groupName,
int groupSize) |
Modifier and Type | Method and Description |
---|---|
void |
RaftService.handleActiveCPMembers(RaftGroupId receivedMetadataGroupId,
long membersCommitIndex,
Collection<CPMemberInfo> members) |
void |
MetadataRaftGroupManager.handleMetadataGroupId(RaftGroupId newMetadataGroupId) |
void |
MetadataRaftGroupManager.restoreMetadataGroupId(RaftGroupId restoredMetadataGroupId) |
RaftNodeImpl |
RaftService.restoreRaftNode(RaftGroupId groupId,
RestoredRaftState restoredState,
LogFileStructure logFileStructure) |
Constructor and Description |
---|
CPGroupInfo(RaftGroupId id,
Collection<RaftEndpoint> members) |
Modifier and Type | Method and Description |
---|---|
protected IAtomicLong |
AtomicLongService.newRaftAtomicProxy(NodeEngineImpl nodeEngine,
RaftGroupId groupId,
String proxyName,
String objectNameForProxy) |
Constructor and Description |
---|
AtomicLongProxy(NodeEngine nodeEngine,
RaftGroupId groupId,
String proxyName,
String objectName) |
Modifier and Type | Method and Description |
---|---|
protected IAtomicReference |
AtomicRefService.newRaftAtomicProxy(NodeEngineImpl nodeEngine,
RaftGroupId groupId,
String proxyName,
String objectNameForProxy) |
Constructor and Description |
---|
AtomicRefProxy(NodeEngine nodeEngine,
RaftGroupId groupId,
String proxyName,
String objectName) |
Constructor and Description |
---|
CountDownLatchProxy(NodeEngine nodeEngine,
RaftGroupId groupId,
String proxyName,
String objectName) |
Constructor and Description |
---|
AbstractFencedLockProxy(AbstractProxySessionManager sessionManager,
RaftGroupId groupId,
String proxyName,
String objectName) |
FencedLockProxy(NodeEngine nodeEngine,
RaftGroupId groupId,
String proxyName,
String objectName) |
Constructor and Description |
---|
SessionAwareSemaphoreProxy(NodeEngine nodeEngine,
RaftGroupId groupId,
String proxyName,
String objectName) |
SessionlessSemaphoreProxy(NodeEngine nodeEngine,
RaftGroupId groupId,
String proxyName,
String objectName) |
Modifier and Type | Method and Description |
---|---|
protected abstract DistributedObject |
RaftAtomicValueService.newRaftAtomicProxy(NodeEngineImpl nodeEngine,
RaftGroupId groupId,
String proxyName,
String objectNameForProxy) |
Modifier and Type | Method and Description |
---|---|
RaftGroupId |
NopCPMetadataStore.readMetadataGroupId() |
RaftGroupId |
CPMetadataStore.readMetadataGroupId()
Reads group id of the METADATA group, or reads null if METADATA
group id has not changed
|
Modifier and Type | Method and Description |
---|---|
RaftStateStore |
CPPersistenceService.createRaftStateStore(RaftGroupId groupId,
LogFileStructure logFileStructure)
Creates a
RaftStateStore that is going to be used by the local Raft node
of the given CP group. |
RaftStateStore |
NopCPPersistenceService.createRaftStateStore(RaftGroupId groupId,
LogFileStructure logFileStructure) |
void |
NopCPMetadataStore.persistMetadataGroupId(RaftGroupId groupId) |
void |
CPMetadataStore.persistMetadataGroupId(RaftGroupId groupId)
Persists group id of the METADATA group.
|
void |
CPPersistenceService.removeRaftStateStore(RaftGroupId groupId)
Removes the store associated with groupId,
removes all persisted state and releases acquired resources.
|
void |
NopCPPersistenceService.removeRaftStateStore(RaftGroupId groupId) |
Constructor and Description |
---|
PublishActiveCPMembersOp(RaftGroupId metadataGroupId,
long membersCommitIndex,
Collection<CPMemberInfo> members) |
RaftServicePreJoinOp(boolean discoveryCompleted,
RaftGroupId metadataGroupId) |
Modifier and Type | Field and Description |
---|---|
protected RaftGroupId |
SessionAwareProxy.groupId |
Modifier and Type | Method and Description |
---|---|
RaftGroupId |
SessionAwareProxy.getGroupId() |
Modifier and Type | Method and Description |
---|---|
Map<RaftGroupId,InternalCompletableFuture<Object>> |
AbstractProxySessionManager.shutdown()
Invokes a shutdown call on server to close all existing sessions.
|
Modifier and Type | Method and Description |
---|---|
long |
AbstractProxySessionManager.acquireSession(RaftGroupId groupId)
Increments acquire count of the session.
|
long |
AbstractProxySessionManager.acquireSession(RaftGroupId groupId,
int count)
Increments acquire count of the session.
|
protected InternalCompletableFuture<Object> |
ProxySessionManagerService.closeSession(RaftGroupId groupId,
Long sessionId) |
protected abstract InternalCompletableFuture<Object> |
AbstractProxySessionManager.closeSession(RaftGroupId groupId,
Long sessionId)
Closes the given session on the Raft group
|
protected long |
ProxySessionManagerService.generateThreadId(RaftGroupId groupId) |
protected abstract long |
AbstractProxySessionManager.generateThreadId(RaftGroupId groupId)
Generates a cluster-wide unique thread id for the caller
|
Long |
AbstractProxySessionManager.getOrCreateUniqueThreadId(RaftGroupId groupId) |
long |
AbstractProxySessionManager.getSession(RaftGroupId groupId)
Returns id of the session opened for the given Raft group.
|
long |
AbstractProxySessionManager.getSessionAcquireCount(RaftGroupId groupId,
long sessionId) |
protected InternalCompletableFuture<Object> |
ProxySessionManagerService.heartbeat(RaftGroupId groupId,
long sessionId) |
protected abstract InternalCompletableFuture<Object> |
AbstractProxySessionManager.heartbeat(RaftGroupId groupId,
long sessionId)
Commits a heartbeat for the session on the Raft group
|
void |
AbstractProxySessionManager.invalidateSession(RaftGroupId groupId,
long id)
Invalidates the given session.
|
void |
AbstractProxySessionManager.releaseSession(RaftGroupId groupId,
long id)
Decrements acquire count of the session.
|
void |
AbstractProxySessionManager.releaseSession(RaftGroupId groupId,
long id,
int count)
Decrements acquire count of the session.
|
protected SessionResponse |
ProxySessionManagerService.requestNewSession(RaftGroupId groupId) |
protected abstract SessionResponse |
AbstractProxySessionManager.requestNewSession(RaftGroupId groupId)
Creates a new session on the Raft group
|
Constructor and Description |
---|
SessionAwareProxy(AbstractProxySessionManager sessionManager,
RaftGroupId groupId) |
Copyright © 2019 Hazelcast, Inc.. All rights reserved.