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.