Uses of Interface
com.hazelcast.cp.CPGroupId

Packages that use CPGroupId

Package	Description
com.hazelcast.cp	Contains public APIs of the CP subsystem
com.hazelcast.cp.exception	Contains exceptions that can be thrown by APIs of the CP subsystem
com.hazelcast.cp.internal	Contains implementation of the CP subsystem
com.hazelcast.cp.internal.datastructures.atomiclong	Contains service classes for the Raft-based IAtomicLong implementation
com.hazelcast.cp.internal.datastructures.atomiclong.operation	Contains operations for the Raft-based IAtomicLong implementation
com.hazelcast.cp.internal.datastructures.atomiclong.proxy	Contains IAtomicLong functionality based on the Raft algorithm.
com.hazelcast.cp.internal.datastructures.atomicref	Contains service classes for the Raft-based IAtomicReference implementation
com.hazelcast.cp.internal.datastructures.atomicref.operation	Contains operations for the Raft-based IAtomicReference implementation
com.hazelcast.cp.internal.datastructures.atomicref.proxy	Contains IAtomicReference functionality based on the Raft algorithm.
com.hazelcast.cp.internal.datastructures.countdownlatch	Contains service classes for the Raft-based ICountDownLatch implementation
com.hazelcast.cp.internal.datastructures.countdownlatch.operation	Contains operations for the Raft-based ICountDownLatch implementation
com.hazelcast.cp.internal.datastructures.countdownlatch.proxy	Contains IAtomicLong functionality based on the Raft algorithm.
com.hazelcast.cp.internal.datastructures.lock	Contains service classes for the Raft-based ILock and FencedLock implementation
com.hazelcast.cp.internal.datastructures.lock.operation	Contains operations for the Raft-based ILock implementation
com.hazelcast.cp.internal.datastructures.semaphore	Contains service classes for the Raft-based ISemaphore implementation
com.hazelcast.cp.internal.datastructures.semaphore.operation	Contains operations for the Raft-based ISemaphore implementation
com.hazelcast.cp.internal.datastructures.spi	Contains the abstractions that is used for managing proxies for the Raft-based data structure implementations
com.hazelcast.cp.internal.datastructures.spi.blocking	Contains the interfaces and abstractions that are implemented / extended by blocking Raft services, such as Lock, Semaphore, and CountDownLatch
com.hazelcast.cp.internal.datastructures.spi.blocking.operation	Contains the operations that are used by the AbstractBlockingService abstraction
com.hazelcast.cp.internal.datastructures.spi.operation	Contains the operations that is used for managing proxies for the Raft-based data structure implementations
com.hazelcast.cp.internal.operation	Contains operations for the Raft Invocation SPI
com.hazelcast.cp.internal.operation.integration	Contains Hazelcast operations that carry out Raft RPCs
com.hazelcast.cp.internal.raft	Contains abstractions that are defined for the core Raft algorithm implementation
com.hazelcast.cp.internal.raft.impl	Contains implementation classes of the Raft algorithm
com.hazelcast.cp.internal.raft.impl.state	Contains classes that keep state of Raft nodes
com.hazelcast.cp.internal.raftop	Contains operations that are used in Hazelcast's Raft implementation
com.hazelcast.cp.internal.raftop.metadata	Contains operations that are used in the Metadata CP group
com.hazelcast.cp.internal.raftop.snapshot	Contains operations that are used by Hazelcast to implement Raft's snapshotting mechanism
com.hazelcast.cp.internal.session	Contains service classes for the Raft-based ISemaphore implementation
com.hazelcast.cp.internal.session.operation	Contains operations that are internally used by the CP session API
com.hazelcast.cp.lock	Contains locking APIs of the CP subsystem
com.hazelcast.spi.impl.operationservice.impl	Contains the code for the InternalOperationService implementation.

Uses of CPGroupId in com.hazelcast.cp

Methods in com.hazelcast.cp that return CPGroupId

