A C D G I N P R S U W

A

ack(long) - 接口 中的方法com.alibaba.otter.canal.client.CanalConnector

进行 batch id 的确认。

ack(long) - 类 中的方法com.alibaba.otter.canal.client.impl.ClusterCanalConnector

ack(long) - 类 中的方法com.alibaba.otter.canal.client.impl.SimpleCanalConnector

C

CanalConnector - com.alibaba.otter.canal.client中的接口

canal数据操作客户端

CanalConnectors - com.alibaba.otter.canal.client中的类

canal connectors创建工具类

CanalConnectors() - 类 的构造器com.alibaba.otter.canal.client.CanalConnectors

CanalNodeAccessStrategy - com.alibaba.otter.canal.client中的接口

集群节点访问控制接口

check() - 类 中的方法com.alibaba.otter.canal.client.impl.running.ClientRunningMonitor

检查当前的状态

checkValid() - 接口 中的方法com.alibaba.otter.canal.client.CanalConnector

检查下链接是否合法 几种case下链接不合法: 1.

checkValid() - 类 中的方法com.alibaba.otter.canal.client.impl.ClusterCanalConnector

checkValid() - 类 中的方法com.alibaba.otter.canal.client.impl.SimpleCanalConnector

ClientRunningData - com.alibaba.otter.canal.client.impl.running中的类

client running状态信息

ClientRunningData() - 类 的构造器com.alibaba.otter.canal.client.impl.running.ClientRunningData

ClientRunningListener - com.alibaba.otter.canal.client.impl.running中的接口

触发一下mainstem发生切换

ClientRunningMonitor - com.alibaba.otter.canal.client.impl.running中的类

clinet running控制

ClientRunningMonitor() - 类 的构造器com.alibaba.otter.canal.client.impl.running.ClientRunningMonitor

ClusterCanalConnector - com.alibaba.otter.canal.client.impl中的类

集群版本connector实现，自带了failover功能

ClusterCanalConnector(String, String, String, CanalNodeAccessStrategy) - 类 的构造器com.alibaba.otter.canal.client.impl.ClusterCanalConnector

ClusterNodeAccessStrategy - com.alibaba.otter.canal.client.impl中的类

集群模式的调度策略

ClusterNodeAccessStrategy(String, ZkClientx) - 类 的构造器com.alibaba.otter.canal.client.impl.ClusterNodeAccessStrategy

com.alibaba.otter.canal.client - 程序包 com.alibaba.otter.canal.client

com.alibaba.otter.canal.client.impl - 程序包 com.alibaba.otter.canal.client.impl

com.alibaba.otter.canal.client.impl.running - 程序包 com.alibaba.otter.canal.client.impl.running

connect() - 接口 中的方法com.alibaba.otter.canal.client.CanalConnector

链接对应的canal server

connect() - 类 中的方法com.alibaba.otter.canal.client.impl.ClusterCanalConnector

connect() - 类 中的方法com.alibaba.otter.canal.client.impl.SimpleCanalConnector

D

disconnect() - 接口 中的方法com.alibaba.otter.canal.client.CanalConnector

释放链接

disconnect() - 类 中的方法com.alibaba.otter.canal.client.impl.ClusterCanalConnector

disconnect() - 类 中的方法com.alibaba.otter.canal.client.impl.SimpleCanalConnector

G

get(int) - 接口 中的方法com.alibaba.otter.canal.client.CanalConnector

获取数据，自动进行确认，该方法返回的条件：尝试拿batchSize条记录，有多少取多少，不会阻塞等待

get(int, Long, TimeUnit) - 接口 中的方法com.alibaba.otter.canal.client.CanalConnector

获取数据，自动进行确认 该方法返回的条件： a.

get(int) - 类 中的方法com.alibaba.otter.canal.client.impl.ClusterCanalConnector

get(int, Long, TimeUnit) - 类 中的方法com.alibaba.otter.canal.client.impl.ClusterCanalConnector

get(int) - 类 中的方法com.alibaba.otter.canal.client.impl.SimpleCanalConnector

get(int, Long, TimeUnit) - 类 中的方法com.alibaba.otter.canal.client.impl.SimpleCanalConnector

getAccessStrategy() - 类 中的方法com.alibaba.otter.canal.client.impl.ClusterCanalConnector

getAddress() - 类 中的方法com.alibaba.otter.canal.client.impl.running.ClientRunningData

getAddress() - 类 中的方法com.alibaba.otter.canal.client.impl.SimpleCanalConnector

getClientId() - 类 中的方法com.alibaba.otter.canal.client.impl.running.ClientRunningData

