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 and 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

Modifier and Type	Method and Description
void	close()
org.tikv.kvproto.Coprocessor.KeyRange	getKeyRange()
org.tikv.common.region.TiRegion	getRegion()
org.tikv.kvproto.Coprocessor.KeyRange	getRegionKeyRange()
boolean	isRunning()
void	onCompleted()
void	onError(Throwable error)
void	onNext(org.tikv.kvproto.Cdcpb.ChangeDataEvent event)
boolean	regionEnclosed()
void	setRegion(org.tikv.common.region.TiRegion region)
void	start(long startTs)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RegionCDCClient

public 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 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:

close in interface AutoCloseable

Throws:

Exception

onCompleted

public void onCompleted()

Specified by:

onCompleted in interface org.tikv.shade.io.grpc.stub.StreamObserver<org.tikv.kvproto.Cdcpb.ChangeDataEvent>

onError

public void onError(Throwable error)

Specified by:

onError in interface org.tikv.shade.io.grpc.stub.StreamObserver<org.tikv.kvproto.Cdcpb.ChangeDataEvent>

onNext

public void onNext(org.tikv.kvproto.Cdcpb.ChangeDataEvent event)

Specified by:

onNext in interface org.tikv.shade.io.grpc.stub.StreamObserver<org.tikv.kvproto.Cdcpb.ChangeDataEvent>