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 *config.DBConfig) (*config.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_repos.Position
  • func (i *TwoStageInputPlugin) NewPositionCache() (position_cache.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 *config.DBConfig) (*config.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 *config.MySQLBinlogPosition `json:"current_position"`
	StartPosition   *config.MySQLBinlogPosition `json:"start_position"`
}

func DeserializeBinlogPositionValue

func DeserializeBinlogPositionValue(value string) (BinlogPositionsValue, error)

type SourceProbeCfg

type SourceProbeCfg struct {
	SourceMySQL *config.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_repos.Position

func (*TwoStageInputPlugin) NewPositionCache

func (i *TwoStageInputPlugin) NewPositionCache() (position_cache.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_cache.PositionCacheInterface) error

func (*TwoStageInputPlugin) Wait

func (i *TwoStageInputPlugin) Wait()