接口 | 说明 |
---|---|
IChannelConnect | |
IChannelDialer | |
IChannelProcessor | |
IChannelProcessorFactory | |
ICheckpointer | |
ITunnelWorker |
类 | 说明 |
---|---|
ChannelConnect |
ChannelConnect维护数据消费的状态和所需的相关资源。
|
ChannelDialer | |
ChannelProcessFactory |
带记录数据消费位点功能的Channel数据处理器的工厂类。
|
Checkpointer |
Checkpoint记录器,用于Channel(向服务器)记录数据消费位点。
|
DefaultChannelProcessor | |
FailedChannelConnect | |
ProcessRecordsInput | |
ReadRecordsPipeResult | |
TunnelClientConfig | |
TunnelStateMachine |
TunnelStateMachine用于Channel和ChannelConnect状态的维护和更新(包括本机内存以及和Tunnel服务端的交互)。
|
TunnelWorker |
TunnelWorker是基于TableStore数据接口之上的全增量一体化服务,用户可以简单地实现对表中历史存量和新增数据的消费处理。
|
TunnelWorkerConfig |
TunnelWorker的自定义配置。
|
枚举 | 说明 |
---|---|
ChannelConnectStatus | |
TunnelWorkerStatus |
异常错误 | 说明 |
---|---|
TunnelWorkerException |
Copyright © 2019. All Rights Reserved.