Package | Description |
---|---|
alluxio.grpc | |
alluxio.master.journal.raft |
Modifier and Type | Field and Description |
---|---|
static com.google.protobuf.Parser<DownloadSnapshotPResponse> |
DownloadSnapshotPResponse.PARSER
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
DownloadSnapshotPResponse |
DownloadSnapshotPResponse.Builder.build() |
DownloadSnapshotPResponse |
DownloadSnapshotPResponse.Builder.buildPartial() |
static DownloadSnapshotPResponse |
DownloadSnapshotPResponse.getDefaultInstance() |
DownloadSnapshotPResponse |
DownloadSnapshotPResponse.getDefaultInstanceForType() |
DownloadSnapshotPResponse |
DownloadSnapshotPResponse.Builder.getDefaultInstanceForType() |
static DownloadSnapshotPResponse |
DownloadSnapshotPResponse.parseDelimitedFrom(InputStream input) |
static DownloadSnapshotPResponse |
DownloadSnapshotPResponse.parseDelimitedFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static DownloadSnapshotPResponse |
DownloadSnapshotPResponse.parseFrom(byte[] data) |
static DownloadSnapshotPResponse |
DownloadSnapshotPResponse.parseFrom(byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static DownloadSnapshotPResponse |
DownloadSnapshotPResponse.parseFrom(ByteBuffer data) |
static DownloadSnapshotPResponse |
DownloadSnapshotPResponse.parseFrom(ByteBuffer data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static DownloadSnapshotPResponse |
DownloadSnapshotPResponse.parseFrom(com.google.protobuf.ByteString data) |
static DownloadSnapshotPResponse |
DownloadSnapshotPResponse.parseFrom(com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static DownloadSnapshotPResponse |
DownloadSnapshotPResponse.parseFrom(com.google.protobuf.CodedInputStream input) |
static DownloadSnapshotPResponse |
DownloadSnapshotPResponse.parseFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static DownloadSnapshotPResponse |
DownloadSnapshotPResponse.parseFrom(InputStream input) |
static DownloadSnapshotPResponse |
DownloadSnapshotPResponse.parseFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
Modifier and Type | Method and Description |
---|---|
static io.grpc.MethodDescriptor<DownloadSnapshotPRequest,DownloadSnapshotPResponse> |
RaftJournalServiceGrpc.getDownloadSnapshotMethod() |
com.google.protobuf.Parser<DownloadSnapshotPResponse> |
DownloadSnapshotPResponse.getParserForType() |
static com.google.protobuf.Parser<DownloadSnapshotPResponse> |
DownloadSnapshotPResponse.parser() |
Modifier and Type | Method and Description |
---|---|
DownloadSnapshotPResponse.Builder |
DownloadSnapshotPResponse.Builder.mergeFrom(DownloadSnapshotPResponse other) |
static DownloadSnapshotPResponse.Builder |
DownloadSnapshotPResponse.newBuilder(DownloadSnapshotPResponse prototype) |
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.
|
Modifier and Type | Method and Description |
---|---|
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.
|
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 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.