Package | Description |
---|---|
alluxio.grpc | |
alluxio.master.journal.raft |
Modifier and Type | Field and Description |
---|---|
static com.google.protobuf.Parser<DownloadSnapshotPRequest> |
DownloadSnapshotPRequest.PARSER
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
DownloadSnapshotPRequest |
DownloadSnapshotPRequest.Builder.build() |
DownloadSnapshotPRequest |
DownloadSnapshotPRequest.Builder.buildPartial() |
static DownloadSnapshotPRequest |
DownloadSnapshotPRequest.getDefaultInstance() |
DownloadSnapshotPRequest |
DownloadSnapshotPRequest.getDefaultInstanceForType() |
DownloadSnapshotPRequest |
DownloadSnapshotPRequest.Builder.getDefaultInstanceForType() |
static DownloadSnapshotPRequest |
DownloadSnapshotPRequest.parseDelimitedFrom(InputStream input) |
static DownloadSnapshotPRequest |
DownloadSnapshotPRequest.parseDelimitedFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static DownloadSnapshotPRequest |
DownloadSnapshotPRequest.parseFrom(byte[] data) |
static DownloadSnapshotPRequest |
DownloadSnapshotPRequest.parseFrom(byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static DownloadSnapshotPRequest |
DownloadSnapshotPRequest.parseFrom(ByteBuffer data) |
static DownloadSnapshotPRequest |
DownloadSnapshotPRequest.parseFrom(ByteBuffer data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static DownloadSnapshotPRequest |
DownloadSnapshotPRequest.parseFrom(com.google.protobuf.ByteString data) |
static DownloadSnapshotPRequest |
DownloadSnapshotPRequest.parseFrom(com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static DownloadSnapshotPRequest |
DownloadSnapshotPRequest.parseFrom(com.google.protobuf.CodedInputStream input) |
static DownloadSnapshotPRequest |
DownloadSnapshotPRequest.parseFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static DownloadSnapshotPRequest |
DownloadSnapshotPRequest.parseFrom(InputStream input) |
static DownloadSnapshotPRequest |
DownloadSnapshotPRequest.parseFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
Modifier and Type | Method and Description |
---|---|
io.grpc.stub.StreamObserver<DownloadSnapshotPRequest> |
RaftJournalServiceGrpc.RaftJournalServiceImplBase.downloadSnapshot(io.grpc.stub.StreamObserver<DownloadSnapshotPResponse> responseObserver)
Downloads a snapshot from primary master.
|
io.grpc.stub.StreamObserver<DownloadSnapshotPRequest> |
RaftJournalServiceGrpc.RaftJournalServiceStub.downloadSnapshot(io.grpc.stub.StreamObserver<DownloadSnapshotPResponse> responseObserver)
Downloads a snapshot from primary master.
|
static io.grpc.MethodDescriptor<DownloadSnapshotPRequest,DownloadSnapshotPResponse> |
RaftJournalServiceGrpc.getDownloadSnapshotMethod() |
com.google.protobuf.Parser<DownloadSnapshotPRequest> |
DownloadSnapshotPRequest.getParserForType() |
static com.google.protobuf.Parser<DownloadSnapshotPRequest> |
DownloadSnapshotPRequest.parser() |
Modifier and Type | Method and Description |
---|---|
DownloadSnapshotPRequest.Builder |
DownloadSnapshotPRequest.Builder.mergeFrom(DownloadSnapshotPRequest other) |
static DownloadSnapshotPRequest.Builder |
DownloadSnapshotPRequest.newBuilder(DownloadSnapshotPRequest prototype) |
Modifier and Type | Method and Description |
---|---|
io.grpc.stub.StreamObserver<DownloadSnapshotPRequest> |
RaftJournalServiceHandler.downloadSnapshot(io.grpc.stub.StreamObserver<DownloadSnapshotPResponse> responseObserver) |
io.grpc.stub.StreamObserver<DownloadSnapshotPRequest> |
RaftJournalServiceClient.downloadSnapshot(io.grpc.stub.StreamObserver<DownloadSnapshotPResponse> responseObserver)
Downloads a snapshot.
|
static SnapshotDownloader<DownloadSnapshotPRequest,DownloadSnapshotPResponse> |
SnapshotDownloader.forFollower(org.apache.ratis.statemachine.impl.SimpleStateMachineStorage storage,
String source)
Builds a stream for follower to download a snapshot.
|
static SnapshotUploader<DownloadSnapshotPResponse,DownloadSnapshotPRequest> |
SnapshotUploader.forLeader(org.apache.ratis.statemachine.impl.SimpleStateMachineStorage storage,
org.apache.ratis.statemachine.SnapshotInfo snapshot,
io.grpc.stub.StreamObserver<DownloadSnapshotPResponse> stream)
Builds a stream for leader to upload a snapshot.
|
io.grpc.stub.StreamObserver<DownloadSnapshotPRequest> |
SnapshotReplicationManager.sendSnapshotToFollower(io.grpc.stub.StreamObserver<DownloadSnapshotPResponse> responseObserver)
Sends a snapshot to a follower.
|
Copyright © 2023. All Rights Reserved.