helper

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

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

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