Modifier and Type	Method and Description
CPGroupId	CPGroup.id() Returns unique id of the CP group

Methods in com.hazelcast.cp that return types with arguments of type CPGroupId

Modifier and Type	Method and Description
ICompletableFuture<Collection<CPGroupId>>	CPSubsystemManagementService.getCPGroupIds() Returns all active CP group ids.

Uses of CPGroupId in com.hazelcast.cp.exception

Methods in com.hazelcast.cp.exception that return CPGroupId

Modifier and Type	Method and Description
CPGroupId	CPGroupDestroyedException.getGroupId()

Constructors in com.hazelcast.cp.exception with parameters of type CPGroupId

Constructor and Description
CPGroupDestroyedException(CPGroupId groupId)
NotLeaderException(CPGroupId groupId, Endpoint local, Endpoint leader)

Uses of CPGroupId in com.hazelcast.cp.internal

Classes in com.hazelcast.cp.internal that implement CPGroupId

Modifier and Type	Class and Description
class	RaftGroupId Implementation of CPGroupId.

Methods in com.hazelcast.cp.internal that return CPGroupId

Modifier and Type	Method and Description
CPGroupId	MetadataRaftGroupManager.createRaftGroup(String groupName, Collection<CPMemberInfo> members, long commitIndex)

Methods in com.hazelcast.cp.internal that return types with arguments of type CPGroupId

Modifier and Type	Method and Description
Collection<CPGroupId>	MetadataRaftGroupManager.getActiveGroupIds()
ICompletableFuture<Collection<CPGroupId>>	RaftService.getAllCPGroupIds()
ICompletableFuture<Collection<CPGroupId>>	RaftService.getCPGroupIds()
Collection<CPGroupId>	RaftService.getCPGroupIdsLocally()
Collection<CPGroupId>	MetadataRaftGroupManager.getDestroyingGroupIds()
Collection<CPGroupId>	MetadataRaftGroupManager.getGroupIds()

Methods in com.hazelcast.cp.internal with parameters of type CPGroupId

Modifier and Type	Method and Description
void	RaftService.createRaftNode(CPGroupId groupId, Collection<CPMemberInfo> members)
InternalCompletableFuture<Object>	RaftInvocationManager.destroy(CPGroupId groupId)
void	RaftService.destroyRaftNode(CPGroupId groupId)
ICompletableFuture<CPGroup>	RaftService.getCPGroup(CPGroupId groupId)
CPGroupInfo	RaftService.getCPGroupLocally(CPGroupId groupId)
CPGroupInfo	MetadataRaftGroupManager.getGroup(CPGroupId groupId)
RaftNode	RaftService.getOrInitRaftNode(CPGroupId groupId)
RaftNode	RaftService.getRaftNode(CPGroupId groupId)
void	RaftService.handleAppendEntries(CPGroupId groupId, AppendRequest request, CPMember target)
void	RaftService.handleAppendResponse(CPGroupId groupId, AppendFailureResponse response, CPMember target)
void	RaftService.handleAppendResponse(CPGroupId groupId, AppendSuccessResponse response, CPMember target)
void	RaftService.handlePreVoteRequest(CPGroupId groupId, PreVoteRequest request, CPMember target)
void	RaftService.handlePreVoteResponse(CPGroupId groupId, PreVoteResponse response, CPMember target)
void	RaftService.handleSnapshot(CPGroupId groupId, InstallSnapshot request, CPMember target)
void	RaftService.handleVoteRequest(CPGroupId groupId, VoteRequest request, CPMember target)
void	RaftService.handleVoteResponse(CPGroupId groupId, VoteResponse response, CPMember target)
<T> InternalCompletableFuture<T>	RaftInvocationManager.invoke(CPGroupId groupId, RaftOp raftOp)
boolean	RaftService.isRaftGroupDestroyed(CPGroupId groupId)
void	RaftGroupLifecycleAwareService.onGroupDestroy(CPGroupId groupId) Called on the thread of the Raft group when the given Raft group is destroyed, either gracefully or forcefully.
void	TermChangeAwareService.onNewTermCommit(CPGroupId groupId, long commitIndex) Invokes as part of the first commit after a new leader is elected.
<T> InternalCompletableFuture<T>	RaftInvocationManager.query(CPGroupId groupId, RaftOp raftOp, QueryPolicy queryPolicy)
<T> InternalCompletableFuture<T>	RaftInvocationManager.queryLocally(CPGroupId groupId, RaftOp raftOp, QueryPolicy queryPolicy)
void	MetadataRaftGroupManager.restoreSnapshot(CPGroupId groupId, long commitIndex, MetadataRaftGroupSnapshot snapshot)
void	RaftService.restoreSnapshot(CPGroupId groupId, long commitIndex, MetadataRaftGroupSnapshot snapshot)
abstract Object	RaftOp.run(CPGroupId groupId, long commitIndex) Contains actual Raft operation logic.
void	RaftService.stepDownRaftNode(CPGroupId groupId)
MetadataRaftGroupSnapshot	MetadataRaftGroupManager.takeSnapshot(CPGroupId groupId, long commitIndex)
MetadataRaftGroupSnapshot	RaftService.takeSnapshot(CPGroupId groupId, long commitIndex)
void	MetadataRaftGroupManager.triggerDestroyRaftGroup(CPGroupId groupId)

