public static final class PumpGrpc.PumpStub extends io.grpc.stub.AbstractAsyncStub<PumpGrpc.PumpStub>
Interfaces exported by Pump.
Modifier and Type | Method and Description |
---|---|
protected PumpGrpc.PumpStub |
build(io.grpc.Channel channel,
io.grpc.CallOptions callOptions) |
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.
|
protected PumpGrpc.PumpStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
build
in class io.grpc.stub.AbstractStub<PumpGrpc.PumpStub>
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.
Copyright © 2024 PingCAP. All rights reserved.