Package | Description |
---|---|
com.hazelcast.cp.internal |
Contains implementation of the CP subsystem
|
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.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.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.operation |
Contains operations that are internally used by the CP session API
|
Modifier and Type | Method and Description |
---|---|
RaftOp |
RaftOp.setNodeEngine(NodeEngine nodeEngine) |
Modifier and Type | Method and Description |
---|---|
<T> InternalCompletableFuture<T> |
RaftInvocationManager.invoke(CPGroupId groupId,
RaftOp raftOp) |
<T> InternalCompletableFuture<T> |
RaftInvocationManager.query(CPGroupId groupId,
RaftOp raftOp,
QueryPolicy queryPolicy) |
<T> InternalCompletableFuture<T> |
RaftInvocationManager.queryLocally(CPGroupId groupId,
RaftOp raftOp,
QueryPolicy queryPolicy) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractAtomicLongOp
Base class for operations of Raft-based atomic long
|
class |
AddAndGetOp
Operation for
IAtomicLong.addAndGet(long) |
class |
AlterOp
Operation for
IAtomicLong.alter(IFunction) |
class |
ApplyOp<R>
Operation for
IAtomicLong.apply(IFunction) |
class |
CompareAndSetOp
Operation for
IAtomicLong.compareAndSet(long, long) |
class |
GetAndAddOp
Operation for
IAtomicLong.getAndAdd(long) (long, long)}
and IAtomicLong.get() |
class |
GetAndSetOp
Operation for
IAtomicLong.getAndSet(long) |
class |
LocalGetOp
Operation for
RaftAtomicLongProxy.localGet(QueryPolicy) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractAtomicRefOp
Base class for operations of Raft-based atomic reference
|
class |
ContainsOp
Operation for
IAtomicReference.contains(Object) |
class |
GetOp
Operation for
IAtomicReference.get() |
class |
SetOp
Operation for
IAtomicReference.set(Object) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractCountDownLatchOp
Base class for operations of Raft-based count down latch
|
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() |
class |
TrySetCountOp
Operation for
ICountDownLatch.trySetCount(int) |
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 |
ExpireWaitKeysOp
Expires the given wait keys on the given blocking service.
|
Modifier and Type | Class and Description |
---|---|
class |
DestroyRaftObjectOp
Destroys the distributed object with the given name
on the requested Raft group
|
Constructor and Description |
---|
DefaultRaftReplicateOp(CPGroupId groupId,
RaftOp op) |
RaftQueryOp(CPGroupId groupId,
RaftOp raftOp,
QueryPolicy queryPolicy) |
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.
|
class |
NotifyTermChangeOp
When leader of a Raft group changes, this operation is automatically
committed to the Raft group so that related services can perform some
actions.
|
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 |
MetadataRaftGroupOp
Base class for the
RaftOp impls that are committed 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 |
RestoreSnapshotOp
RaftOp to restore snapshot using related
SnapshotAwareService.takeSnapshot(CPGroupId, long) . |
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 © 2020 Hazelcast, Inc.. All Rights Reserved.