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 FileReadingFollower struct {
	*Source
	// contains filtered or unexported fields
}

type FileReadingFollowerConfig struct {
	Path   string `json:"path"`
	Offset int64  `json:"offset"`
}

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:"laststate"`
	Lsn        uint64 `json:"offset"`
	SlotStatus bool   `json:"slotstatus"`
}

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"`
	SlaveID      int                    `json:"slave_id" mapstructure:"slave_id"`
	Offset       string                 `json:"offset"`
	LogFile      string                 `json:"logfile"`
	OldValue     bool                   `json:"old_value" mapstructure:"old_value"`
	FilterPolicy string                 `json:"filter_policy" mapstructure:"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"`
	SlotName     string                 `json:"slot_name" mapstructure:"slot_name"`
	OldValue     bool                   `json:"old_value" mapstructure:"old_value"`
	FilterPolicy string                 `json:"filter_policy" mapstructure:"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 {
	Wait string `json:"wait"`
}

type SQLSchema map[string]map[string]map[string]*ColumnSchema

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 Syslog struct {
	*Source

	NbMessages int
	// contains filtered or unexported fields
}

type SyslogConfig struct {
	Type string `json:"Type"`
	Port int    `json:"Port"`
}