com.alipay.sofa.jraft.rpc.impl

Class BoltRaftRpcFactory

java.lang.Object

com.alipay.sofa.jraft.rpc.impl.BoltRaftRpcFactory

All Implemented Interfaces:

RaftRpcFactory

@SPI
public class BoltRaftRpcFactory
extends Object
implements RaftRpcFactory

Author:

jiachun.fjc

Nested Class Summary

Nested classes/interfaces inherited from interface com.alipay.sofa.jraft.rpc.RaftRpcFactory

RaftRpcFactory.ConfigHelper<T>

Field Summary

Fields inherited from interface com.alipay.sofa.jraft.rpc.RaftRpcFactory

DEFAULT

Constructor Summary

Constructors

Constructor and Description
BoltRaftRpcFactory()

Method Summary

Modifier and Type	Method and Description
RpcClient	createRpcClient(RaftRpcFactory.ConfigHelper<RpcClient> helper) Creates a raft RPC client.
RpcServer	createRpcServer(Endpoint endpoint, RaftRpcFactory.ConfigHelper<RpcServer> helper) Creates a raft RPC server.
void	ensurePipeline() Ensure RPC framework supports pipeline.
void	registerProtobufSerializer(String className, Object... args) Register serializer with class name.

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.alipay.sofa.jraft.rpc.RaftRpcFactory

createRpcClient, createRpcServer, defaultJRaftClientConfigHelper, defaultJRaftServerConfigHelper, getRpcResponseFactory, isReplicatorPipelineEnabled

Constructor Detail

BoltRaftRpcFactory

public BoltRaftRpcFactory()

Method Detail

registerProtobufSerializer

public void registerProtobufSerializer(String className,
                                       Object... args)

Description copied from interface: RaftRpcFactory

Register serializer with class name.

Specified by:

registerProtobufSerializer in interface RaftRpcFactory

Parameters:

className - class name

args - extended parameters, different implementers may need different parameters, the order of parameters need a convention

createRpcClient

public RpcClient createRpcClient(RaftRpcFactory.ConfigHelper<RpcClient> helper)

Description copied from interface: RaftRpcFactory

Creates a raft RPC client.

Specified by:

createRpcClient in interface RaftRpcFactory

Parameters:

helper - config helper for rpc client impl

Returns:

a new rpc client instance

createRpcServer

public RpcServer createRpcServer(Endpoint endpoint,
                                 RaftRpcFactory.ConfigHelper<RpcServer> helper)

Description copied from interface: RaftRpcFactory

Creates a raft RPC server.

Specified by:

createRpcServer in interface RaftRpcFactory

Parameters:

endpoint - server address to bind

helper - config helper for rpc server impl

Returns:

a new rpc server instance

ensurePipeline

public void ensurePipeline()

Description copied from interface: RaftRpcFactory

Ensure RPC framework supports pipeline.

Specified by:

ensurePipeline in interface RaftRpcFactory