output

Documentation

Index

• Constants
• Variables
• type Doris
  • func (ds *Doris) AddRule(config map[string]interface{}) error
  • func (ds *Doris) Close()
  • func (ds *Doris) Configure(pipelineName string, configOutput map[string]interface{}) error
  • func (ds *Doris) DeleteRule(config map[string]interface{}) error
  • func (ds *Doris) Execute(msgs []*msg.Msg, table *schema.Table, targetSchema string, targetTable string) error
  • func (ds *Doris) ExecuteSQL(cmd string, args ...interface{}) (rr *mysql.Result, err error)
  • func (ds *Doris) GetRules() interface{}
  • func (ds *Doris) GetTable(db string, table string) (*schema.Table, error)
  • func (ds *Doris) IsPaused() bool
  • func (ds *Doris) NewOutput(outputConfig interface{}, rulesMap map[string]interface{}, ...)
  • func (ds *Doris) Pause() error
  • func (ds *Doris) Resume() error
  • func (ds *Doris) SendData(content []string, table *schema.Table, targetSchema string, targetTable string, ...) error
  • func (ds *Doris) StartMetrics()
  • func (ds *Doris) StartOutput(outputChan *channel.OutputChannel)
• type Mysql
  • func (m *Mysql) AddRule(config map[string]interface{}) error
  • func (m *Mysql) Close()
  • func (m *Mysql) Configure(pipelineName string, configOutput map[string]interface{}) error
  • 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)
• type Starrocks
  • func (sr *Starrocks) AddRule(config map[string]interface{}) error
  • func (sr *Starrocks) Close()
  • func (sr *Starrocks) Configure(pipelineName string, configOutput map[string]interface{}) error
  • func (sr *Starrocks) DeleteRule(config map[string]interface{}) error
  • func (sr *Starrocks) Execute(msgs []*msg.Msg, table *schema.Table, targetSchema string, targetTable string) error
  • func (sr *Starrocks) ExecuteSQL(cmd string, args ...interface{}) (rr *mysql.Result, err error)
  • func (sr *Starrocks) GetRules() interface{}
  • func (sr *Starrocks) GetTable(db string, table string) (*schema.Table, error)
  • func (sr *Starrocks) IsPaused() bool
  • func (sr *Starrocks) NewOutput(outputConfig interface{}, rulesMap map[string]interface{}, ...)
  • func (sr *Starrocks) Pause() error
  • func (sr *Starrocks) Resume() error
  • func (sr *Starrocks) SendData(content []string, table *schema.Table, targetSchema string, targetTable string, ...) error
  • func (sr *Starrocks) StartMetrics()
  • func (sr *Starrocks) StartOutput(outputChan *channel.OutputChannel)

Constants

const DorisName = "doris"

const MysqlName = "mysql"

const StarrocksName = "starrocks"

Variables

var DeleteColumn = "_delete_sign_"

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

var RetryCount = 3

var RetryInterval = 5

Types

type Doris

type Doris struct {
	*config.DorisConfig
	// contains filtered or unexported fields
}

func (*Doris) AddRule

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

func (*Doris) Close

func (ds *Doris) Close()

func (*Doris) Configure

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

func (*Doris) DeleteRule

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

func (*Doris) Execute

func (ds *Doris) Execute(msgs []*msg.Msg, table *schema.Table, targetSchema string, targetTable string) error

func (*Doris) ExecuteSQL

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

func (*Doris) GetRules

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

func (*Doris) GetTable

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

func (*Doris) IsPaused

func (ds *Doris) IsPaused() bool

func (*Doris) NewOutput

func (ds *Doris) NewOutput(outputConfig interface{}, rulesMap map[string]interface{}, inSchema core.Schema)

func (*Doris) Pause

func (ds *Doris) Pause() error

func (*Doris) Resume

func (ds *Doris) Resume() error

func (*Doris) SendData

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

func (*Doris) StartMetrics

func (ds *Doris) StartMetrics()

func (*Doris) StartOutput

func (ds *Doris) StartOutput(outputChan *channel.OutputChannel)

type Mysql

type Mysql struct {
	*config.MysqlConfig
	// contains filtered or unexported fields
}

func (*Mysql) AddRule

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

func (*Mysql) Close

func (m *Mysql) Close()

func (*Mysql) Configure

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

func (*Mysql) DeleteRule

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

func (*Mysql) Execute

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

func (*Mysql) ExecuteSQL

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

func (*Mysql) GetRules

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

func (*Mysql) GetTable

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

func (*Mysql) IsPaused

func (m *Mysql) IsPaused() bool

func (*Mysql) NewOutput

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

func (*Mysql) Pause

func (m *Mysql) Pause() error

func (*Mysql) Resume

func (m *Mysql) Resume() error

func (*Mysql) RewriteExecute

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

func (*Mysql) StartMetrics

func (m *Mysql) StartMetrics()

func (*Mysql) StartOutput

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

type Starrocks

type Starrocks struct {
	*config.StarrocksConfig
	// contains filtered or unexported fields
}

func (*Starrocks) AddRule

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

func (*Starrocks) Close

func (sr *Starrocks) Close()

func (*Starrocks) Configure

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

func (*Starrocks) DeleteRule

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

func (*Starrocks) Execute

func (sr *Starrocks) Execute(msgs []*msg.Msg, table *schema.Table, targetSchema string, targetTable string) error

func (*Starrocks) ExecuteSQL

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

func (*Starrocks) GetRules

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

func (*Starrocks) GetTable

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

func (*Starrocks) IsPaused

func (sr *Starrocks) IsPaused() bool

func (*Starrocks) NewOutput

func (sr *Starrocks) NewOutput(outputConfig interface{}, rulesMap map[string]interface{}, inSchema core.Schema)

func (*Starrocks) Pause

func (sr *Starrocks) Pause() error

func (*Starrocks) Resume

func (sr *Starrocks) Resume() error

func (*Starrocks) SendData

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

func (*Starrocks) StartMetrics

func (sr *Starrocks) StartMetrics()

func (*Starrocks) StartOutput

func (sr *Starrocks) StartOutput(outputChan *channel.OutputChannel)