mysql

Documentation

Index

• type CheckPoint
• type Mysql
  • func (m *Mysql) CheckPointToString() string
  • func (m *Mysql) Collect(collector pipeline.Collector) error
  • func (m *Mysql) Description() string
  • func (m *Mysql) Init(context pipeline.Context) (int, error)
  • func (m *Mysql) InitCheckPointFromString(val string)
  • func (m *Mysql) ParseRows(rows *sql.Rows, collector pipeline.Collector) int
  • func (m *Mysql) SaveCheckPoint(collector pipeline.Collector)
  • func (m *Mysql) Start(collector pipeline.Collector) error
  • func (m *Mysql) Stop() error

Types

type CheckPoint

type CheckPoint struct {
	CheckPointColumn     string
	CheckPointColumnType string
	Value                string
	LastUpdateTime       time.Time
}

type Mysql

type Mysql struct {
	DefaultCharset        string
	ColumnsCharset        map[string]string
	ColumnsHash           map[string]string
	ConnectionRetryTime   int
	ConnectionRetryWaitMs int
	Driver                string
	Net                   string
	Address               string
	DataBase              string
	User                  string
	Password              string
	PasswordPath          string
	Location              string
	DialTimeOutMs         int
	ReadTimeOutMs         int
	Limit                 bool
	PageSize              int
	MaxSyncSize           int
	StateMent             string
	StateMentPath         string
	CheckPoint            bool
	CheckPointColumn      string
	// int or time
	CheckPointColumnType  string
	CheckPointStart       string
	CheckPointSavePerPage bool
	IntervalMs            int
	SSLCA                 string
	SSLCert               string
	SSLKey                string
	// contains filtered or unexported fields
}

func (*Mysql) CheckPointToString

func (m *Mysql) CheckPointToString() string

func (*Mysql) Collect

func (m *Mysql) Collect(collector pipeline.Collector) error

func (*Mysql) Description

func (m *Mysql) Description() string

func (*Mysql) Init

func (m *Mysql) Init(context pipeline.Context) (int, error)

func (*Mysql) InitCheckPointFromString

func (m *Mysql) InitCheckPointFromString(val string)

func (*Mysql) ParseRows

func (m *Mysql) ParseRows(rows *sql.Rows, collector pipeline.Collector) int

func (*Mysql) SaveCheckPoint

func (m *Mysql) SaveCheckPoint(collector pipeline.Collector)

func (*Mysql) Start

func (m *Mysql) Start(collector pipeline.Collector) error

Start starts the ServiceInput's service, whatever that may be

func (*Mysql) Stop

func (m *Mysql) Stop() error

Stop stops the services and closes any necessary channels and connections