Method parameters in com.hazelcast.cp.internal with type arguments of type CPGroupId

Modifier and Type	Method and Description
void	MetadataRaftGroupManager.completeDestroyRaftGroups(Set<CPGroupId> groupIds)
MembershipChangeSchedule	MetadataRaftGroupManager.completeRaftGroupMembershipChanges(long commitIndex, Map<CPGroupId,Tuple2<Long,Long>> changedGroups)

Uses of CPGroupId in com.hazelcast.cp.internal.datastructures.atomiclong

Methods in com.hazelcast.cp.internal.datastructures.atomiclong that return CPGroupId

Modifier and Type	Method and Description
CPGroupId	RaftAtomicLong.groupId()

Methods in com.hazelcast.cp.internal.datastructures.atomiclong with parameters of type CPGroupId

Modifier and Type	Method and Description
boolean	RaftAtomicLongService.destroyRaftObject(CPGroupId groupId, String name)
RaftAtomicLong	RaftAtomicLongService.getAtomicLong(CPGroupId groupId, String name)
void	RaftAtomicLongService.onGroupDestroy(CPGroupId groupId)
void	RaftAtomicLongService.restoreSnapshot(CPGroupId groupId, long commitIndex, RaftAtomicLongSnapshot snapshot)
RaftAtomicLongSnapshot	RaftAtomicLongService.takeSnapshot(CPGroupId groupId, long commitIndex)

Uses of CPGroupId in com.hazelcast.cp.internal.datastructures.atomiclong.operation

Methods in com.hazelcast.cp.internal.datastructures.atomiclong.operation with parameters of type CPGroupId

Modifier and Type	Method and Description
Object	AlterOp.run(CPGroupId groupId, long commitIndex)
Object	ApplyOp.run(CPGroupId groupId, long commitIndex)
Object	LocalGetOp.run(CPGroupId groupId, long commitIndex)
Object	CompareAndSetOp.run(CPGroupId groupId, long commitIndex)
Object	GetAndAddOp.run(CPGroupId groupId, long commitIndex)
Object	AddAndGetOp.run(CPGroupId groupId, long commitIndex)
Object	GetAndSetOp.run(CPGroupId groupId, long commitIndex)

Uses of CPGroupId in com.hazelcast.cp.internal.datastructures.atomiclong.proxy

Methods in com.hazelcast.cp.internal.datastructures.atomiclong.proxy that return CPGroupId

Modifier and Type	Method and Description
CPGroupId	RaftAtomicLongProxy.getGroupId()

