A B C F G I M N R S

A

addServerInterceptor(ServerInterceptor) - Method in class com.alipay.sofa.jraft.rpc.impl.GrpcServer

B

boundPort() - Method in class com.alipay.sofa.jraft.rpc.impl.GrpcServer

C

checkConnection(Endpoint) - Method in class com.alipay.sofa.jraft.rpc.impl.GrpcClient

checkConnection(Endpoint, boolean) - Method in class com.alipay.sofa.jraft.rpc.impl.GrpcClient

closeConnection(Endpoint) - Method in class com.alipay.sofa.jraft.rpc.impl.GrpcClient

com.alipay.sofa.jraft.rpc.impl - package com.alipay.sofa.jraft.rpc.impl

ConnectionInterceptor - Class in com.alipay.sofa.jraft.rpc.impl

Intercepting incoming calls to get Connection and attach to current Context before that are dispatched by ServerCallHandler.

ConnectionInterceptor() - Constructor for class com.alipay.sofa.jraft.rpc.impl.ConnectionInterceptor

createRpcClient(RaftRpcFactory.ConfigHelper<RpcClient>) - Method in class com.alipay.sofa.jraft.rpc.impl.GrpcRaftRpcFactory

createRpcServer(Endpoint, RaftRpcFactory.ConfigHelper<RpcServer>) - Method in class com.alipay.sofa.jraft.rpc.impl.GrpcRaftRpcFactory

F

findRespInstance(String) - Static method in class com.alipay.sofa.jraft.rpc.impl.MarshallerHelper

findResponseInstanceByRequest(String) - Method in interface com.alipay.sofa.jraft.rpc.impl.MarshallerRegistry

Find response default instance by request's class name.

G

getCurrentConnection(List<ConnectionClosedEventListener>) - Static method in class com.alipay.sofa.jraft.rpc.impl.ConnectionInterceptor

getHandlerRegistry() - Method in class com.alipay.sofa.jraft.rpc.impl.GrpcServer

getMarshallerRegistry() - Method in class com.alipay.sofa.jraft.rpc.impl.GrpcRaftRpcFactory

getOrCreateConnection(ServerStream, List<ConnectionClosedEventListener>) - Static method in class io.grpc.netty.shaded.io.grpc.netty.NettyConnectionHelper

getRemoteAddress() - Static method in class com.alipay.sofa.jraft.rpc.impl.RemoteAddressInterceptor

getRpcResponseFactory() - Method in class com.alipay.sofa.jraft.rpc.impl.GrpcRaftRpcFactory

getServer() - Method in class com.alipay.sofa.jraft.rpc.impl.GrpcServer

getServerStream(ServerCall<?, ?>) - Static method in class io.grpc.internal.ServerStreamHelper

GrpcClient - Class in com.alipay.sofa.jraft.rpc.impl

GRPC RPC client implement.

GrpcClient(Map<String, Message>, MarshallerRegistry) - Constructor for class com.alipay.sofa.jraft.rpc.impl.GrpcClient

GrpcRaftRpcFactory - Class in com.alipay.sofa.jraft.rpc.impl

GrpcRaftRpcFactory() - Constructor for class com.alipay.sofa.jraft.rpc.impl.GrpcRaftRpcFactory

GrpcResponseFactory - Class in com.alipay.sofa.jraft.rpc.impl

Helper to create error response for GRPC implementation.

GrpcResponseFactory() - Constructor for class com.alipay.sofa.jraft.rpc.impl.GrpcResponseFactory

GrpcServer - Class in com.alipay.sofa.jraft.rpc.impl

GRPC RPC server implement.

GrpcServer(Server, MutableHandlerRegistry, Map<String, Message>, MarshallerRegistry) - Constructor for class com.alipay.sofa.jraft.rpc.impl.GrpcServer

GrpcServerHelper - Class in com.alipay.sofa.jraft.rpc.impl

GrpcServerHelper() - Constructor for class com.alipay.sofa.jraft.rpc.impl.GrpcServerHelper

I

init(RpcOptions) - Method in class com.alipay.sofa.jraft.rpc.impl.GrpcClient

init(Void) - Method in class com.alipay.sofa.jraft.rpc.impl.GrpcServer

interceptCall(ServerCall<ReqT, RespT>, Metadata, ServerCallHandler<ReqT, RespT>) - Method in class com.alipay.sofa.jraft.rpc.impl.ConnectionInterceptor

