output

package
v0.5.4 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 3, 2024 License: GPL-2.0 Imports: 22 Imported by: 0

Documentation

Index

Constants

View Source 
const DorisName = "doris"
View Source 
const MysqlName = "mysql"
View Source 
const StarrocksName = "starrocks"

Variables

View Source 
var DeleteColumn = "_delete_sign_"
View Source 
var DeleteCondition = fmt.Sprintf("%s=1", DeleteColumn)
View Source 
var RetryCount = 3
View Source 
var RetryInterval = 5

Functions

This section is empty.

Types

type Doris added in v0.3.0 

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

func (*Doris) AddRule added in v0.3.0 

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

func (*Doris) Close added in v0.3.0 

func (ds *Doris) Close()

func (*Doris) Configure added in v0.5.0 

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

func (*Doris) DeleteRule added in v0.3.0 

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

func (*Doris) Execute added in v0.3.0 

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

func (*Doris) ExecuteSQL added in v0.3.1 

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

func (*Doris) GetRules added in v0.3.0 

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

func (*Doris) GetTable added in v0.3.0 

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

func (*Doris) IsPaused added in v0.3.7 

func (ds *Doris) IsPaused() bool

func (*Doris) NewOutput added in v0.3.0 

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

func (*Doris) Pause added in v0.3.7 

func (ds *Doris) Pause() error

func (*Doris) Resume added in v0.3.7 

func (ds *Doris) Resume() error

func (*Doris) SendData added in v0.3.7 

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

func (*Doris) StartMetrics added in v0.3.0 

func (ds *Doris) StartMetrics()

func (*Doris) StartOutput added in v0.3.0 

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

type Mysql added in v0.4.0 

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

func (*Mysql) AddRule added in v0.4.0 

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

func (*Mysql) Close added in v0.4.0 

func (m *Mysql) Close()

func (*Mysql) Configure added in v0.5.0 

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

func (*Mysql) DeleteRule added in v0.4.0 

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

func (*Mysql) Execute added in v0.4.0 

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

func (*Mysql) ExecuteSQL added in v0.4.0 

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

func (*Mysql) GetRules added in v0.4.0 

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

func (*Mysql) GetTable added in v0.4.0 

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

func (*Mysql) IsPaused added in v0.4.0 

func (m *Mysql) IsPaused() bool

func (*Mysql) NewOutput added in v0.4.0 

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

func (*Mysql) Pause added in v0.4.0 

func (m *Mysql) Pause() error

func (*Mysql) Resume added in v0.4.0 

func (m *Mysql) Resume() error

func (*Mysql) RewriteExecute added in v0.4.0 

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

func (*Mysql) StartMetrics added in v0.4.0 

func (m *Mysql) StartMetrics()

func (*Mysql) StartOutput added in v0.4.0 

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

type Starrocks 

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

func (*Starrocks) AddRule added in v0.3.0 

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

func (*Starrocks) Close added in v0.3.0 

func (sr *Starrocks) Close()

func (*Starrocks) Configure added in v0.5.0 

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

func (*Starrocks) DeleteRule added in v0.3.0 

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 added in v0.3.1 

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

func (*Starrocks) GetRules added in v0.3.0 

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

func (*Starrocks) GetTable added in v0.3.0 

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

func (*Starrocks) IsPaused added in v0.3.7 

func (sr *Starrocks) IsPaused() bool

func (*Starrocks) NewOutput added in v0.3.0 

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

func (*Starrocks) Pause added in v0.3.7 

func (sr *Starrocks) Pause() error

func (*Starrocks) Resume added in v0.3.7 

func (sr *Starrocks) Resume() error

func (*Starrocks) SendData added in v0.3.7 

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

func (*Starrocks) StartMetrics added in v0.3.0 

func (sr *Starrocks) StartMetrics()

func (*Starrocks) StartOutput added in v0.3.0 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.