observer

Documentation

Index

• type BaseObserver
• type MySQLDest
• type MySQLObserver
  • func NewMySQLObserver(dsts []MySQLDest) (*MySQLObserver, error)
  • func (o *MySQLObserver) OnEvent(evt *binlog.Event) error
• type NotifyChain
  • func (c *NotifyChain) AddObserver(ob Observer)
  • func (c *NotifyChain) Broadcast(evt *binlog.Event) error
  • func (c *NotifyChain) RemoveObserver(ob Observer)
• type Observer

Types

type BaseObserver

type BaseObserver struct {
	// contains filtered or unexported fields
}

BaseObserver implement the Observer GetID and SetID method

type MySQLDest

type MySQLDest struct {
	Host     string
	Port     uint16
	Username string
	Password string
	Charset  string
	Text     bool
}

MySQLDest is the config show how to synchronize binlog data to destinate MySQL

type MySQLObserver

type MySQLObserver struct {
	BaseObserver
	// contains filtered or unexported fields
}

MySQLObserver observe binlog events and translate to SQL statement, and execute to destinate database

func NewMySQLObserver

func NewMySQLObserver(dsts []MySQLDest) (*MySQLObserver, error)

NewMySQLObserver create an observer observe binlog event and synchronize to MySQL

func (*MySQLObserver) OnEvent

func (o *MySQLObserver) OnEvent(evt *binlog.Event) error

type NotifyChain

type NotifyChain struct {
	// contains filtered or unexported fields
}

NotifyChain holds observers and notify them if event happened

func (*NotifyChain) AddObserver

func (c *NotifyChain) AddObserver(ob Observer)

AddObserver add a observer to the chain

func (*NotifyChain) Broadcast

func (c *NotifyChain) Broadcast(evt *binlog.Event) error

Broadcast notify all observer event occurs

func (*NotifyChain) RemoveObserver

func (c *NotifyChain) RemoveObserver(ob Observer)

RemoveObserver remove a observer from the chain

type Observer

type Observer interface {
	OnEvent(*binlog.Event) error
	GetID() int
	SetID(int)
}

Observer can observe binlog event