output

Jan 27, 2024

Changes in this version

+ var RetryCount = 3

+ var RetryInterval = 5

Nov 22, 2023

Changes in this version

+ const DorisName

+ const MysqlName

+ const StarrocksName

type Doris

+ func (ds *Doris) Configure(pipelineName string, configOutput map[string]interface{}) error

type Mysql

+ func (m *Mysql) Configure(pipelineName string, configOutput map[string]interface{}) error

type Starrocks

+ func (sr *Starrocks) Configure(pipelineName string, configOutput map[string]interface{}) error

Oct 27, 2023

Changes in this version

+ type Mysql struct

+ func (m *Mysql) AddRule(config map[string]interface{}) error

+ func (m *Mysql) Close()

+ func (m *Mysql) DeleteRule(config map[string]interface{}) error

+ func (m *Mysql) Execute(msgs []*msg.Msg, table *schema.Table, targetSchema string, targetTable string) error

+ func (m *Mysql) ExecuteSQL(cmd string, args ...interface{}) (rr *mysql.Result, err error)

+ func (m *Mysql) GetRules() interface{}

+ func (m *Mysql) GetTable(db string, table string) (*schema.Table, error)

+ func (m *Mysql) IsPaused() bool

+ func (m *Mysql) NewOutput(outputConfig interface{}, rulesMap map[string]interface{}, ...)

+ func (m *Mysql) Pause() error

+ func (m *Mysql) Resume() error

+ func (m *Mysql) RewriteExecute(event *msg.Msg, table *schema.Table, targetSchema string, targetTable string) error

+ func (m *Mysql) StartMetrics()

+ func (m *Mysql) StartOutput(outputChan *channel.OutputChannel)

Aug 17, 2023

Changes in this version

type Doris

+ func (ds *Doris) IsPaused() bool

+ func (ds *Doris) Pause() error

+ func (ds *Doris) Resume() error

+ func (ds *Doris) SendData(content []string, table *schema.Table, targetSchema string, targetTable string, ...) error

type Plugin

+ IsPaused func() bool

+ Pause func() error

+ Resume func() error

type Starrocks

+ func (sr *Starrocks) IsPaused() bool

+ func (sr *Starrocks) Pause() error

+ func (sr *Starrocks) Resume() error

+ func (sr *Starrocks) SendData(content []string, table *schema.Table, targetSchema string, targetTable string, ...) error

Jul 3, 2023

Changes in this version

type Doris

+ func (ds *Doris) ExecuteSQL(cmd string, args ...interface{}) (rr *mysql.Result, err error)

type Starrocks

+ func (sr *Starrocks) ExecuteSQL(cmd string, args ...interface{}) (rr *mysql.Result, err error)

Jun 30, 2023

Changes in this version

+ var DeleteColumn = "_delete_sign_"

+ var DeleteCondition = fmt.Sprintf("%s=1", DeleteColumn)

+ type Doris struct

+ func (ds *Doris) AddRule(config map[string]interface{}) error

+ func (ds *Doris) Close()

+ func (ds *Doris) DeleteRule(config map[string]interface{}) error

+ func (ds *Doris) Execute(msgs []*msg.Msg, table *Table) error

+ func (ds *Doris) GetRules() interface{}

+ func (ds *Doris) GetTable(db string, table string) (*Table, error)

+ func (ds *Doris) NewOutput(outputConfig interface{})

+ func (ds *Doris) StartMetrics()

+ func (ds *Doris) StartOutput(outputChan *channel.OutputChannel, rulesMap map[string]interface{})

+ type Plugin interface

+ AddRule func(map[string]interface{}) error

+ Close func()

+ DeleteRule func(map[string]interface{}) error

+ Execute func(msgs []*msg.Msg, tableObj *Table) error

+ GetRules func() interface{}

+ NewOutput func(config interface{})

+ StartOutput func(outputChan *channel.OutputChannel, rulesMap map[string]interface{})

type Starrocks

+ func (sr *Starrocks) AddRule(config map[string]interface{}) error

+ func (sr *Starrocks) Close()

+ func (sr *Starrocks) DeleteRule(config map[string]interface{}) error

+ func (sr *Starrocks) GetRules() interface{}

+ func (sr *Starrocks) GetTable(db string, table string) (*Table, error)

+ func (sr *Starrocks) NewOutput(outputConfig interface{})

+ func (sr *Starrocks) StartMetrics()

+ func (sr *Starrocks) StartOutput(outputChan *channel.OutputChannel, rulesMap map[string]interface{})

+ type Table struct

+ Columns []string

+ Name string

+ Schema string

+ type TableColumn struct

+ Name string

Jun 7, 2023

Changes in this version

+ type Starrocks struct

+ func (sr *Starrocks) Execute(msgs []*msg.Msg, rule *rule.MysqlToSrRule, table *schema.Table) error

+ func (sr *Starrocks) MongoExecute(msgs []*msg.MongoMsg, rule *rule.MongoToSrRule, coll *msg.Coll) error