consumer

Documentation

Index

• func ClearPos(sid int) bool
• func ConsumeData(interval time.Duration)
• func GetPos(sid int) (string, string, uint32)
• func SavePos(sid int)

Functions

func ClearPos

func ClearPos(sid int) bool

ClearPos 删除同步的位置点， 在mysql 发生failover 时使用

func ConsumeData

func ConsumeData(interval time.Duration)

ConsumeData 消费mysql 的变更

func GetPos

func GetPos(sid int) (string, string, uint32)

GetPos 获取解析到的位置点

func SavePos

func SavePos(sid int)

SavePos 异步将解析到的位置点写到数据库中