| Interface | Description |
|---|---|
| IChannelConnect | |
| IChannelDialer | |
| IChannelProcessor | |
| IChannelProcessorFactory | |
| ICheckpointer | |
| ITunnelWorker |
| Class | Description |
|---|---|
| ChannelConnect |
ChannelConnect维护数据消费的状态和所需的相关资源。
ChannelConnect的状态和其对应的Channel息息相关,对应的细节可参见:
TunnelStateMachine的说明。 |
| ChannelDialer | |
| ChannelProcessFactory |
带记录数据消费位点功能的Channel数据处理器的工厂类。
|
| Checkpointer |
Checkpoint记录器,用于Channel(向服务器)记录数据消费位点。
|
| DefaultChannelProcessor | |
| FailedChannelConnect | |
| ProcessRecordsInput | |
| ReadRecordsPipeResult | |
| TunnelClientConfig | |
| TunnelStateMachine |
TunnelStateMachine用于Channel和ChannelConnect状态的维护和更新(包括本机内存以及和Tunnel服务端的交互)。
Channel的状态有五类: WAIT, OPEN, CLOSING, CLOSE, TERMINATED。Channel状态的说明如下:
1.
|
| TunnelWorker |
TunnelWorker是基于TableStore数据接口之上的全增量一体化服务,用户可以简单地实现对表中历史存量和新增数据的消费处理。
TunnelWorker的设计哲学是通过每一轮的定时心跳探测(Heartbeat)来进行活跃Channel的探测,Channel和ChannelConnect状态的更新,数据处理任务的初始化、运行和结束等。
TunnelWorker实现自动化数据处理的流程如下:
1.
|
| TunnelWorkerConfig |
TunnelWorker的自定义配置。
|
| Enum | Description |
|---|---|
| ChannelConnectStatus | |
| TunnelWorkerStatus |
| Exception | Description |
|---|---|
| TunnelWorkerException |
Copyright © 2024. All Rights Reserved.