| Constructor and Description | 
|---|
RaftAtomicLongProxy(ClientContext context,
                   RaftGroupId groupId,
                   String proxyName,
                   String objectName)  | 
| Constructor and Description | 
|---|
RaftAtomicRefProxy(ClientContext context,
                  RaftGroupId groupId,
                  String proxyName,
                  String objectName)  | 
| Constructor and Description | 
|---|
RaftCountDownLatchProxy(ClientContext context,
                       RaftGroupId groupId,
                       String proxyName,
                       String objectName)  | 
| Constructor and Description | 
|---|
RaftFencedLockProxy(ClientContext context,
                   RaftGroupId groupId,
                   String proxyName,
                   String objectName)  | 
| Constructor and Description | 
|---|
RaftSessionAwareSemaphoreProxy(ClientContext context,
                              RaftGroupId groupId,
                              String proxyName,
                              String objectName)  | 
RaftSessionlessSemaphoreProxy(ClientContext context,
                             RaftGroupId groupId,
                             String proxyName,
                             String objectName)  | 
| Modifier and Type | Method and Description | 
|---|---|
protected ICompletableFuture<Object> | 
ClientProxySessionManager.closeSession(RaftGroupId groupId,
            Long sessionId)  | 
protected long | 
ClientProxySessionManager.generateThreadId(RaftGroupId groupId)  | 
protected ICompletableFuture<Object> | 
ClientProxySessionManager.heartbeat(RaftGroupId groupId,
         long sessionId)  | 
protected SessionResponse | 
ClientProxySessionManager.requestNewSession(RaftGroupId groupId)  | 
| 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)  | 
InternalCompletableFuture<RaftGroupId> | 
RaftService.createRaftGroupForProxyAsync(String name)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
RaftService.handleActiveCPMembers(RaftGroupId latestMetadataGroupId,
                     long membersCommitIndex,
                     Collection<CPMemberInfo> members)  | 
void | 
MetadataRaftGroupManager.handleMetadataGroupId(RaftGroupId newMetadataGroupId)  | 
| Constructor and Description | 
|---|
CPGroupInfo(RaftGroupId id,
           Collection<CPMemberInfo> members)  | 
| Constructor and Description | 
|---|
RaftAtomicLongProxy(NodeEngine nodeEngine,
                   RaftGroupId groupId,
                   String proxyName,
                   String objectName)  | 
| Constructor and Description | 
|---|
RaftAtomicRefProxy(NodeEngine nodeEngine,
                  RaftGroupId groupId,
                  String proxyName,
                  String objectName)  | 
| Constructor and Description | 
|---|
RaftCountDownLatchProxy(NodeEngine nodeEngine,
                       RaftGroupId groupId,
                       String proxyName,
                       String objectName)  | 
| Constructor and Description | 
|---|
AbstractRaftFencedLockProxy(AbstractProxySessionManager sessionManager,
                           RaftGroupId groupId,
                           String proxyName,
                           String objectName)  | 
RaftFencedLockProxy(NodeEngine nodeEngine,
                   RaftGroupId groupId,
                   String proxyName,
                   String objectName)  | 
| Constructor and Description | 
|---|
RaftSessionAwareSemaphoreProxy(NodeEngine nodeEngine,
                              RaftGroupId groupId,
                              String proxyName,
                              String objectName)  | 
RaftSessionlessSemaphoreProxy(NodeEngine nodeEngine,
                             RaftGroupId groupId,
                             String proxyName,
                             String objectName)  | 
| 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,ICompletableFuture<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 ICompletableFuture<Object> | 
ProxySessionManagerService.closeSession(RaftGroupId groupId,
            Long sessionId)  | 
protected abstract ICompletableFuture<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 
 | 
protected Long | 
SessionAwareProxy.getOrCreateUniqueThreadId(RaftGroupId groupId)  | 
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 ICompletableFuture<Object> | 
ProxySessionManagerService.heartbeat(RaftGroupId groupId,
         long sessionId)  | 
protected abstract ICompletableFuture<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 © 2020 Hazelcast, Inc.. All Rights Reserved.