com.alipay.sofa.jraft.rpc.impl

Class GrpcServer

java.lang.Object

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

All Implemented Interfaces:

Lifecycle<Void>, RpcServer

public class GrpcServer
extends Object
implements RpcServer

GRPC RPC server implement.

Author:

nicholas.jxf, jiachun.fjc

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
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()

Methods inherited from class java.lang.Object

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

Constructor Detail

GrpcServer

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

Method Detail

init

public boolean init(Void opts)

Specified by:

init in interface Lifecycle<Void>

shutdown

public void shutdown()

Specified by:

shutdown in interface Lifecycle<Void>

registerConnectionClosedEventListener

public void registerConnectionClosedEventListener(ConnectionClosedEventListener listener)

Specified by:

registerConnectionClosedEventListener in interface RpcServer

registerProcessor

public void registerProcessor(RpcProcessor processor)

Specified by:

registerProcessor in interface RpcServer

boundPort

public int boundPort()

Specified by:

boundPort in interface 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)