sources

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

type ColumnSchema struct {
	TableDatabase          string
	TableSchema            string
	TableName              string
	ColumnName             string
	ColumnOrdPos           int
	IsNullable             string
	DataType               string
	CharacterMaximumLength sql.NullInt64
	NumericPrecision       sql.NullInt64
	NumericScale           sql.NullInt64
	ColumnType             string
	ColumnKey              string
}

type Dummy struct {
	*Source
}

type JDBCQuery struct {
	*Source
	Config JDBCQueryConfig
	// contains filtered or unexported fields
}

type JDBCQueryConfig struct {
	Host      string `json:"host"`
	Port      int    `json:"port"`
	User      string `json:"user"`
	Password  string `json:"password"`
	BatchSize int    `json:"batchsize"`
	NbWorker  int    `json:"nbworker"`
}

type MSSQLQuery struct {
	*JDBCQuery
	// contains filtered or unexported fields
}

type MSSQLQueryConfig struct {
	*JDBCQueryConfig
	SslMode  string `json:"sslmode"`
	Database string `json:"database"`
}

type Message struct {
	Columnnames  []string      `json:"columnnames"`
	Columntypes  []string      `json:"columntypes"`
	Columnvalues []interface{} `json:"columnvalues"`
	Kind         string        `json:"kind"`
	Schema       string        `json:"schema"`
	Table        string        `json:"table"`
	Oldkeys      Oldkeys       `json:"oldkeys"`
}

type Messages struct {
	Change []Message `json:"change"`
}

type Meta struct {
	LastState string `json:"message"`
	Lsn       uint64 `json:"offset"`
}

type MySQLQuery struct {
	*JDBCQuery
	// contains filtered or unexported fields
}

type MysqlCDC struct {
	*Source
	// contains filtered or unexported fields
}

type MysqlCDCConfig struct {
	Host          string                 `json:"host"`
	Port          int                    `json:"port"`
	User          string                 `json:"user"`
	Password      string                 `json:"password"`
	Slave_id      int                    `json:"slave_id"`
	Offset        string                 `json:"offset"`
	LogFile       string                 `json:"logfile"`
	Old_value     bool                   `json:"old_value"`
	Filter_policy string                 `json:"filter_policy"`
	Filter        map[string]interface{} `json:"filter"`
	Enabled       bool                   `json:"enabled"`
}

type MysqlQueryConfig struct {
	*JDBCQueryConfig
	Schema  string   `json:"schema"`
	Exclude []string `json:"exclude"`
}

type Oldkeys struct {
	Keynames  []string      `json:"keynames"`
	Keytypes  []string      `json:"keytypes"`
	Keyvalues []interface{} `json:"keyvalues"`
}

type PostgreSQLCDC struct {
	*Source
	// contains filtered or unexported fields
}

type PostgreSQLCDCConf struct {
	Host          string                 `json:"host"`
	Port          int                    `json:"port"`
	User          string                 `json:"user"`
	Password      string                 `json:"password"`
	SslMode       string                 `json:"sslmode"`
	Database      string                 `json:"database"`
	Offset        string                 `json:"offset"`
	Slot_name     string                 `json:"slot_name"`
	Old_value     bool                   `json:"old_value"`
	Filter_policy string                 `json:"filter_policy"`
	Filter        map[string]interface{} `json:"filter"`
	Enabled       bool                   `json:"enabled"`
}

type PostgreSQLQuery struct {
	*JDBCQuery
	// contains filtered or unexported fields
}

type PostgreSQLQueryConfig struct {
	*JDBCQueryConfig
	SslMode  string `json:"sslmode"`
	Database string `json:"database"`
}

type Query struct {
	Query string `description:"SQL query to execute on agent" required:"true"`
}

type Random struct {
	*Source

	NbMessages int
	// contains filtered or unexported fields
}

type RandomConfig struct {
	Enabled bool   `json:"enabled"`
	Wait    string `json:"wait"`
}

type Source struct {
	Name          string
	OutputChannel chan *events.LookatchEvent
	AgentInfo     *AgentHeader
	IsEnable      bool
	Conf          *viper.Viper
	Offset        int64
}

type SourceI interface {
	Init()
	Stop() error
	Start(...interface{}) error
	GetName() string
	GetOutputChan() chan *events.LookatchEvent
	GetMeta() map[string]interface{}
	GetSchema() interface{}
	GetStatus() interface{}
	IsEnable() bool
	HealthCheck() bool
	GetAvailableActions() map[string]*control.ActionDescription
	Process(string, ...interface{}) interface{}
}

type SqlSchema map[string]map[string]map[string]*ColumnSchema