Constructor and Description |
---|
PumpImplBase() |
Modifier and Type | Method and Description |
---|---|
io.grpc.ServerServiceDefinition |
bindService() |
void |
pullBinlogs(PumpOuterClass.PullBinlogReq request,
io.grpc.stub.StreamObserver<PumpOuterClass.PullBinlogResp> responseObserver)
Sends binlog stream from a given location.
|
void |
writeBinlog(PumpOuterClass.WriteBinlogReq request,
io.grpc.stub.StreamObserver<PumpOuterClass.WriteBinlogResp> responseObserver)
Writes a binlog to the local file on the pump machine.
|
public void writeBinlog(PumpOuterClass.WriteBinlogReq request, io.grpc.stub.StreamObserver<PumpOuterClass.WriteBinlogResp> responseObserver)
Writes a binlog to the local file on the pump machine. A response with an empty errmsg is returned if the binlog is written successfully.
public void pullBinlogs(PumpOuterClass.PullBinlogReq request, io.grpc.stub.StreamObserver<PumpOuterClass.PullBinlogResp> responseObserver)
Sends binlog stream from a given location.
public final io.grpc.ServerServiceDefinition bindService()
bindService
in interface io.grpc.BindableService
Copyright © 2023 PingCAP. All rights reserved.