Package | Description |
---|---|
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.operation |
Contains operations for the Raft Invocation SPI
|
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.task |
Contains tasks running on leader or leader-candidates.
|
Modifier and Type | Method and Description |
---|---|
<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 | Method and Description |
---|---|
long |
RaftAtomicLongProxy.localGet(QueryPolicy queryPolicy) |
ICompletableFuture<Long> |
RaftAtomicLongProxy.localGetAsync(QueryPolicy queryPolicy) |
Constructor and Description |
---|
RaftQueryOp(CPGroupId groupId,
RaftOp raftOp,
QueryPolicy queryPolicy) |
Modifier and Type | Method and Description |
---|---|
static QueryPolicy |
QueryPolicy.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static QueryPolicy[] |
QueryPolicy.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
ICompletableFuture |
RaftNodeImpl.query(Object operation,
QueryPolicy queryPolicy) |
ICompletableFuture |
RaftNode.query(Object operation,
QueryPolicy queryPolicy)
Executes the given operation on Raft group depending
on the
QueryPolicy |
Constructor and Description |
---|
QueryTask(RaftNodeImpl raftNode,
Object operation,
QueryPolicy policy,
SimpleCompletableFuture resultFuture) |
Copyright © 2020 Hazelcast, Inc.. All Rights Reserved.