Versions in this module Expand all Collapse all v0 v0.1.0 Mar 16, 2023 Changes in this version + const DefaultFlushBatchSize + const DefaultFlushIntervalMS + const ErrorTypeRowDiff + const ErrorTypeRowMiss + const UpdateTimeTypeMilli + const UpdateTimeTypeNano + const UpdateTimeTypeSec + const UpdateTimeTypeTime + type MysqlCheckOutput struct + func NewMysqlCheckOutput() *MysqlCheckOutput + func (o *MysqlCheckOutput) Configure(config core.StringMap) (err error) + func (o *MysqlCheckOutput) Process(m *core.Message) + func (o *MysqlCheckOutput) Start() (err error) + func (o *MysqlCheckOutput) Stop() + type MysqlCheckOutputConfig struct + Host string + ID string + Password string + Port uint16 + ResultFilePath string + TableBufferSize int + TableFlushIntervalMS int64 + UpdateTimeColumn string + UpdateTimeSkipSeconds int64 + UpdateTimeType string + User string + type TableProcessor struct + func NewTableProcessor(db string, table string, output *MysqlCheckOutput) (*TableProcessor, error) + func (p *TableProcessor) Flush() + func (p *TableProcessor) Process(m *core.Message) + func (p *TableProcessor) Run()
Go to main page