Documentation ¶
Index ¶
- type Sync
- func (s *Sync) GetMasterPos() (mysql.Position, error)
- func (s *Sync) Monitor() error
- func (s *Sync) QueryEventProcess(event *replication.BinlogEvent, queryEvent *replication.QueryEvent) error
- func (s *Sync) RotateEventProcess(event *replication.BinlogEvent, rotateEvent *replication.RotateEvent) error
- func (s *Sync) RowsEventProcess(action string, event *replication.BinlogEvent, ...) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Sync ¶
type Sync struct {
// contains filtered or unexported fields
}
Sync 同步模块
func (*Sync) GetMasterPos ¶
GetMasterPos 获取 Master Pos信息
func (*Sync) QueryEventProcess ¶
func (s *Sync) QueryEventProcess(event *replication.BinlogEvent, queryEvent *replication.QueryEvent) error
func (*Sync) RotateEventProcess ¶
func (s *Sync) RotateEventProcess(event *replication.BinlogEvent, rotateEvent *replication.RotateEvent) error
func (*Sync) RowsEventProcess ¶
func (s *Sync) RowsEventProcess(action string, event *replication.BinlogEvent, rowsEvent *replication.RowsEvent) error
Click to show internal directories.
Click to hide internal directories.