Uses of CPGroupId in com.hazelcast.cp.internal.datastructures.atomicref

Methods in com.hazelcast.cp.internal.datastructures.atomicref that return CPGroupId

Modifier and Type	Method and Description
CPGroupId	RaftAtomicRef.groupId()

Methods in com.hazelcast.cp.internal.datastructures.atomicref with parameters of type CPGroupId

Modifier and Type	Method and Description
boolean	RaftAtomicRefService.destroyRaftObject(CPGroupId groupId, String name)
RaftAtomicRef	RaftAtomicRefService.getAtomicRef(CPGroupId groupId, String name)
void	RaftAtomicRefService.onGroupDestroy(CPGroupId groupId)
void	RaftAtomicRefService.restoreSnapshot(CPGroupId groupId, long commitIndex, RaftAtomicRefSnapshot snapshot)
RaftAtomicRefSnapshot	RaftAtomicRefService.takeSnapshot(CPGroupId groupId, long commitIndex)

Uses of CPGroupId in com.hazelcast.cp.internal.datastructures.atomicref.operation

Methods in com.hazelcast.cp.internal.datastructures.atomicref.operation with parameters of type CPGroupId

Modifier and Type	Method and Description
Object	ApplyOp.run(CPGroupId groupId, long commitIndex)
Object	ContainsOp.run(CPGroupId groupId, long commitIndex)
Object	CompareAndSetOp.run(CPGroupId groupId, long commitIndex)
Object	GetOp.run(CPGroupId groupId, long commitIndex)
Object	SetOp.run(CPGroupId groupId, long commitIndex)

Uses of CPGroupId in com.hazelcast.cp.internal.datastructures.atomicref.proxy

Methods in com.hazelcast.cp.internal.datastructures.atomicref.proxy that return CPGroupId

Modifier and Type	Method and Description
CPGroupId	RaftAtomicRefProxy.getGroupId()

Uses of CPGroupId in com.hazelcast.cp.internal.datastructures.countdownlatch

Methods in com.hazelcast.cp.internal.datastructures.countdownlatch with parameters of type CPGroupId

Modifier and Type	Method and Description
boolean	RaftCountDownLatchService.await(CPGroupId groupId, String name, long commitIndex, UUID invocationUid, long timeoutMillis)
int	RaftCountDownLatchService.countDown(CPGroupId groupId, String name, UUID invocationUuid, int expectedRound)
protected RaftCountDownLatchRegistry	RaftCountDownLatchService.createNewRegistry(CPGroupId groupId)
protected RaftCountDownLatch	RaftCountDownLatchRegistry.createNewResource(CPGroupId groupId, String name)
int	RaftCountDownLatchService.getRemainingCount(CPGroupId groupId, String name)
int	RaftCountDownLatchService.getRound(CPGroupId groupId, String name)
boolean	RaftCountDownLatchService.trySetCount(CPGroupId groupId, String name, int count)

Uses of CPGroupId in com.hazelcast.cp.internal.datastructures.countdownlatch.operation

Methods in com.hazelcast.cp.internal.datastructures.countdownlatch.operation with parameters of type CPGroupId

Modifier and Type	Method and Description
Object	CountDownOp.run(CPGroupId groupId, long commitIndex)
Object	AwaitOp.run(CPGroupId groupId, long commitIndex)
Object	GetRoundOp.run(CPGroupId groupId, long commitIndex)
Object	GetCountOp.run(CPGroupId groupId, long commitIndex)
Object	TrySetCountOp.run(CPGroupId groupId, long commitIndex)

Uses of CPGroupId in com.hazelcast.cp.internal.datastructures.countdownlatch.proxy

Methods in com.hazelcast.cp.internal.datastructures.countdownlatch.proxy that return CPGroupId

Modifier and Type	Method and Description
CPGroupId	RaftCountDownLatchProxy.getGroupId()

