public class CopycatGrpcClientConnection extends CopycatGrpcConnection
CopycatGrpcConnection
implementation for client.CopycatGrpcConnection.ConnectionOwner, CopycatGrpcConnection.ContextualFuture<T>, CopycatGrpcConnection.HandlerHolder
Constructor and Description |
---|
CopycatGrpcClientConnection(io.atomix.catalyst.concurrent.ThreadContext context,
ExecutorService executor,
GrpcChannel channel,
long requestTimeoutMs)
Creates a connection object for client.
|
Modifier and Type | Method and Description |
---|---|
CompletableFuture<Void> |
close() |
handler, handler, handleResponseMessage, onClose, onCompleted, onError, onException, onNext, send, sendAndReceive, setTargetObserver, toString
public CopycatGrpcClientConnection(io.atomix.catalyst.concurrent.ThreadContext context, ExecutorService executor, GrpcChannel channel, long requestTimeoutMs)
CopycatGrpcConnection.setTargetObserver(io.grpc.stub.StreamObserver<alluxio.grpc.CopycatMessage>)
should be called explicitly before using the connection.context
- copycat thread contextexecutor
- transport executorchannel
- underlying gRPC channelrequestTimeoutMs
- timeout in milliseconds for requestspublic CompletableFuture<Void> close()
close
in interface io.atomix.catalyst.transport.Connection
close
in class CopycatGrpcConnection
Copyright © 2023. All Rights Reserved.