com.alipay.sofa.jraft.rpc.impl

类 GrpcClient

java.lang.Object

com.alipay.sofa.jraft.rpc.impl.GrpcClient

所有已实现的接口:

Lifecycle<RpcOptions>, RpcClient

public class GrpcClient
extends Object
implements RpcClient

GRPC RPC client implement.

作者:

nicholas.jxf, jiachun.fjc

构造器概要

构造器

构造器和说明
GrpcClient(Map<String,Message> parserClasses, MarshallerRegistry marshallerRegistry)

方法概要

限定符和类型	方法和说明
boolean	checkConnection(Endpoint endpoint)
boolean	checkConnection(Endpoint endpoint, boolean createIfAbsent)
void	closeConnection(Endpoint endpoint)
boolean	init(RpcOptions opts)
void	invokeAsync(Endpoint endpoint, Object request, InvokeContext ctx, InvokeCallback callback, long timeoutMs)
Object	invokeSync(Endpoint endpoint, Object request, InvokeContext ctx, long timeoutMs)
void	registerConnectEventListener(ReplicatorGroup replicatorGroup)
void	shutdown()

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

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

从接口继承的方法 com.alipay.sofa.jraft.rpc.RpcClient

invokeAsync, invokeSync

构造器详细资料

GrpcClient

public GrpcClient(Map<String,Message> parserClasses,
                  MarshallerRegistry marshallerRegistry)

方法详细资料

init

public boolean init(RpcOptions opts)

指定者:

init 在接口中 Lifecycle<RpcOptions>

shutdown

public void shutdown()

指定者:

shutdown 在接口中 Lifecycle<RpcOptions>

checkConnection

public boolean checkConnection(Endpoint endpoint)

指定者:

checkConnection 在接口中 RpcClient

checkConnection

public boolean checkConnection(Endpoint endpoint,
                               boolean createIfAbsent)

指定者:

checkConnection 在接口中 RpcClient

closeConnection

public void closeConnection(Endpoint endpoint)

指定者:

closeConnection 在接口中 RpcClient

registerConnectEventListener

public void registerConnectEventListener(ReplicatorGroup replicatorGroup)

指定者:

registerConnectEventListener 在接口中 RpcClient

invokeSync

public Object invokeSync(Endpoint endpoint,
                         Object request,
                         InvokeContext ctx,
                         long timeoutMs)
                  throws RemotingException

指定者:

invokeSync 在接口中 RpcClient

抛出:

RemotingException

invokeAsync

public void invokeAsync(Endpoint endpoint,
                        Object request,
                        InvokeContext ctx,
                        InvokeCallback callback,
                        long timeoutMs)

指定者:

invokeAsync 在接口中 RpcClient