@SPI(priority=1) public class GrpcRaftRpcFactory extends Object implements RaftRpcFactory
RaftRpcFactory.ConfigHelper<T>DEFAULT| 构造器和说明 |
|---|
GrpcRaftRpcFactory() |
| 限定符和类型 | 方法和说明 |
|---|---|
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) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitcreateRpcClient, createRpcServer, defaultJRaftClientConfigHelper, defaultJRaftServerConfigHelper, ensurePipelinepublic void registerProtobufSerializer(String className, Object... args)
registerProtobufSerializer 在接口中 RaftRpcFactorypublic RpcClient createRpcClient(RaftRpcFactory.ConfigHelper<RpcClient> helper)
createRpcClient 在接口中 RaftRpcFactorypublic RpcServer createRpcServer(Endpoint endpoint, RaftRpcFactory.ConfigHelper<RpcServer> helper)
createRpcServer 在接口中 RaftRpcFactorypublic RpcResponseFactory getRpcResponseFactory()
getRpcResponseFactory 在接口中 RaftRpcFactorypublic boolean isReplicatorPipelineEnabled()
isReplicatorPipelineEnabled 在接口中 RaftRpcFactorypublic MarshallerRegistry getMarshallerRegistry()
Copyright © 2020. All rights reserved.