Package | Description |
---|---|
com.hazelcast.client.cp.internal.session |
Contains client-side impl of the Raft proxy session manager
|
com.hazelcast.cp.internal |
Contains implementation of the CP subsystem
|
com.hazelcast.cp.internal.datastructures.atomiclong.proxy |
Contains
IAtomicLong functionality
based on the Raft algorithm. |
com.hazelcast.cp.internal.datastructures.atomicref.proxy |
Contains
IAtomicReference functionality
based on the Raft algorithm. |
com.hazelcast.cp.internal.datastructures.countdownlatch.proxy |
Contains
IAtomicLong functionality
based on the Raft algorithm. |
com.hazelcast.cp.internal.datastructures.lock.proxy |
Contains
ILock functionality
based on the Raft algorithm. |
com.hazelcast.cp.internal.datastructures.semaphore.proxy |
Contains
ISemaphore functionality
based on the Raft algorithm. |
com.hazelcast.cp.internal.raftop.metadata |
Contains operations that are used in the Metadata CP group
|
com.hazelcast.cp.internal.session |
Contains service classes
for the Raft-based
ISemaphore implementation |
Modifier and Type | Method and Description |
---|---|
Map<RaftGroupId,ICompletableFuture<Object>> |
ClientProxySessionManager.shutdown() |
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 © 2019 Hazelcast, Inc.. All Rights Reserved.