Package | Description |
---|---|
com.hazelcast.cp.internal.datastructures.atomiclong.operation |
Contains operations for the Raft-based
IAtomicLong implementation |
com.hazelcast.cp.internal.datastructures.atomicref.operation |
Contains operations for the Raft-based
IAtomicReference implementation |
com.hazelcast.cp.internal.datastructures.countdownlatch.operation |
Contains operations for the Raft-based
ICountDownLatch implementation |
com.hazelcast.cp.internal.datastructures.lock.operation |
Contains operations for the Raft-based
ILock implementation |
com.hazelcast.cp.internal.datastructures.semaphore.operation |
Contains operations for the Raft-based
ISemaphore implementation |
com.hazelcast.cp.internal.operation |
Contains operations for the Raft Invocation SPI
|
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.session.operation |
Contains operations that are internally used by the CP session API
|
Modifier and Type | Class and Description |
---|---|
class |
AddAndGetOp
Operation for
IAtomicLong.addAndGet(long) |
class |
GetAndAddOp
Operation for
IAtomicLong.getAndAdd(long) (long, long)}
and IAtomicLong.get() |
class |
LocalGetOp
Operation for
RaftAtomicLongProxy.localGet(QueryPolicy) |
Modifier and Type | Class and Description |
---|---|
class |
ContainsOp
Operation for
IAtomicReference.contains(Object) |
class |
GetOp
Operation for
IAtomicReference.get() |
Modifier and Type | Class and Description |
---|---|
class |
AwaitOp
Operation for
ICountDownLatch.await(long, TimeUnit) |
class |
CountDownOp
Operation for
ICountDownLatch.countDown() |
class |
GetCountOp
Operation for
ICountDownLatch.getCount() |
class |
GetRoundOp
Operation used by
ICountDownLatch.countDown() |
Modifier and Type | Class and Description |
---|---|
class |
GetLockOwnershipStateOp |
class |
LockOp
Operation for
FencedLock.lock() |
class |
TryLockOp
Operation for
FencedLock.lock() |
class |
UnlockOp
Operation for
FencedLock.unlock() |
Modifier and Type | Class and Description |
---|---|
class |
AcquirePermitsOp
Operation for
ISemaphore.acquire() |
class |
AvailablePermitsOp
Operation for
ISemaphore.availablePermits() |
class |
ChangePermitsOp
Operation for
ISemaphore.increasePermits(int)
and ISemaphore.reducePermits(int) |
class |
DrainPermitsOp
Operation for
ISemaphore.drainPermits() } |
class |
InitSemaphoreOp
Operation for
ISemaphore.init(int) |
class |
ReleasePermitsOp
Operation for
ISemaphore.release() |
Modifier and Type | Class and Description |
---|---|
class |
ChangeRaftGroupMembershipOp
Replicates a membership change operation to a Raft group.
|
class |
DefaultRaftReplicateOp
The operation used by
RaftInvocationManager to replicate a given
RaftOp to leader of the target Raft group. |
class |
DestroyRaftGroupOp
Replicates a
DestroyRaftGroupCmd to a Raft group. |
class |
RaftQueryOp
The operation that passes a query to leader or a follower of a Raft group.
|
Modifier and Type | Class and Description |
---|---|
class |
GetInitialRaftGroupMembersIfCurrentGroupMemberOp
When a CP member is added to a Raft group, a new member list is committed to
the Raft group first.
|
Modifier and Type | Class and Description |
---|---|
class |
AddCPMemberOp
A
RaftOp that adds a new CP member to the CP subsystem. |
class |
CompleteDestroyRaftGroupsOp
Marks the given Raft groups as
CPGroup.CPGroupStatus.DESTROYED
and notifies its CP members |
class |
CompleteRaftGroupMembershipChangesOp
Commits the given successfully-applied membership changes to the Metadata
Raft group.
|
class |
CreateRaftGroupOp
Creates a new Raft group with the given name and the members and returns
its ID.
|
class |
ForceDestroyRaftGroupOp
If a Raft node loses its majority completely, its remaining members cannot
leave the CP subsystem gracefully.
|
class |
GetActiveCPMembersOp
Returns the current active CP members in the Metadata group.
|
class |
GetActiveRaftGroupByNameOp
Returns an active CP group by its name
|
class |
GetActiveRaftGroupIdsOp
Returns ids of the active Raft groups.
|
class |
GetDestroyingRaftGroupIdsOp
Returns ids of the Raft groups that are currently being destroyed.
|
class |
GetMembershipChangeScheduleOp
Returns the list of pending membership changes that will be orchestrated by
the leader node of the Metadata group.
|
class |
GetRaftGroupIdsOp
Returns ids of the Raft groups.
|
class |
GetRaftGroupOp
Returns information about the queried Raft group.
|
class |
InitMetadataRaftGroupOp
Used during cluster startup by CP members to commit their CP member list
to the Metadata group.
|
class |
RemoveCPMemberOp
When a CP member is shutting down gracefully, or a crashed CP member is
removed from the CP subsystem via
RaftService.removeCPMember(String) , this operation is
committed to the Metadata Raft group. |
class |
TriggerDestroyRaftGroupOp
Initiates the destroy process for the given Raft group.
|
Modifier and Type | Class and Description |
---|---|
class |
CloseInactiveSessionsOp
Closes inactive sessions.
|
class |
CloseSessionOp
Closes the given session on the Raft group and notifies services
via the
SessionAwareService interface. |
class |
CreateSessionOp
Creates a new session for the given endpoint and returns its id.
|
class |
ExpireSessionsOp
Expires sessions that do have not committed any heartbeat for
CPSubsystemConfig.getSessionTimeToLiveSeconds() seconds. |
class |
GenerateThreadIdOp
Operation for generating a cluster-wide unique thread id for the caller.
|
class |
GetSessionsOp
Returns the collection of active sessions in the given Raft group
|
class |
HeartbeatSessionOp
Pushes given session's heartbeat timeout forward.
|
Copyright © 2022 Hazelcast, Inc.. All Rights Reserved.