Package org.tikv.cdc
Class RegionCDCClient
- java.lang.Object
-
- org.tikv.cdc.RegionCDCClient
-
- All Implemented Interfaces:
AutoCloseable,org.tikv.shade.io.grpc.stub.StreamObserver<org.tikv.kvproto.Cdcpb.ChangeDataEvent>
public class RegionCDCClient extends Object implements AutoCloseable, org.tikv.shade.io.grpc.stub.StreamObserver<org.tikv.kvproto.Cdcpb.ChangeDataEvent>
Copied from https://github.com/tikv/client-java project to fix https://github.com/tikv/client-java/issues/600 for 3.2.0 version.
-
-
Constructor Summary
Constructors Constructor Description RegionCDCClient(org.tikv.common.region.TiRegion region, org.tikv.kvproto.Coprocessor.KeyRange keyRange, org.tikv.shade.io.grpc.ManagedChannel channel, java.util.function.Consumer<org.tikv.cdc.CDCEvent> eventConsumer, org.tikv.cdc.CDCConfig config)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidclose()org.tikv.kvproto.Coprocessor.KeyRangegetKeyRange()org.tikv.common.region.TiRegiongetRegion()org.tikv.kvproto.Coprocessor.KeyRangegetRegionKeyRange()booleanisRunning()voidonCompleted()voidonError(Throwable error)voidonNext(org.tikv.kvproto.Cdcpb.ChangeDataEvent event)booleanregionEnclosed()voidsetRegion(org.tikv.common.region.TiRegion region)voidstart(long startTs)
-
-
-
Method Detail
-
start
public void start(long startTs)
-
getRegion
public org.tikv.common.region.TiRegion getRegion()
-
setRegion
public void setRegion(org.tikv.common.region.TiRegion region)
-
getKeyRange
public org.tikv.kvproto.Coprocessor.KeyRange getKeyRange()
-
getRegionKeyRange
public org.tikv.kvproto.Coprocessor.KeyRange getRegionKeyRange()
-
regionEnclosed
public boolean regionEnclosed()
-
isRunning
public boolean isRunning()
-
close
public void close() throws Exception- Specified by:
closein interfaceAutoCloseable- Throws:
Exception
-
onCompleted
public void onCompleted()
- Specified by:
onCompletedin interfaceorg.tikv.shade.io.grpc.stub.StreamObserver<org.tikv.kvproto.Cdcpb.ChangeDataEvent>
-
onError
public void onError(Throwable error)
- Specified by:
onErrorin interfaceorg.tikv.shade.io.grpc.stub.StreamObserver<org.tikv.kvproto.Cdcpb.ChangeDataEvent>
-
onNext
public void onNext(org.tikv.kvproto.Cdcpb.ChangeDataEvent event)
- Specified by:
onNextin interfaceorg.tikv.shade.io.grpc.stub.StreamObserver<org.tikv.kvproto.Cdcpb.ChangeDataEvent>
-
-