binlog

Interface CisternGrpc.AsyncService

All Known Implementing Classes:

CisternGrpc.CisternImplBase

Enclosing class:

CisternGrpc

public static interface CisternGrpc.AsyncService

 Interfaces exported by CisternServer.
 

Method Summary

Modifier and Type	Method and Description
default void	dumpBinlog(CisternOuterClass.DumpBinlogReq request, io.grpc.stub.StreamObserver<CisternOuterClass.DumpBinlogResp> responseObserver) DumpBinlog dumps continuous binlog items in a stream from a given position
default void	dumpDDLJobs(CisternOuterClass.DumpDDLJobsReq request, io.grpc.stub.StreamObserver<CisternOuterClass.DumpDDLJobsResp> responseObserver) DumpDDLJobs dumps all history DDL jobs before a specified commitTS
default void	notify(CisternOuterClass.NotifyReq request, io.grpc.stub.StreamObserver<CisternOuterClass.NotifyResp> responseObserver) Notify notifies all living cisterns that a new pump is coming the living cisterns can be queried from pd

Method Detail

dumpBinlog

default void dumpBinlog(CisternOuterClass.DumpBinlogReq request,
                        io.grpc.stub.StreamObserver<CisternOuterClass.DumpBinlogResp> responseObserver)

 DumpBinlog dumps continuous binlog items in a stream from a given position
 

dumpDDLJobs

default void dumpDDLJobs(CisternOuterClass.DumpDDLJobsReq request,
                         io.grpc.stub.StreamObserver<CisternOuterClass.DumpDDLJobsResp> responseObserver)

 DumpDDLJobs dumps all history DDL jobs before a specified commitTS
 

notify

default void notify(CisternOuterClass.NotifyReq request,
                    io.grpc.stub.StreamObserver<CisternOuterClass.NotifyResp> responseObserver)

 Notify notifies all living cisterns that a new pump is coming
 the living cisterns can be queried from pd