| Modifier and Type | Method and Description |
|---|---|
com.google.protobuf.Message |
NodeImpl.handleInstallSnapshot(RpcRequests.InstallSnapshotRequest request,
RpcRequestClosure done) |
| Modifier and Type | Field and Description |
|---|---|
static com.google.protobuf.Parser<RpcRequests.InstallSnapshotRequest> |
RpcRequests.InstallSnapshotRequest.PARSER
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
RpcRequests.InstallSnapshotRequest |
RpcRequests.InstallSnapshotRequest.Builder.build() |
RpcRequests.InstallSnapshotRequest |
RpcRequests.InstallSnapshotRequest.Builder.buildPartial() |
static RpcRequests.InstallSnapshotRequest |
RpcRequests.InstallSnapshotRequest.getDefaultInstance() |
RpcRequests.InstallSnapshotRequest |
RpcRequests.InstallSnapshotRequest.getDefaultInstanceForType() |
RpcRequests.InstallSnapshotRequest |
RpcRequests.InstallSnapshotRequest.Builder.getDefaultInstanceForType() |
static RpcRequests.InstallSnapshotRequest |
RpcRequests.InstallSnapshotRequest.parseDelimitedFrom(InputStream input) |
static RpcRequests.InstallSnapshotRequest |
RpcRequests.InstallSnapshotRequest.parseDelimitedFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static RpcRequests.InstallSnapshotRequest |
RpcRequests.InstallSnapshotRequest.parseFrom(byte[] data) |
static RpcRequests.InstallSnapshotRequest |
RpcRequests.InstallSnapshotRequest.parseFrom(byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static RpcRequests.InstallSnapshotRequest |
RpcRequests.InstallSnapshotRequest.parseFrom(ByteBuffer data) |
static RpcRequests.InstallSnapshotRequest |
RpcRequests.InstallSnapshotRequest.parseFrom(ByteBuffer data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static RpcRequests.InstallSnapshotRequest |
RpcRequests.InstallSnapshotRequest.parseFrom(com.google.protobuf.ByteString data) |
static RpcRequests.InstallSnapshotRequest |
RpcRequests.InstallSnapshotRequest.parseFrom(com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static RpcRequests.InstallSnapshotRequest |
RpcRequests.InstallSnapshotRequest.parseFrom(com.google.protobuf.CodedInputStream input) |
static RpcRequests.InstallSnapshotRequest |
RpcRequests.InstallSnapshotRequest.parseFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static RpcRequests.InstallSnapshotRequest |
RpcRequests.InstallSnapshotRequest.parseFrom(InputStream input) |
static RpcRequests.InstallSnapshotRequest |
RpcRequests.InstallSnapshotRequest.parseFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
| Modifier and Type | Method and Description |
|---|---|
com.google.protobuf.Parser<RpcRequests.InstallSnapshotRequest> |
RpcRequests.InstallSnapshotRequest.getParserForType() |
static com.google.protobuf.Parser<RpcRequests.InstallSnapshotRequest> |
RpcRequests.InstallSnapshotRequest.parser() |
| Modifier and Type | Method and Description |
|---|---|
com.google.protobuf.Message |
RaftServerService.handleInstallSnapshot(RpcRequests.InstallSnapshotRequest request,
RpcRequestClosure done)
Handle install-snapshot request, return response message or
called done.run() with response.
|
Future<com.google.protobuf.Message> |
RaftClientService.installSnapshot(Endpoint endpoint,
RpcRequests.InstallSnapshotRequest request,
RpcResponseClosure<RpcRequests.InstallSnapshotResponse> done)
Sends a install-snapshot request and handle the response with done.
|
RpcRequests.InstallSnapshotRequest.Builder |
RpcRequests.InstallSnapshotRequest.Builder.mergeFrom(RpcRequests.InstallSnapshotRequest other) |
static RpcRequests.InstallSnapshotRequest.Builder |
RpcRequests.InstallSnapshotRequest.newBuilder(RpcRequests.InstallSnapshotRequest prototype) |
| Modifier and Type | Method and Description |
|---|---|
protected String |
InstallSnapshotRequestProcessor.getGroupId(RpcRequests.InstallSnapshotRequest request) |
protected String |
InstallSnapshotRequestProcessor.getPeerId(RpcRequests.InstallSnapshotRequest request) |
Future<com.google.protobuf.Message> |
DefaultRaftClientService.installSnapshot(Endpoint endpoint,
RpcRequests.InstallSnapshotRequest request,
RpcResponseClosure<RpcRequests.InstallSnapshotResponse> done) |
com.google.protobuf.Message |
InstallSnapshotRequestProcessor.processRequest0(RaftServerService service,
RpcRequests.InstallSnapshotRequest request,
RpcRequestClosure done) |
| Modifier and Type | Method and Description |
|---|---|
void |
SnapshotExecutor.installSnapshot(RpcRequests.InstallSnapshotRequest request,
RpcRequests.InstallSnapshotResponse.Builder response,
RpcRequestClosure done)
Install snapshot according to the very RPC from leader
After the installing succeeds (StateMachine is reset with the snapshot)
or fails, done will be called to respond
Errors:
- Term mismatches: which happens interrupt_downloading_snapshot was
called before install_snapshot, indicating that this RPC was issued by
the old leader.
|
| Modifier and Type | Method and Description |
|---|---|
void |
SnapshotExecutorImpl.installSnapshot(RpcRequests.InstallSnapshotRequest request,
RpcRequests.InstallSnapshotResponse.Builder response,
RpcRequestClosure done) |
Copyright © 2024. All rights reserved.