mysql

Documentation

Index

• Variables
• type CDC
  • func NewCDC(options *Options) (*CDC, error)
  • func (cdc *CDC) Listen() error
• type Options
• type Table
• type TableHandlerFunc

Variables

var DefaultWriter io.Writer = os.Stdout

Types

type CDC

type CDC struct {
	Options Options
	// contains filtered or unexported fields
}

func NewCDC

func NewCDC(options *Options) (*CDC, error)

func (*CDC) Listen

func (cdc *CDC) Listen() error

type Options

type Options struct {
	Host     string // default, "127.0.0.1"
	Port     int    // default, 3306
	User     string // default, root
	Password string
	Database string
	Tables   []Table
	Flavor   string // flavor is mysql or mariadb, default mysql
	ServerID uint32
}

type Table

type Table struct {
	Name        string
	HandlerFunc TableHandlerFunc
}

type TableHandlerFunc

type TableHandlerFunc func(oldItem map[string]interface{}, newItem map[string]interface{}, table string)