Uses of CPGroupId in com.hazelcast.cp.internal.datastructures.lock

Methods in com.hazelcast.cp.internal.datastructures.lock with parameters of type CPGroupId

Modifier and Type	Method and Description
AcquireResult	RaftLockService.acquire(CPGroupId groupId, long commitIndex, String name, LockEndpoint endpoint, UUID invocationUid)
protected com.hazelcast.cp.internal.datastructures.lock.RaftLockRegistry	RaftLockService.createNewRegistry(CPGroupId groupId)
RaftLockOwnershipState	RaftLockService.getLockOwnershipState(CPGroupId groupId, String name)
boolean	RaftLockService.release(CPGroupId groupId, long commitIndex, String name, LockEndpoint endpoint, UUID invocationUid)
AcquireResult	RaftLockService.tryAcquire(CPGroupId groupId, long commitIndex, String name, LockEndpoint endpoint, UUID invocationUid, long timeoutMs)

Uses of CPGroupId in com.hazelcast.cp.internal.datastructures.lock.operation

Methods in com.hazelcast.cp.internal.datastructures.lock.operation with parameters of type CPGroupId

Modifier and Type	Method and Description
Object	GetLockOwnershipStateOp.run(CPGroupId groupId, long commitIndex)
Object	LockOp.run(CPGroupId groupId, long commitIndex)
Object	TryLockOp.run(CPGroupId groupId, long commitIndex)
Object	UnlockOp.run(CPGroupId groupId, long commitIndex)

Uses of CPGroupId in com.hazelcast.cp.internal.datastructures.semaphore

Methods in com.hazelcast.cp.internal.datastructures.semaphore with parameters of type CPGroupId

Modifier and Type	Method and Description
boolean	RaftSemaphoreService.acquirePermits(CPGroupId groupId, long commitIndex, String name, SemaphoreEndpoint endpoint, UUID invocationUid, int permits, long timeoutMs)
int	RaftSemaphoreService.availablePermits(CPGroupId groupId, String name)
boolean	RaftSemaphoreService.changePermits(CPGroupId groupId, long commitIndex, String name, SemaphoreEndpoint endpoint, UUID invocationUid, int permits)
protected RaftSemaphoreRegistry	RaftSemaphoreService.createNewRegistry(CPGroupId groupId)
protected RaftSemaphore	RaftSemaphoreRegistry.createNewResource(CPGroupId groupId, String name)
int	RaftSemaphoreService.drainPermits(CPGroupId groupId, String name, long commitIndex, SemaphoreEndpoint endpoint, UUID invocationUid)
boolean	RaftSemaphoreService.initSemaphore(CPGroupId groupId, String name, int permits)
void	RaftSemaphoreService.releasePermits(CPGroupId groupId, long commitIndex, String name, SemaphoreEndpoint endpoint, UUID invocationUid, int permits)

Uses of CPGroupId in com.hazelcast.cp.internal.datastructures.semaphore.operation

Methods in com.hazelcast.cp.internal.datastructures.semaphore.operation with parameters of type CPGroupId

Modifier and Type	Method and Description
Object	ReleasePermitsOp.run(CPGroupId groupId, long commitIndex)
Object	AvailablePermitsOp.run(CPGroupId groupId, long commitIndex)
Object	DrainPermitsOp.run(CPGroupId groupId, long commitIndex)
Object	InitSemaphoreOp.run(CPGroupId groupId, long commitIndex)
Object	ChangePermitsOp.run(CPGroupId groupId, long commitIndex)
Object	AcquirePermitsOp.run(CPGroupId groupId, long commitIndex)

Uses of CPGroupId in com.hazelcast.cp.internal.datastructures.spi

Methods in com.hazelcast.cp.internal.datastructures.spi with parameters of type CPGroupId

Modifier and Type	Method and Description
boolean	RaftRemoteService.destroyRaftObject(CPGroupId groupId, String objectName) Destroys the given Raft data structure on the Raft group.

