软件包 net.neoremind.fountain.eventposition

接口摘要

DisposeEventPosition	保存最后一个处理的mysql 事件所对应的gt id,重启或者数据源崩溃时从该id继续恢复数据读取。
DisposeEventPositionBridge	用于fountain-producer和fountain-consumer部署在同一个jvm中的场景，此时需要消费者来记录 当前已经成功处理的消息的gt id，使用该类来解耦生产者和消费者
EventPositionExtender	扩展已经同步的binlog的位置信息, 一般来讲需要存储binlog event的global transaction id,在使用原生row base binlog 的情况下,需要根据global transaction id转化为binlog file name和position。
GroupIdSyncPoint	支持groupId SyncPoint
SyncPoint	描述mysql的数据同步点，用来代替EventPosition.

类摘要

AbstractProxyDisposeEventPosition	抽象的代理DisposeEventPosition
AsyncFixedRateDisposeEventPosition	以固定的时间频率异步的存储同步点
BaiduGroupIdSyncPoint	描述百度mysql分支的group id
BinlogAndOffsetSyncPoint	描述传统row base binlog同步点
BinlogAndOffsetSyncPoint.MysqlSyncPoint	描述传统的mysql的同步点
DelayGroupIdDisposeEventPosition	延迟一般一个、最多两个事务记录同步点，同步点必须是GroupIdSyncPoint
DelayGtIdDisposeEventPosition	不用延迟直接存储GtId，针对MySQL5.6本身会Server，fountain会传递自己的executed gtid set，以GtIdSet中的GtId.intervalStart和 GtId.intervalEnd表示，这里面GtId.intervalEnd是个开区间，最后一个点会重新下发。
DisposeEventPositionBridgeImpl	实现DisposeEventPositionBridge接口。
GtId	MySQL 5.6版本之后使用的Global Transaction Id，简称为GtId。
GtIdSet	MySQL 5.6之后引入Gtid_set数据结构，目的是为了轻量级的记录大量的连续全局事务ID， 比如已经在从数据库上执行的全局事务ID, 或者主库上正在运行的全局事务ID。
GtIdSyncPoint	描述MySQL5.6版本的gtid同步点
LocalFileBinlogAndOffsetDisposeEventPosition	保存BinlogAndOffsetSyncPoint 类型syncpoint的实现
LocalFileDisposeEventPosition	采用本地文件来记录gt id的DisposeEventPosition 接口实现
LocalFileGtIdSetDisposeEventPosition	保存GtIdSyncPoint 类型syncpoint的实现
ReadonlyDisposeEventPosition	用于fountain-producer和fountaion-consumer在同一jvm中，producer使用该类只读取文件中 存储的gt id， 而不会记录gt id，记录gt id的行为交给consumer实现。
RegistableDisposeEventPosition	支持注册的DisposeEventPosition抽象实现