helper

Documentation

Index

• func BinlogPositionValueDecoder(s string) (interface{}, error)
• func BinlogPositionValueEncoder(v interface{}) (string, error)
• func GetInputFromPlugin(pluginName string, pipelineName string, data map[string]interface{}) (core.Input, error)
• func GetProbCfg(sourceProbeCfg *SourceProbeCfg, sourceDBCfg *utils.DBConfig) (*utils.DBConfig, string)
• func NewTwoStageInputPlugin(full, incremental core.Input) (core.Input, error)
• func SerializeBinlogPositionValue(position BinlogPositionsValue) (string, error)
• type BinlogPositionsValue
  • func DeserializeBinlogPositionValue(value string) (BinlogPositionsValue, error)
• type SourceProbeCfg
• type TwoStageInputPlugin
  • func (i *TwoStageInputPlugin) Close()
  • func (i *TwoStageInputPlugin) Done() chan position_store.Position
  • func (i *TwoStageInputPlugin) NewPositionCache() (position_store.PositionCacheInterface, error)
  • func (i *TwoStageInputPlugin) SendDeadSignal() error
  • func (i *TwoStageInputPlugin) Stage() config.InputMode
  • func (i *TwoStageInputPlugin) Start(emitter core.Emitter, router core.Router, ...) error
  • func (i *TwoStageInputPlugin) Wait()

Functions

func BinlogPositionValueDecoder

func BinlogPositionValueDecoder(s string) (interface{}, error)

func BinlogPositionValueEncoder

func BinlogPositionValueEncoder(v interface{}) (string, error)

func GetInputFromPlugin

func GetInputFromPlugin(pluginName string, pipelineName string, data map[string]interface{}) (core.Input, error)

func GetProbCfg

func GetProbCfg(sourceProbeCfg *SourceProbeCfg, sourceDBCfg *utils.DBConfig) (*utils.DBConfig, string)

func NewTwoStageInputPlugin

func NewTwoStageInputPlugin(full, incremental core.Input) (core.Input, error)

func SerializeBinlogPositionValue

func SerializeBinlogPositionValue(position BinlogPositionsValue) (string, error)

Types

type BinlogPositionsValue

type BinlogPositionsValue struct {
	CurrentPosition *utils.MySQLBinlogPosition `json:"current_position"`
	StartPosition   *utils.MySQLBinlogPosition `json:"start_position"`
}

func DeserializeBinlogPositionValue

func DeserializeBinlogPositionValue(value string) (BinlogPositionsValue, error)

type SourceProbeCfg

type SourceProbeCfg struct {
	SourceMySQL *utils.DBConfig `mapstructure:"mysql"json:"mysql"`
	Annotation  string          `mapstructure:"annotation"json:"annotation"`
}

type TwoStageInputPlugin

type TwoStageInputPlugin struct {
	// contains filtered or unexported fields
}

func (*TwoStageInputPlugin) Close

func (i *TwoStageInputPlugin) Close()

func (*TwoStageInputPlugin) Done

func (i *TwoStageInputPlugin) Done() chan position_store.Position

func (*TwoStageInputPlugin) NewPositionCache

func (i *TwoStageInputPlugin) NewPositionCache() (position_store.PositionCacheInterface, error)

func (*TwoStageInputPlugin) SendDeadSignal

func (i *TwoStageInputPlugin) SendDeadSignal() error

func (*TwoStageInputPlugin) Stage

func (i *TwoStageInputPlugin) Stage() config.InputMode

func (*TwoStageInputPlugin) Start

func (i *TwoStageInputPlugin) Start(emitter core.Emitter, router core.Router, positionCache position_store.PositionCacheInterface) error

func (*TwoStageInputPlugin) Wait

func (i *TwoStageInputPlugin) Wait()