Uses of CPGroupId in com.hazelcast.cp.internal.datastructures.spi.blocking

Fields in com.hazelcast.cp.internal.datastructures.spi.blocking declared as CPGroupId

Modifier and Type	Field and Description
protected CPGroupId	BlockingResource.groupId
protected CPGroupId	ResourceRegistry.groupId

Methods in com.hazelcast.cp.internal.datastructures.spi.blocking that return CPGroupId

Modifier and Type	Method and Description
CPGroupId	BlockingResource.getGroupId()
CPGroupId	ResourceRegistry.getGroupId()

Methods in com.hazelcast.cp.internal.datastructures.spi.blocking with parameters of type CPGroupId

Modifier and Type	Method and Description
protected abstract RR	AbstractBlockingService.createNewRegistry(CPGroupId groupId) Creates a registry for the given Raft group.
protected abstract R	ResourceRegistry.createNewResource(CPGroupId groupId, String name)
boolean	AbstractBlockingService.destroyRaftObject(CPGroupId groupId, String name)
void	AbstractBlockingService.expireWaitKeys(CPGroupId groupId, Collection<Tuple2<String,UUID>> keys)
Collection<Long>	AbstractBlockingService.getAttachedSessions(CPGroupId groupId)
protected RR	AbstractBlockingService.getOrInitRegistry(CPGroupId groupId)
RR	AbstractBlockingService.getRegistryOrNull(CPGroupId groupId)
protected void	AbstractBlockingService.heartbeatSession(CPGroupId groupId, long sessionId)
protected void	AbstractBlockingService.notifyWaitKeys(CPGroupId groupId, String name, Collection<W> keys, Object result)
void	AbstractBlockingService.onGroupDestroy(CPGroupId groupId)
void	AbstractBlockingService.onSessionClose(CPGroupId groupId, long sessionId)
void	AbstractBlockingService.restoreSnapshot(CPGroupId groupId, long commitIndex, RR registry)
protected void	AbstractBlockingService.scheduleTimeout(CPGroupId groupId, String name, UUID invocationUid, long timeoutMs)
RR	AbstractBlockingService.takeSnapshot(CPGroupId groupId, long commitIndex)

Constructors in com.hazelcast.cp.internal.datastructures.spi.blocking with parameters of type CPGroupId

Constructor and Description
BlockingResource(CPGroupId groupId, String name)
ResourceRegistry(CPGroupId groupId)

Uses of CPGroupId in com.hazelcast.cp.internal.datastructures.spi.blocking.operation

Methods in com.hazelcast.cp.internal.datastructures.spi.blocking.operation with parameters of type CPGroupId

Modifier and Type	Method and Description
Object	ExpireWaitKeysOp.run(CPGroupId groupId, long commitIndex)

Uses of CPGroupId in com.hazelcast.cp.internal.datastructures.spi.operation

Methods in com.hazelcast.cp.internal.datastructures.spi.operation with parameters of type CPGroupId

Modifier and Type	Method and Description
Object	DestroyRaftObjectOp.run(CPGroupId groupId, long commitIndex)

Uses of CPGroupId in com.hazelcast.cp.internal.operation

Constructors in com.hazelcast.cp.internal.operation with parameters of type CPGroupId

Constructor and Description
ChangeRaftGroupMembershipOp(CPGroupId groupId, long membersCommitIndex, CPMemberInfo member, MembershipChangeMode membershipChangeMode)
DefaultRaftReplicateOp(CPGroupId groupId, RaftOp raftOp)
DestroyRaftGroupOp(CPGroupId groupId)
RaftQueryOp(CPGroupId groupId, RaftOp raftOp, QueryPolicy queryPolicy)

Uses of CPGroupId in com.hazelcast.cp.internal.operation.integration

Fields in com.hazelcast.cp.internal.operation.integration declared as CPGroupId

Modifier and Type	Field and Description
protected CPGroupId	AsyncRaftOp.groupId