getCurrentConnector() - 类 中的方法com.alibaba.otter.canal.client.impl.ClusterCanalConnector

getPassword() - 类 中的方法com.alibaba.otter.canal.client.impl.ClusterCanalConnector

getPassword() - 类 中的方法com.alibaba.otter.canal.client.impl.SimpleCanalConnector

getRetryInterval() - 类 中的方法com.alibaba.otter.canal.client.impl.ClusterCanalConnector

getRetryTimes() - 类 中的方法com.alibaba.otter.canal.client.impl.ClusterCanalConnector

getSoTimeout() - 类 中的方法com.alibaba.otter.canal.client.impl.ClusterCanalConnector

getSoTimeout() - 类 中的方法com.alibaba.otter.canal.client.impl.SimpleCanalConnector

getUsername() - 类 中的方法com.alibaba.otter.canal.client.impl.ClusterCanalConnector

getUsername() - 类 中的方法com.alibaba.otter.canal.client.impl.SimpleCanalConnector

getWithoutAck(int) - 接口 中的方法com.alibaba.otter.canal.client.CanalConnector

不指定 position 获取事件，该方法返回的条件: 尝试拿batchSize条记录，有多少取多少，不会阻塞等待
canal 会记住此 client 最新的position。

getWithoutAck(int, Long, TimeUnit) - 接口 中的方法com.alibaba.otter.canal.client.CanalConnector

不指定 position 获取事件.

getWithoutAck(int) - 类 中的方法com.alibaba.otter.canal.client.impl.ClusterCanalConnector

getWithoutAck(int, Long, TimeUnit) - 类 中的方法com.alibaba.otter.canal.client.impl.ClusterCanalConnector

getWithoutAck(int) - 类 中的方法com.alibaba.otter.canal.client.impl.SimpleCanalConnector

getWithoutAck(int, Long, TimeUnit) - 类 中的方法com.alibaba.otter.canal.client.impl.SimpleCanalConnector

getZkClient() - 类 中的方法com.alibaba.otter.canal.client.impl.ClusterNodeAccessStrategy

I

initRunning() - 类 中的方法com.alibaba.otter.canal.client.impl.running.ClientRunningMonitor

isActive() - 类 中的方法com.alibaba.otter.canal.client.impl.running.ClientRunningData

N

newClusterConnector(List<? extends SocketAddress>, String, String, String) - 类 中的静态方法com.alibaba.otter.canal.client.CanalConnectors

创建带cluster模式的客户端链接，自动完成failover切换

newClusterConnector(String, String, String, String) - 类 中的静态方法com.alibaba.otter.canal.client.CanalConnectors

创建带cluster模式的客户端链接，自动完成failover切换，服务器列表自动扫描

newSingleConnector(SocketAddress, String, String, String) - 类 中的静态方法com.alibaba.otter.canal.client.CanalConnectors

创建单链接的客户端链接

nextNode() - 接口 中的方法com.alibaba.otter.canal.client.CanalNodeAccessStrategy

nextNode() - 类 中的方法com.alibaba.otter.canal.client.impl.ClusterNodeAccessStrategy

nextNode() - 类 中的方法com.alibaba.otter.canal.client.impl.SimpleNodeAccessStrategy

P

processActiveEnter() - 接口 中的方法com.alibaba.otter.canal.client.impl.running.ClientRunningListener

触发现在轮到自己做为active，需要载入上一个active的上下文数据

processActiveExit() - 接口 中的方法com.alibaba.otter.canal.client.impl.running.ClientRunningListener

触发一下当前active模式失败

R

releaseRunning() - 类 中的方法com.alibaba.otter.canal.client.impl.running.ClientRunningMonitor

rollback(long) - 接口 中的方法com.alibaba.otter.canal.client.CanalConnector

回滚到未进行 ack 的地方，指定回滚具体的batchId

rollback() - 接口 中的方法com.alibaba.otter.canal.client.CanalConnector

回滚到未进行 ack 的地方，下次fetch的时候，可以从最后一个没有 ack 的地方开始拿

rollback(long) - 类 中的方法com.alibaba.otter.canal.client.impl.ClusterCanalConnector

rollback() - 类 中的方法com.alibaba.otter.canal.client.impl.ClusterCanalConnector

rollback(long) - 类 中的方法com.alibaba.otter.canal.client.impl.SimpleCanalConnector

rollback() - 类 中的方法com.alibaba.otter.canal.client.impl.SimpleCanalConnector

S

