|
||||||||||
| 上一个 下一个 | 框架 无框架 | |||||||||
| 使用 BaseLogEvent 的软件包 | |
|---|---|
| net.neoremind.fountain.event | |
| net.neoremind.fountain.rowbaselog.event | |
| net.neoremind.fountain.support | |
| net.neoremind.fountain.event 中 BaseLogEvent 的使用 |
|---|
| 返回 BaseLogEvent 的 net.neoremind.fountain.event 中的方法 | |
|---|---|
abstract BaseLogEvent |
BaseLogEvent.parseData(ByteBuffer buf)
解析二进制数据填充event属性数据 |
| net.neoremind.fountain.rowbaselog.event 中 BaseLogEvent 的使用 |
|---|
| net.neoremind.fountain.rowbaselog.event 中 BaseLogEvent 的子类 | |
|---|---|
class |
FormatDescriptionEvent
binlog format描述事件,在v4版本的binlog文件中,第一个event就是FORMAT_DESCRIPTION_EVENT, 它描述了接下来其他的event是如何layed out的。 |
class |
GtidEvent
GTID event 对于MySQL5.6.5及之后的版本,如果GTID_MODE = ON, 每个事务的replicate都会前置一个type code= EventConstant.GTID_EVENT的事件。 |
class |
QueryLogEvent
|
class |
RotateEvent
binlog文件的结尾,通常(只要master不当机)就是ROTATE_EVENT或者STOP_EVENT |
class |
RowsLogEvent
|
class |
RowsLogEventV1
|
class |
RowsLogEventV2
|
class |
StopEvent
binlog文件的结尾,通常(只要master不当机)就是ROTATE_EVENT或者STOP_EVENT |
class |
TableMapEvent
|
class |
UnkownBinlogEvent
|
class |
XidLogEvent
Transaction ID for 2PC, written whenever a COMMIT is expected. |
| 返回 BaseLogEvent 的 net.neoremind.fountain.rowbaselog.event 中的方法 | |
|---|---|
BaseLogEvent |
XidLogEvent.parseData(ByteBuffer buf)
|
BaseLogEvent |
UnkownBinlogEvent.parseData(ByteBuffer buf)
|
BaseLogEvent |
TableMapEvent.parseData(ByteBuffer buf)
|
BaseLogEvent |
StopEvent.parseData(ByteBuffer buf)
|
BaseLogEvent |
RowsLogEvent.parseData(ByteBuffer buf)
|
BaseLogEvent |
RotateEvent.parseData(ByteBuffer buf)
|
BaseLogEvent |
QueryLogEvent.parseData(ByteBuffer buf)
|
BaseLogEvent |
GtidEvent.parseData(ByteBuffer buf)
|
BaseLogEvent |
FormatDescriptionEvent.parseData(ByteBuffer buf)
|
| net.neoremind.fountain.support 中 BaseLogEvent 的使用 |
|---|
| 类型参数类型为 BaseLogEvent 的 net.neoremind.fountain.support 中的类 | |
|---|---|
interface |
EventCallback<T extends BaseLogEvent>
BaseLogEvent处理的回调接口 |
| 参数类型为 BaseLogEvent 的 net.neoremind.fountain.support 中的方法 | |
|---|---|
void |
EventListener.handle(BaseLogEvent event,
TrxContext trxContext)
当fountain接收到某个binlog event时候会根据具体类型,找到回调器,然后调用,一般会设置一些变量信息到 TrxContext中 |
void |
TrxContext.handleEvent(BaseLogEvent event)
|
| 类型变量类型为 BaseLogEvent 的 net.neoremind.fountain.support 中的方法参数 | |
|---|---|
void |
EventListener.addCallback(Class<? extends BaseLogEvent> clazz,
EventCallback cb)
为某种binlog event添加回调 |
|
||||||||||
| 上一个 下一个 | 框架 无框架 | |||||||||