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
ICompletableFuture<RaftGroupId>	createRaftGroup(String groupName)
ICompletableFuture<RaftGroupId>	createRaftGroup(String groupName, int groupSize)
InternalCompletableFuture<Object>	destroy(CPGroupId groupId)
RaftInvocationContext	getRaftInvocationContext()
<T> InternalCompletableFuture<T>	invoke(CPGroupId groupId, RaftOp raftOp)
<T> InternalCompletableFuture<T>	query(CPGroupId groupId, RaftOp raftOp, QueryPolicy queryPolicy)
<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 ICompletableFuture<RaftGroupId> createRaftGroup(String groupName)

createRaftGroup

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

invoke

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

query

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

queryLocally

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

destroy

public InternalCompletableFuture<Object> destroy(CPGroupId groupId)

getRaftInvocationContext

public RaftInvocationContext getRaftInvocationContext()