setAccessStrategy(CanalNodeAccessStrategy) - 类 中的方法com.alibaba.otter.canal.client.impl.ClusterCanalConnector

setActive(boolean) - 类 中的方法com.alibaba.otter.canal.client.impl.running.ClientRunningData

setAddress(String) - 类 中的方法com.alibaba.otter.canal.client.impl.running.ClientRunningData

setClientData(ClientRunningData) - 类 中的方法com.alibaba.otter.canal.client.impl.running.ClientRunningMonitor

setClientId(short) - 类 中的方法com.alibaba.otter.canal.client.impl.running.ClientRunningData

setDelayTime(int) - 类 中的方法com.alibaba.otter.canal.client.impl.running.ClientRunningMonitor

setDestination(String) - 类 中的方法com.alibaba.otter.canal.client.impl.running.ClientRunningMonitor

setListener(ClientRunningListener) - 类 中的方法com.alibaba.otter.canal.client.impl.running.ClientRunningMonitor

setPassword(String) - 类 中的方法com.alibaba.otter.canal.client.impl.ClusterCanalConnector

setRetryInterval(int) - 类 中的方法com.alibaba.otter.canal.client.impl.ClusterCanalConnector

setRetryTimes(int) - 类 中的方法com.alibaba.otter.canal.client.impl.ClusterCanalConnector

setRollbackOnConnect(boolean) - 类 中的方法com.alibaba.otter.canal.client.impl.SimpleCanalConnector

setRollbackOnDisConnect(boolean) - 类 中的方法com.alibaba.otter.canal.client.impl.SimpleCanalConnector

setSoTimeout(int) - 类 中的方法com.alibaba.otter.canal.client.impl.ClusterCanalConnector

setSoTimeout(int) - 类 中的方法com.alibaba.otter.canal.client.impl.SimpleCanalConnector

setUsername(String) - 类 中的方法com.alibaba.otter.canal.client.impl.ClusterCanalConnector

setZkClient(ZkClientx) - 类 中的方法com.alibaba.otter.canal.client.impl.ClusterNodeAccessStrategy

setZkClient(ZkClientx) - 类 中的方法com.alibaba.otter.canal.client.impl.running.ClientRunningMonitor

setZkClientx(ZkClientx) - 类 中的方法com.alibaba.otter.canal.client.impl.SimpleCanalConnector

SimpleCanalConnector - com.alibaba.otter.canal.client.impl中的类

基于CanalServerWithNetty定义的网络协议接口，对于canal数据进行get/rollback/ack等操作

SimpleCanalConnector(SocketAddress, String, String, String) - 类 的构造器com.alibaba.otter.canal.client.impl.SimpleCanalConnector

SimpleCanalConnector(SocketAddress, String, String, String, int) - 类 的构造器com.alibaba.otter.canal.client.impl.SimpleCanalConnector

SimpleNodeAccessStrategy - com.alibaba.otter.canal.client.impl中的类

简单版本的node访问实现

SimpleNodeAccessStrategy(List<? extends SocketAddress>) - 类 的构造器com.alibaba.otter.canal.client.impl.SimpleNodeAccessStrategy

start() - 类 中的方法com.alibaba.otter.canal.client.impl.running.ClientRunningMonitor

stop() - 类 中的方法com.alibaba.otter.canal.client.impl.running.ClientRunningMonitor

subscribe(String) - 接口 中的方法com.alibaba.otter.canal.client.CanalConnector

客户端订阅，重复订阅时会更新对应的filter信息 说明： a.

subscribe() - 接口 中的方法com.alibaba.otter.canal.client.CanalConnector

客户端订阅，不提交客户端filter，以服务端的filter为准

subscribe() - 类 中的方法com.alibaba.otter.canal.client.impl.ClusterCanalConnector

subscribe(String) - 类 中的方法com.alibaba.otter.canal.client.impl.ClusterCanalConnector

subscribe() - 类 中的方法com.alibaba.otter.canal.client.impl.SimpleCanalConnector

subscribe(String) - 类 中的方法com.alibaba.otter.canal.client.impl.SimpleCanalConnector

U

unsubscribe() - 接口 中的方法com.alibaba.otter.canal.client.CanalConnector

取消订阅

unsubscribe() - 类 中的方法com.alibaba.otter.canal.client.impl.ClusterCanalConnector

unsubscribe() - 类 中的方法com.alibaba.otter.canal.client.impl.SimpleCanalConnector

W

waitForActive() - 类 中的方法com.alibaba.otter.canal.client.impl.running.ClientRunningMonitor

阻塞等待自己成为active，如果自己成为active，立马返回

A C D G I N P R S U W