public class RaftJournalServiceHandler extends RaftJournalServiceGrpc.RaftJournalServiceImplBase
Constructor and Description |
---|
RaftJournalServiceHandler(SnapshotReplicationManager manager) |
Modifier and Type | Method and Description |
---|---|
io.grpc.stub.StreamObserver<DownloadSnapshotPRequest> |
downloadSnapshot(io.grpc.stub.StreamObserver<DownloadSnapshotPResponse> responseObserver)
Downloads a snapshot from primary master.
|
io.grpc.stub.StreamObserver<UploadSnapshotPRequest> |
uploadSnapshot(io.grpc.stub.StreamObserver<UploadSnapshotPResponse> responseObserver)
Uploads a snapshot to primary master.
|
bindService
public RaftJournalServiceHandler(SnapshotReplicationManager manager)
manager
- the snapshot replication managerpublic io.grpc.stub.StreamObserver<UploadSnapshotPRequest> uploadSnapshot(io.grpc.stub.StreamObserver<UploadSnapshotPResponse> responseObserver)
RaftJournalServiceGrpc.RaftJournalServiceImplBase
Uploads a snapshot to primary master.
uploadSnapshot
in class RaftJournalServiceGrpc.RaftJournalServiceImplBase
public io.grpc.stub.StreamObserver<DownloadSnapshotPRequest> downloadSnapshot(io.grpc.stub.StreamObserver<DownloadSnapshotPResponse> responseObserver)
RaftJournalServiceGrpc.RaftJournalServiceImplBase
Downloads a snapshot from primary master.
downloadSnapshot
in class RaftJournalServiceGrpc.RaftJournalServiceImplBase
Copyright © 2023. All Rights Reserved.