Constructors in com.hazelcast.cp.internal.operation.integration with parameters of type CPGroupId

Constructor and Description
AppendFailureResponseOp(CPGroupId groupId, AppendFailureResponse appendResponse)
AppendRequestOp(CPGroupId groupId, AppendRequest appendRequest)
AppendSuccessResponseOp(CPGroupId groupId, AppendSuccessResponse appendResponse)
InstallSnapshotOp(CPGroupId groupId, InstallSnapshot installSnapshot)
PreVoteRequestOp(CPGroupId groupId, PreVoteRequest voteRequest)
PreVoteResponseOp(CPGroupId groupId, PreVoteResponse voteResponse)
VoteRequestOp(CPGroupId groupId, VoteRequest voteRequest)
VoteResponseOp(CPGroupId groupId, VoteResponse voteResponse)

Uses of CPGroupId in com.hazelcast.cp.internal.raft

Methods in com.hazelcast.cp.internal.raft with parameters of type CPGroupId

Modifier and Type	Method and Description
void	SnapshotAwareService.restoreSnapshot(CPGroupId groupId, long commitIndex, T snapshot) Restores the snapshot for specified CPGroupId.
T	SnapshotAwareService.takeSnapshot(CPGroupId groupId, long commitIndex) Creates a snapshot for specified CPGroupId.

Uses of CPGroupId in com.hazelcast.cp.internal.raft.impl

Methods in com.hazelcast.cp.internal.raft.impl that return CPGroupId

Modifier and Type	Method and Description
CPGroupId	RaftNodeImpl.getGroupId()
CPGroupId	RaftNode.getGroupId() Returns the groupId which this node belongs to.

Constructors in com.hazelcast.cp.internal.raft.impl with parameters of type CPGroupId

Constructor and Description
RaftNodeImpl(CPGroupId groupId, Endpoint localMember, Collection<Endpoint> members, RaftAlgorithmConfig raftAlgorithmConfig, RaftIntegration raftIntegration)

Uses of CPGroupId in com.hazelcast.cp.internal.raft.impl.state

Methods in com.hazelcast.cp.internal.raft.impl.state that return CPGroupId

Modifier and Type	Method and Description
CPGroupId	RaftState.groupId()

Constructors in com.hazelcast.cp.internal.raft.impl.state with parameters of type CPGroupId

Constructor and Description
RaftState(CPGroupId groupId, Endpoint localEndpoint, Collection<Endpoint> endpoints, int logCapacity)

Uses of CPGroupId in com.hazelcast.cp.internal.raftop

Methods in com.hazelcast.cp.internal.raftop with parameters of type CPGroupId

Modifier and Type	Method and Description
Object	NotifyTermChangeOp.run(CPGroupId groupId, long commitIndex)
Object	GetInitialRaftGroupMembersIfCurrentGroupMemberOp.run(CPGroupId groupId, long commitIndex)

Uses of CPGroupId in com.hazelcast.cp.internal.raftop.metadata

Methods in com.hazelcast.cp.internal.raftop.metadata with parameters of type CPGroupId

Modifier and Type	Method and Description
Object	MetadataRaftGroupOp.run(CPGroupId groupId, long commitIndex)

Constructors in com.hazelcast.cp.internal.raftop.metadata with parameters of type CPGroupId

Constructor and Description
CreateRaftNodeOp(CPGroupId groupId, Collection<CPMemberInfo> initialMembers)
GetRaftGroupOp(CPGroupId targetGroupId)
TriggerDestroyRaftGroupOp(CPGroupId targetGroupId)

Constructor parameters in com.hazelcast.cp.internal.raftop.metadata with type arguments of type CPGroupId

Constructor and Description
CompleteDestroyRaftGroupsOp(Set<CPGroupId> groupIds)
CompleteRaftGroupMembershipChangesOp(Map<CPGroupId,Tuple2<Long,Long>> changedGroups)
DestroyRaftNodesOp(Collection<CPGroupId> groupIds)

