com.hazelcast.cp.internal

Class RaftInvocationManager

java.lang.Object

com.hazelcast.cp.internal.RaftInvocationManager

public class RaftInvocationManager
extends Object

Performs invocations to create & destroy Raft groups, commits RaftOp and runs queries on Raft groups.

Method Summary

Modifier and Type	Method and Description
InternalCompletableFuture<RaftGroupId>	createRaftGroup(String groupName)
InternalCompletableFuture<RaftGroupId>	createRaftGroup(String groupName, int groupSize)
InternalCompletableFuture<Object>	destroy(CPGroupId groupId)
RaftInvocationContext	getRaftInvocationContext()
<T> InternalCompletableFuture<T>	invoke(CPGroupId groupId, RaftOp raftOp)
<T> InternalCompletableFuture<T>	invoke(CPGroupId groupId, RaftOp raftOp, boolean deserializeResponse)
<T> InternalCompletableFuture<T>	query(CPGroupId groupId, RaftOp raftOp, QueryPolicy queryPolicy)
<T> InternalCompletableFuture<T>	query(CPGroupId groupId, RaftOp raftOp, QueryPolicy queryPolicy, boolean deserializeResponse)
<T> InternalCompletableFuture<T>	queryLocally(CPGroupId groupId, RaftOp raftOp, QueryPolicy queryPolicy)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

createRaftGroup

public InternalCompletableFuture<RaftGroupId> createRaftGroup(String groupName)

createRaftGroup

public InternalCompletableFuture<RaftGroupId> createRaftGroup(String groupName,
                                                              int groupSize)

invoke

public <T> InternalCompletableFuture<T> invoke(CPGroupId groupId,
                                               RaftOp raftOp)

invoke

public <T> InternalCompletableFuture<T> invoke(CPGroupId groupId,
                                               RaftOp raftOp,
                                               boolean deserializeResponse)

query

public <T> InternalCompletableFuture<T> query(CPGroupId groupId,
                                              RaftOp raftOp,
                                              QueryPolicy queryPolicy)

query

public <T> InternalCompletableFuture<T> query(CPGroupId groupId,
                                              RaftOp raftOp,
                                              QueryPolicy queryPolicy,
                                              boolean deserializeResponse)

queryLocally

public <T> InternalCompletableFuture<T> queryLocally(CPGroupId groupId,
                                                     RaftOp raftOp,
                                                     QueryPolicy queryPolicy)

destroy

public InternalCompletableFuture<Object> destroy(CPGroupId groupId)

getRaftInvocationContext

public RaftInvocationContext getRaftInvocationContext()