output

Documentation

Index

• Variables
• type Doris
  • 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) ExecuteSQL(cmd string, args ...interface{}) (rr *mysql.Result, err 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
• 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) Execute(msgs []*msg.Msg, table *Table) 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) (*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
• type TableColumn

Variables

var DeleteColumn = "_delete_sign_"

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

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) DeleteRule

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

func (*Doris) Execute

func (ds *Doris) Execute(msgs []*msg.Msg, table *Table) 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) (*Table, error)

func (*Doris) NewOutput

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

func (*Doris) StartMetrics

func (ds *Doris) StartMetrics()

func (*Doris) StartOutput

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

type Plugin

type Plugin interface {
	NewOutput(config interface{})
	StartOutput(outputChan *channel.OutputChannel, rulesMap map[string]interface{})
	Execute(msgs []*msg.Msg, tableObj *Table) error
	Close()
	AddRule(map[string]interface{}) error
	DeleteRule(map[string]interface{}) error
	GetRules() interface{}
}

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) DeleteRule

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

func (*Starrocks) Execute

func (sr *Starrocks) Execute(msgs []*msg.Msg, table *Table) 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) (*Table, error)

func (*Starrocks) NewOutput

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

func (*Starrocks) StartMetrics

func (sr *Starrocks) StartMetrics()

func (*Starrocks) StartOutput

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

type Table

type Table struct {
	Schema  string
	Name    string
	Columns []string
}

type TableColumn

type TableColumn struct {
	Name string
}