README
¶
binlog_monitor
This project combines bin-log from mysql, mq.
It will send message to specific topic when bin-log is appended. And also provide receiver sdk to help you to consume message.
Documentation
¶
Index ¶
- type ActionType
- type BinLogMessage
- type Client
- func (c *Client) Register(tableName, topic string, action ActionType)
- func (c *Client) SetOnDDLHandler(funcHandler OnDDLHandler)
- func (c *Client) SetOnGTIDHandler(funcHandler OnGTIDHandler)
- func (c *Client) SetOnPosSyncedHandler(funcHandler OnPosSyncedHandler)
- func (c *Client) SetOnRotateHandler(funcHandler OnRotateHandler)
- func (c *Client) SetOnRowHandler(funcHandler OnRowHandler)
- func (c *Client) SetOnTableChangedHandler(funcHandler OnTableChangedHandler)
- func (c *Client) SetOnXIDHandler(funcHandler OnXIDHandler)
- func (c *Client) Start()
- func (c *Client) StartWithPos(pos *mysql.Position)
- func (c *Client) Stop()
- type OnDDLHandler
- type OnGTIDHandler
- type OnPosSyncedHandler
- type OnRotateHandler
- type OnRowHandler
- type OnTableChangedHandler
- type OnXIDHandler
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ActionType ¶
type ActionType int
const ( Unknown ActionType = iota Delete ActionType = 1 Insert ActionType = 2 Update ActionType = 3 Any ActionType = 4 )
func GetAction ¶
func GetAction(str string) ActionType
type BinLogMessage ¶
type BinLogMessage struct {
TableName string
DBName string
Action ActionType
Data [][]interface{}
}
type Client ¶
type Client struct {
Handler *monitorHandler
// contains filtered or unexported fields
}
func GetClientWithConfig ¶
func GetDefaultClient ¶
func GetDefaultClient() *Client
func (*Client) Register ¶
func (c *Client) Register(tableName, topic string, action ActionType)
func (*Client) SetOnDDLHandler ¶
func (c *Client) SetOnDDLHandler(funcHandler OnDDLHandler)
func (*Client) SetOnGTIDHandler ¶
func (c *Client) SetOnGTIDHandler(funcHandler OnGTIDHandler)
func (*Client) SetOnPosSyncedHandler ¶
func (c *Client) SetOnPosSyncedHandler(funcHandler OnPosSyncedHandler)
func (*Client) SetOnRotateHandler ¶
func (c *Client) SetOnRotateHandler(funcHandler OnRotateHandler)
func (*Client) SetOnRowHandler ¶
func (c *Client) SetOnRowHandler(funcHandler OnRowHandler)
func (*Client) SetOnTableChangedHandler ¶
func (c *Client) SetOnTableChangedHandler(funcHandler OnTableChangedHandler)
func (*Client) SetOnXIDHandler ¶
func (c *Client) SetOnXIDHandler(funcHandler OnXIDHandler)
func (*Client) StartWithPos ¶
type OnDDLHandler ¶
type OnDDLHandler func(nextPos mysql.Position, queryEvent *replication.QueryEvent) error
type OnGTIDHandler ¶
type OnPosSyncedHandler ¶
type OnRotateHandler ¶
type OnRotateHandler func(r *replication.RotateEvent) error
type OnRowHandler ¶
type OnTableChangedHandler ¶
type OnXIDHandler ¶
Source Files
Click to show internal directories.
Click to hide internal directories.