Package | Description |
---|---|
alluxio.client.block.stream | |
alluxio.grpc | |
alluxio.worker.grpc |
Constructor and Description |
---|
DataMessageClientResponseObserver(io.grpc.stub.StreamObserver<RespT> observer,
DataMessageMarshaller<ReqT> requestMarshaller,
DataMessageMarshaller<RespT> responseMarshaller) |
DataMessageClientResponseObserver(io.grpc.stub.StreamObserver<RespT> observer,
DataMessageMarshaller<ReqT> requestMarshaller,
DataMessageMarshaller<RespT> responseMarshaller) |
GrpcDataMessageBlockingStream(java.util.function.Function<io.grpc.stub.StreamObserver<ResT>,io.grpc.stub.StreamObserver<ReqT>> rpcFunc,
int bufferSize,
String description,
DataMessageMarshaller<ReqT> requestMarshaller,
DataMessageMarshaller<ResT> responseMarshaller) |
GrpcDataMessageBlockingStream(java.util.function.Function<io.grpc.stub.StreamObserver<ResT>,io.grpc.stub.StreamObserver<ReqT>> rpcFunc,
int bufferSize,
String description,
DataMessageMarshaller<ReqT> requestMarshaller,
DataMessageMarshaller<ResT> responseMarshaller) |
Modifier and Type | Class and Description |
---|---|
class |
ReadResponseMarshaller
Marshaller for
ReadResponse . |
class |
WriteRequestMarshaller
Marshaller for
WriteRequest . |
Modifier and Type | Method and Description |
---|---|
Optional<DataMessageMarshaller<ReqT>> |
DataMessageMarshallerProvider.getRequestMarshaller() |
Optional<DataMessageMarshaller<ResT>> |
DataMessageMarshallerProvider.getResponseMarshaller() |
Constructor and Description |
---|
DataMessageMarshallerProvider(DataMessageMarshaller<ReqT> requestMarshaller,
DataMessageMarshaller<ResT> responseMarshaller) |
DataMessageMarshallerProvider(DataMessageMarshaller<ReqT> requestMarshaller,
DataMessageMarshaller<ResT> responseMarshaller) |
Constructor and Description |
---|
DataMessageServerRequestObserver(io.grpc.stub.StreamObserver<ResT> observer,
DataMessageMarshaller<ReqT> requestMarshaller,
DataMessageMarshaller<ResT> responseMarshaller) |
DataMessageServerRequestObserver(io.grpc.stub.StreamObserver<ResT> observer,
DataMessageMarshaller<ReqT> requestMarshaller,
DataMessageMarshaller<ResT> responseMarshaller) |
Copyright © 2023. All Rights Reserved.