Package | Description |
---|---|
alluxio.grpc | |
alluxio.master.transport |
Modifier and Type | Field and Description |
---|---|
static com.google.protobuf.Parser<TransportMessage> |
TransportMessage.PARSER
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
TransportMessage |
TransportMessage.Builder.build() |
TransportMessage |
TransportMessage.Builder.buildPartial() |
static TransportMessage |
TransportMessage.getDefaultInstance() |
TransportMessage |
TransportMessage.getDefaultInstanceForType() |
TransportMessage |
TransportMessage.Builder.getDefaultInstanceForType() |
static TransportMessage |
TransportMessage.parseDelimitedFrom(InputStream input) |
static TransportMessage |
TransportMessage.parseDelimitedFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static TransportMessage |
TransportMessage.parseFrom(byte[] data) |
static TransportMessage |
TransportMessage.parseFrom(byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static TransportMessage |
TransportMessage.parseFrom(ByteBuffer data) |
static TransportMessage |
TransportMessage.parseFrom(ByteBuffer data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static TransportMessage |
TransportMessage.parseFrom(com.google.protobuf.ByteString data) |
static TransportMessage |
TransportMessage.parseFrom(com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static TransportMessage |
TransportMessage.parseFrom(com.google.protobuf.CodedInputStream input) |
static TransportMessage |
TransportMessage.parseFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static TransportMessage |
TransportMessage.parseFrom(InputStream input) |
static TransportMessage |
TransportMessage.parseFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
Modifier and Type | Method and Description |
---|---|
default io.grpc.stub.StreamObserver<TransportMessage> |
MessagingServiceGrpc.AsyncService.connect(io.grpc.stub.StreamObserver<TransportMessage> responseObserver) |
io.grpc.stub.StreamObserver<TransportMessage> |
MessagingServiceGrpc.MessagingServiceStub.connect(io.grpc.stub.StreamObserver<TransportMessage> responseObserver) |
static io.grpc.MethodDescriptor<TransportMessage,TransportMessage> |
MessagingServiceGrpc.getConnectMethod() |
static io.grpc.MethodDescriptor<TransportMessage,TransportMessage> |
MessagingServiceGrpc.getConnectMethod() |
com.google.protobuf.Parser<TransportMessage> |
TransportMessage.getParserForType() |
static com.google.protobuf.Parser<TransportMessage> |
TransportMessage.parser() |
Modifier and Type | Method and Description |
---|---|
TransportMessage.Builder |
TransportMessage.Builder.mergeFrom(TransportMessage other) |
static TransportMessage.Builder |
TransportMessage.newBuilder(TransportMessage prototype) |
Modifier and Type | Method and Description |
---|---|
default io.grpc.stub.StreamObserver<TransportMessage> |
MessagingServiceGrpc.AsyncService.connect(io.grpc.stub.StreamObserver<TransportMessage> responseObserver) |
io.grpc.stub.StreamObserver<TransportMessage> |
MessagingServiceGrpc.MessagingServiceStub.connect(io.grpc.stub.StreamObserver<TransportMessage> responseObserver) |
Modifier and Type | Method and Description |
---|---|
io.grpc.stub.StreamObserver<TransportMessage> |
GrpcMessagingServiceClientHandler.connect(io.grpc.stub.StreamObserver<TransportMessage> responseObserver)
RPC for establishing bi-di stream between client/server.
|
Modifier and Type | Method and Description |
---|---|
protected void |
GrpcMessagingConnection.handleResponseMessage(TransportMessage response) |
void |
GrpcMessagingConnection.onNext(TransportMessage message) |
Modifier and Type | Method and Description |
---|---|
io.grpc.stub.StreamObserver<TransportMessage> |
GrpcMessagingServiceClientHandler.connect(io.grpc.stub.StreamObserver<TransportMessage> responseObserver)
RPC for establishing bi-di stream between client/server.
|
void |
GrpcMessagingConnection.setTargetObserver(io.grpc.stub.StreamObserver<TransportMessage> targetObserver)
Sets the stream observer for target.
|
Copyright © 2023. All Rights Reserved.