com.alipay.sofa.jraft.rpc.impl

Class GrpcRaftRpcFactory

java.lang.Object

com.alipay.sofa.jraft.rpc.impl.GrpcRaftRpcFactory

All Implemented Interfaces:

RaftRpcFactory

@SPI(priority=1)
public class GrpcRaftRpcFactory
extends Object
implements RaftRpcFactory

Author:

nicholas.jxf, 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
GrpcRaftRpcFactory()

Method Summary

Modifier and Type	Method and Description
RpcClient	createRpcClient(RaftRpcFactory.ConfigHelper<RpcClient> helper)
RpcServer	createRpcServer(Endpoint endpoint, RaftRpcFactory.ConfigHelper<RpcServer> helper)
MarshallerRegistry	getMarshallerRegistry()
RpcResponseFactory	getRpcResponseFactory()
boolean	isReplicatorPipelineEnabled()
void	registerProtobufSerializer(String className, Object... args)

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, ensurePipeline

Constructor Detail

GrpcRaftRpcFactory

public GrpcRaftRpcFactory()

Method Detail

registerProtobufSerializer

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

Specified by:

registerProtobufSerializer in interface RaftRpcFactory

createRpcClient

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

Specified by:

createRpcClient in interface RaftRpcFactory

createRpcServer

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

Specified by:

createRpcServer in interface RaftRpcFactory

getRpcResponseFactory

public RpcResponseFactory getRpcResponseFactory()

Specified by:

getRpcResponseFactory in interface RaftRpcFactory

isReplicatorPipelineEnabled

public boolean isReplicatorPipelineEnabled()

Specified by:

isReplicatorPipelineEnabled in interface RaftRpcFactory

getMarshallerRegistry

public MarshallerRegistry getMarshallerRegistry()