com.alipay.sofa.jraft.rpc

Class RaftRpcServerFactory

java.lang.Object

com.alipay.sofa.jraft.rpc.RaftRpcServerFactory

public class RaftRpcServerFactory
extends Object

Raft RPC server factory.

Author:

boyan (boyan@alibaba-inc.com), jiachun.fjc

Constructor Summary

Constructors

Constructor and Description
RaftRpcServerFactory()

Method Summary

Modifier and Type	Method and Description
static void	addRaftRequestProcessors(RpcServer rpcServer) Adds RAFT and CLI service request processors with default executor.
static void	addRaftRequestProcessors(RpcServer rpcServer, Executor raftExecutor, Executor cliExecutor) Adds RAFT and CLI service request processors.
static void	addRaftRequestProcessors(RpcServer rpcServer, Executor raftExecutor, Executor cliExecutor, Executor pingExecutor) Adds RAFT and CLI service request processors.
static RpcServer	createAndStartRaftRpcServer(Endpoint endpoint) Creates a raft RPC server and starts it.
static RpcServer	createAndStartRaftRpcServer(Endpoint endpoint, Executor raftExecutor, Executor cliExecutor) Creates a raft RPC server and starts it.
static RpcServer	createRaftRpcServer(Endpoint endpoint) Creates a raft RPC server with default request executors.
static RpcServer	createRaftRpcServer(Endpoint endpoint, Executor raftExecutor, Executor cliExecutor) Creates a raft RPC server with executors to handle requests.
static RpcServer	createRaftRpcServer(Endpoint endpoint, Executor raftExecutor, Executor cliExecutor, Executor pingExecutor) Creates a raft RPC server with executors to handle requests.

Methods inherited from class java.lang.Object

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

Constructor Detail

RaftRpcServerFactory

public RaftRpcServerFactory()

Method Detail

createRaftRpcServer

public static RpcServer createRaftRpcServer(Endpoint endpoint)

Creates a raft RPC server with default request executors.

Parameters:

endpoint - server address to bind

Returns:

a rpc server instance

createRaftRpcServer

public static RpcServer createRaftRpcServer(Endpoint endpoint,
                                            Executor raftExecutor,
                                            Executor cliExecutor)

Creates a raft RPC server with executors to handle requests.

Parameters:

endpoint - server address to bind

raftExecutor - executor to handle RAFT requests.

cliExecutor - executor to handle CLI service requests.

Returns:

a rpc server instance

createRaftRpcServer

public static RpcServer createRaftRpcServer(Endpoint endpoint,
                                            Executor raftExecutor,
                                            Executor cliExecutor,
                                            Executor pingExecutor)

Creates a raft RPC server with executors to handle requests.

Parameters:

endpoint - server address to bind

raftExecutor - executor to handle RAFT requests.

cliExecutor - executor to handle CLI service requests.

pingExecutor - executor to handle ping requests.

Returns:

a rpc server instance

addRaftRequestProcessors

public static void addRaftRequestProcessors(RpcServer rpcServer)

Adds RAFT and CLI service request processors with default executor.

Parameters:

rpcServer - rpc server instance

addRaftRequestProcessors

public static void addRaftRequestProcessors(RpcServer rpcServer,
                                            Executor raftExecutor,
                                            Executor cliExecutor)

Adds RAFT and CLI service request processors.

Parameters:

rpcServer - rpc server instance

raftExecutor - executor to handle RAFT requests.

cliExecutor - executor to handle CLI service requests.

addRaftRequestProcessors

public static void addRaftRequestProcessors(RpcServer rpcServer,
                                            Executor raftExecutor,
                                            Executor cliExecutor,
                                            Executor pingExecutor)

Adds RAFT and CLI service request processors.

Parameters:

rpcServer - rpc server instance

raftExecutor - executor to handle RAFT requests.

cliExecutor - executor to handle CLI service requests.

pingExecutor - executor to handle ping requests.

createAndStartRaftRpcServer

public static RpcServer createAndStartRaftRpcServer(Endpoint endpoint)

Creates a raft RPC server and starts it.

Parameters:

endpoint - server address to bind

Returns:

a rpc server instance

createAndStartRaftRpcServer

public static RpcServer createAndStartRaftRpcServer(Endpoint endpoint,
                                                    Executor raftExecutor,
                                                    Executor cliExecutor)

Creates a raft RPC server and starts it.

Parameters:

endpoint - server address to bind

raftExecutor - executor to handle RAFT requests.

cliExecutor - executor to handle CLI service requests.

Returns:

a rpc server instance