com.alipay.sofa.jraft.rpc.impl

Class GrpcClient

java.lang.Object

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

All Implemented Interfaces:

Lifecycle<RpcOptions>, RpcClient

public class GrpcClient
extends Object
implements RpcClient

GRPC RPC client implement.

Author:

nicholas.jxf, jiachun.fjc

Constructor Summary

Constructors

Constructor and Description
GrpcClient(Map<String,Message> parserClasses, MarshallerRegistry marshallerRegistry)

Method Summary

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

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.RpcClient

invokeAsync, invokeSync

Constructor Detail

GrpcClient

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

Method Detail

init

public boolean init(RpcOptions opts)

Specified by:

init in interface Lifecycle<RpcOptions>

shutdown

public void shutdown()

Specified by:

shutdown in interface Lifecycle<RpcOptions>

checkConnection

public boolean checkConnection(Endpoint endpoint)

Specified by:

checkConnection in interface RpcClient

checkConnection

public boolean checkConnection(Endpoint endpoint,
                               boolean createIfAbsent)

Specified by:

checkConnection in interface RpcClient

closeConnection

public void closeConnection(Endpoint endpoint)

Specified by:

closeConnection in interface RpcClient

registerConnectEventListener

public void registerConnectEventListener(ReplicatorGroup replicatorGroup)

Specified by:

registerConnectEventListener in interface RpcClient

invokeSync

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

Specified by:

invokeSync in interface RpcClient

Throws:

RemotingException

invokeAsync

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

Specified by:

invokeAsync in interface RpcClient