Uses of CPGroupId in com.hazelcast.cp.internal.raftop.snapshot

Methods in com.hazelcast.cp.internal.raftop.snapshot with parameters of type CPGroupId

Modifier and Type	Method and Description
Object	RestoreSnapshotOp.run(CPGroupId groupId, long commitIndex)

Uses of CPGroupId in com.hazelcast.cp.internal.session

Methods in com.hazelcast.cp.internal.session with parameters of type CPGroupId

Modifier and Type	Method and Description
void	RaftSessionService.closeInactiveSessions(CPGroupId groupId, Collection<Long> inactiveSessions)
boolean	RaftSessionService.closeSession(CPGroupId groupId, long sessionId)
SessionResponse	RaftSessionService.createNewSession(CPGroupId groupId, Address endpoint, String endpointName, CPSession.CPSessionOwnerType endpointType, long creationTime)
void	RaftSessionService.expireSessions(CPGroupId groupId, Collection<Tuple2<Long,Long>> sessionsToExpire)
long	RaftSessionService.generateThreadId(CPGroupId groupId)
Collection<Long>	SessionAwareService.getAttachedSessions(CPGroupId groupId) Returns a collection of session ids that this service has attached some resources.
Collection<CPSession>	RaftSessionService.getSessionsLocally(CPGroupId groupId)
void	RaftSessionService.heartbeat(CPGroupId groupId, long sessionId)
void	SessionAccessor.heartbeat(CPGroupId groupId, long sessionId) Performs a heartbeat for the given session id in the Raft group.
boolean	RaftSessionService.isActive(CPGroupId groupId, long sessionId)
boolean	SessionAccessor.isActive(CPGroupId groupId, long sessionId) Checks if there is an active session with the given id in the Raft group
void	RaftSessionService.onGroupDestroy(CPGroupId groupId)
void	RaftSessionService.onNewTermCommit(CPGroupId groupId, long commitIndex)
void	SessionAwareService.onSessionClose(CPGroupId groupId, long sessionId) Called when a session is closed.
void	RaftSessionService.restoreSnapshot(CPGroupId groupId, long commitIndex, com.hazelcast.cp.internal.session.RaftSessionRegistry registry)
com.hazelcast.cp.internal.session.RaftSessionRegistry	RaftSessionService.takeSnapshot(CPGroupId groupId, long commitIndex)

Uses of CPGroupId in com.hazelcast.cp.internal.session.operation

Methods in com.hazelcast.cp.internal.session.operation with parameters of type CPGroupId

Modifier and Type	Method and Description
Object	CloseSessionOp.run(CPGroupId groupId, long commitIndex)
Object	GetSessionsOp.run(CPGroupId groupId, long commitIndex)
Object	HeartbeatSessionOp.run(CPGroupId groupId, long commitIndex)
Object	ExpireSessionsOp.run(CPGroupId groupId, long commitIndex)
Object	GenerateThreadIdOp.run(CPGroupId groupId, long commitIndex)
Object	CreateSessionOp.run(CPGroupId groupId, long commitIndex)
Object	CloseInactiveSessionsOp.run(CPGroupId groupId, long commitIndex)

Uses of CPGroupId in com.hazelcast.cp.lock

Methods in com.hazelcast.cp.lock that return CPGroupId

Modifier and Type	Method and Description
CPGroupId	FencedLock.getGroupId() Returns id of the CP group that runs this FencedLock instance

Uses of CPGroupId in com.hazelcast.spi.impl.operationservice.impl

Constructors in com.hazelcast.spi.impl.operationservice.impl with parameters of type CPGroupId

Constructor and Description
RaftInvocation(com.hazelcast.spi.impl.operationservice.impl.Invocation.Context context, RaftInvocationContext raftInvocationContext, CPGroupId groupId, Operation op, int retryCount, long retryPauseMillis, long callTimeoutMillis)