interceptCall(ServerCall<ReqT, RespT>, Metadata, ServerCallHandler<ReqT, RespT>) - Method in class com.alipay.sofa.jraft.rpc.impl.RemoteAddressInterceptor

invokeAsync(Endpoint, Object, InvokeContext, InvokeCallback, long) - Method in class com.alipay.sofa.jraft.rpc.impl.GrpcClient

invokeSync(Endpoint, Object, InvokeContext, long) - Method in class com.alipay.sofa.jraft.rpc.impl.GrpcClient

io.grpc.internal - package io.grpc.internal

io.grpc.netty.shaded.io.grpc.netty - package io.grpc.netty.shaded.io.grpc.netty

isReplicatorPipelineEnabled() - Method in class com.alipay.sofa.jraft.rpc.impl.GrpcRaftRpcFactory

M

ManagedChannelHelper - Class in com.alipay.sofa.jraft.rpc.impl

ManagedChannelHelper() - Constructor for class com.alipay.sofa.jraft.rpc.impl.ManagedChannelHelper

MarshallerHelper - Class in com.alipay.sofa.jraft.rpc.impl

Not thread safe.

MarshallerHelper() - Constructor for class com.alipay.sofa.jraft.rpc.impl.MarshallerHelper

MarshallerRegistry - Interface in com.alipay.sofa.jraft.rpc.impl

N

NettyConnectionHelper - Class in io.grpc.netty.shaded.io.grpc.netty

Get netty channel.

NettyConnectionHelper() - Constructor for class io.grpc.netty.shaded.io.grpc.netty.NettyConnectionHelper

newResponse(Message, int, String, Object...) - Method in class com.alipay.sofa.jraft.rpc.impl.GrpcResponseFactory

R

registerConnectEventListener(ReplicatorGroup) - Method in class com.alipay.sofa.jraft.rpc.impl.GrpcClient

registerConnectionClosedEventListener(ConnectionClosedEventListener) - Method in class com.alipay.sofa.jraft.rpc.impl.GrpcServer

registerProcessor(RpcProcessor) - Method in class com.alipay.sofa.jraft.rpc.impl.GrpcServer

registerProtobufSerializer(String, Object...) - Method in class com.alipay.sofa.jraft.rpc.impl.GrpcRaftRpcFactory

registerRespInstance(String, Message) - Static method in class com.alipay.sofa.jraft.rpc.impl.MarshallerHelper

registerResponseInstance(String, Message) - Method in interface com.alipay.sofa.jraft.rpc.impl.MarshallerRegistry

Register response default instance.

RemoteAddressInterceptor - Class in com.alipay.sofa.jraft.rpc.impl

GRPC server interceptor to trace remote address.

RemoteAddressInterceptor() - Constructor for class com.alipay.sofa.jraft.rpc.impl.RemoteAddressInterceptor

S

ServerStreamHelper - Class in io.grpc.internal

Get grpc's server stream.

ServerStreamHelper() - Constructor for class io.grpc.internal.ServerStreamHelper

setDefaultExecutor(ExecutorService) - Method in class com.alipay.sofa.jraft.rpc.impl.GrpcServer

shutdown() - Method in class com.alipay.sofa.jraft.rpc.impl.GrpcClient

shutdown() - Method in class com.alipay.sofa.jraft.rpc.impl.GrpcServer

shutdownAndAwaitTermination(Server) - Static method in class com.alipay.sofa.jraft.rpc.impl.GrpcServerHelper

shutdownAndAwaitTermination(Server, long) - Static method in class com.alipay.sofa.jraft.rpc.impl.GrpcServerHelper

The following method shuts down an Server in two phases, first by calling shutdown to reject incoming tasks, and then calling shutdownNow, if necessary, to cancel any lingering tasks.

shutdownAndAwaitTermination(ManagedChannel) - Static method in class com.alipay.sofa.jraft.rpc.impl.ManagedChannelHelper

shutdownAndAwaitTermination(ManagedChannel, long) - Static method in class com.alipay.sofa.jraft.rpc.impl.ManagedChannelHelper

The following method shuts down an ManagedChannel in two phases, first by calling shutdown to reject incoming tasks, and then calling shutdownNow, if necessary, to cancel any lingering tasks.

A B C F G I M N R S