Documentation
¶
Index ¶
- type CheckPoint
- type Mysql
- func (m *Mysql) CheckPointToString() string
- func (m *Mysql) Collect(collector ilogtail.Collector) error
- func (m *Mysql) Description() string
- func (m *Mysql) Init(context ilogtail.Context) (int, error)
- func (m *Mysql) InitCheckPointFromString(val string)
- func (m *Mysql) ParseRows(rows *sql.Rows, collector ilogtail.Collector) int
- func (m *Mysql) SaveCheckPoint(collector ilogtail.Collector)
- func (m *Mysql) Start(collector ilogtail.Collector) error
- func (m *Mysql) Stop() error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CheckPoint ¶
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 (*Mysql) Description ¶
func (*Mysql) InitCheckPointFromString ¶
func (*Mysql) SaveCheckPoint ¶
Click to show internal directories.
Click to hide internal directories.