com.alipay.sofa.jraft.rpc.impl

类 GrpcServer

java.lang.Object

com.alipay.sofa.jraft.rpc.impl.GrpcServer

所有已实现的接口:

Lifecycle<Void>, RpcServer

public class GrpcServer
extends Object
implements RpcServer

GRPC RPC server implement.

作者:

nicholas.jxf, jiachun.fjc

构造器概要

构造器

构造器和说明
GrpcServer(io.grpc.Server server, io.grpc.util.MutableHandlerRegistry handlerRegistry, Map<String,Message> parserClasses, MarshallerRegistry marshallerRegistry)

方法概要

限定符和类型	方法和说明
boolean	addServerInterceptor(io.grpc.ServerInterceptor interceptor)
int	boundPort()
io.grpc.util.MutableHandlerRegistry	getHandlerRegistry()
io.grpc.Server	getServer()
boolean	init(Void opts)
void	registerConnectionClosedEventListener(ConnectionClosedEventListener listener)
void	registerProcessor(RpcProcessor processor)
void	setDefaultExecutor(ExecutorService defaultExecutor)
void	shutdown()

从类继承的方法 java.lang.Object

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

构造器详细资料

GrpcServer

public GrpcServer(io.grpc.Server server,
                  io.grpc.util.MutableHandlerRegistry handlerRegistry,
                  Map<String,Message> parserClasses,
                  MarshallerRegistry marshallerRegistry)

方法详细资料

init

public boolean init(Void opts)

指定者:

init 在接口中 Lifecycle<Void>

shutdown

public void shutdown()

指定者:

shutdown 在接口中 Lifecycle<Void>

registerConnectionClosedEventListener

public void registerConnectionClosedEventListener(ConnectionClosedEventListener listener)

指定者:

registerConnectionClosedEventListener 在接口中 RpcServer

registerProcessor

public void registerProcessor(RpcProcessor processor)

指定者:

registerProcessor 在接口中 RpcServer

boundPort

public int boundPort()

指定者:

boundPort 在接口中 RpcServer

setDefaultExecutor

public void setDefaultExecutor(ExecutorService defaultExecutor)

getServer

public io.grpc.Server getServer()

getHandlerRegistry

public io.grpc.util.MutableHandlerRegistry getHandlerRegistry()

addServerInterceptor

public boolean addServerInterceptor(io.grpc.ServerInterceptor interceptor)