Package | Description |
---|---|
alluxio.hub.agent.rpc.service | |
alluxio.hub.manager.process | |
alluxio.hub.proto |
Modifier and Type | Method and Description |
---|---|
void |
AgentManagerService.processStatusChange(AgentProcessStatusChangeRequest request,
io.grpc.stub.StreamObserver<AgentProcessStatusChangeResponse> responseObserver) |
Modifier and Type | Method and Description |
---|---|
List<AgentProcessStatusChangeResponse> |
ManagerProcessContext.processStatusChange(ProcessStatusChangeRequest batchReq)
Process state change request for Alluxio nodes.
|
Modifier and Type | Field and Description |
---|---|
static com.google.protobuf.Parser<AgentProcessStatusChangeResponse> |
AgentProcessStatusChangeResponse.PARSER
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
AgentProcessStatusChangeResponse |
AgentProcessStatusChangeResponse.Builder.build() |
AgentProcessStatusChangeResponse |
AgentProcessStatusChangeResponse.Builder.buildPartial() |
static AgentProcessStatusChangeResponse |
AgentProcessStatusChangeResponse.getDefaultInstance() |
AgentProcessStatusChangeResponse |
AgentProcessStatusChangeResponse.getDefaultInstanceForType() |
AgentProcessStatusChangeResponse |
AgentProcessStatusChangeResponse.Builder.getDefaultInstanceForType() |
AgentProcessStatusChangeResponse |
ProcessStatusChangeResponse.PayloadOrBuilder.getProcessStatusChangeResponse(int index)
repeated .alluxio.hub.proto.AgentProcessStatusChangeResponse process_status_change_response = 1; |
AgentProcessStatusChangeResponse |
ProcessStatusChangeResponse.Payload.getProcessStatusChangeResponse(int index)
repeated .alluxio.hub.proto.AgentProcessStatusChangeResponse process_status_change_response = 1; |
AgentProcessStatusChangeResponse |
ProcessStatusChangeResponse.Payload.Builder.getProcessStatusChangeResponse(int index)
repeated .alluxio.hub.proto.AgentProcessStatusChangeResponse process_status_change_response = 1; |
static AgentProcessStatusChangeResponse |
AgentProcessStatusChangeResponse.parseDelimitedFrom(InputStream input) |
static AgentProcessStatusChangeResponse |
AgentProcessStatusChangeResponse.parseDelimitedFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static AgentProcessStatusChangeResponse |
AgentProcessStatusChangeResponse.parseFrom(byte[] data) |
static AgentProcessStatusChangeResponse |
AgentProcessStatusChangeResponse.parseFrom(byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static AgentProcessStatusChangeResponse |
AgentProcessStatusChangeResponse.parseFrom(ByteBuffer data) |
static AgentProcessStatusChangeResponse |
AgentProcessStatusChangeResponse.parseFrom(ByteBuffer data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static AgentProcessStatusChangeResponse |
AgentProcessStatusChangeResponse.parseFrom(com.google.protobuf.ByteString data) |
static AgentProcessStatusChangeResponse |
AgentProcessStatusChangeResponse.parseFrom(com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static AgentProcessStatusChangeResponse |
AgentProcessStatusChangeResponse.parseFrom(com.google.protobuf.CodedInputStream input) |
static AgentProcessStatusChangeResponse |
AgentProcessStatusChangeResponse.parseFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static AgentProcessStatusChangeResponse |
AgentProcessStatusChangeResponse.parseFrom(InputStream input) |
static AgentProcessStatusChangeResponse |
AgentProcessStatusChangeResponse.parseFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
AgentProcessStatusChangeResponse |
AgentManagerServiceGrpc.AgentManagerServiceBlockingStub.processStatusChange(AgentProcessStatusChangeRequest request) |
Modifier and Type | Method and Description |
---|---|
com.google.protobuf.Parser<AgentProcessStatusChangeResponse> |
AgentProcessStatusChangeResponse.getParserForType() |
static io.grpc.MethodDescriptor<AgentProcessStatusChangeRequest,AgentProcessStatusChangeResponse> |
AgentManagerServiceGrpc.getProcessStatusChangeMethod() |
List<AgentProcessStatusChangeResponse> |
ProcessStatusChangeResponse.PayloadOrBuilder.getProcessStatusChangeResponseList()
repeated .alluxio.hub.proto.AgentProcessStatusChangeResponse process_status_change_response = 1; |
List<AgentProcessStatusChangeResponse> |
ProcessStatusChangeResponse.Payload.getProcessStatusChangeResponseList()
repeated .alluxio.hub.proto.AgentProcessStatusChangeResponse process_status_change_response = 1; |
List<AgentProcessStatusChangeResponse> |
ProcessStatusChangeResponse.Payload.Builder.getProcessStatusChangeResponseList()
repeated .alluxio.hub.proto.AgentProcessStatusChangeResponse process_status_change_response = 1; |
static com.google.protobuf.Parser<AgentProcessStatusChangeResponse> |
AgentProcessStatusChangeResponse.parser() |
com.google.common.util.concurrent.ListenableFuture<AgentProcessStatusChangeResponse> |
AgentManagerServiceGrpc.AgentManagerServiceFutureStub.processStatusChange(AgentProcessStatusChangeRequest request) |
Modifier and Type | Method and Description |
---|---|
ProcessStatusChangeResponse.Payload.Builder |
ProcessStatusChangeResponse.Payload.Builder.addProcessStatusChangeResponse(AgentProcessStatusChangeResponse value)
repeated .alluxio.hub.proto.AgentProcessStatusChangeResponse process_status_change_response = 1; |
ProcessStatusChangeResponse.Payload.Builder |
ProcessStatusChangeResponse.Payload.Builder.addProcessStatusChangeResponse(int index,
AgentProcessStatusChangeResponse value)
repeated .alluxio.hub.proto.AgentProcessStatusChangeResponse process_status_change_response = 1; |
AgentProcessStatusChangeResponse.Builder |
AgentProcessStatusChangeResponse.Builder.mergeFrom(AgentProcessStatusChangeResponse other) |
static AgentProcessStatusChangeResponse.Builder |
AgentProcessStatusChangeResponse.newBuilder(AgentProcessStatusChangeResponse prototype) |
ProcessStatusChangeResponse.Payload.Builder |
ProcessStatusChangeResponse.Payload.Builder.setProcessStatusChangeResponse(int index,
AgentProcessStatusChangeResponse value)
repeated .alluxio.hub.proto.AgentProcessStatusChangeResponse process_status_change_response = 1; |
Modifier and Type | Method and Description |
---|---|
ProcessStatusChangeResponse.Payload.Builder |
ProcessStatusChangeResponse.Payload.Builder.addAllProcessStatusChangeResponse(Iterable<? extends AgentProcessStatusChangeResponse> values)
repeated .alluxio.hub.proto.AgentProcessStatusChangeResponse process_status_change_response = 1; |
void |
AgentManagerServiceGrpc.AgentManagerServiceImplBase.processStatusChange(AgentProcessStatusChangeRequest request,
io.grpc.stub.StreamObserver<AgentProcessStatusChangeResponse> responseObserver) |
void |
AgentManagerServiceGrpc.AgentManagerServiceStub.processStatusChange(AgentProcessStatusChangeRequest request,
io.grpc.stub.StreamObserver<AgentProcessStatusChangeResponse> responseObserver) |
Copyright © 2023. All Rights Reserved.