sql

type Config struct {
	SourceID        string            `json:"source_id" yaml:"source_id"`
	Driver          string            `json:"driver" yaml:"driver"`
	DSN             string            `json:"dsn" yaml:"dsn"`
	Mode            string            `json:"mode" yaml:"mode"` // "batch" or "stream"
	Query           string            `json:"query" yaml:"query"`
	StreamingQuery  string            `json:"stream_query" yaml:"stream_query"`
	Table           string            `json:"table" yaml:"table"`
	WatermarkColumn string            `json:"watermark_column" yaml:"watermark_column"`
	StartWatermark  string            `json:"start_watermark" yaml:"start_watermark"`
	WatermarkType   string            `json:"watermark_type" yaml:"watermark_type"` // "string", "int", "float", "time"
	PollInterval    time.Duration     `json:"poll_interval" yaml:"poll_interval"`
	MaxRows         int               `json:"max_rows" yaml:"max_rows"`
	SchemaName      string            `json:"schema_name" yaml:"schema_name"`
	SchemaVersion   string            `json:"schema_version" yaml:"schema_version"`
	SourceKey       string            `json:"source_key" yaml:"source_key"`
	Timeout         time.Duration     `json:"timeout" yaml:"timeout"`
	ColumnMapping   map[string]string `json:"column_mapping" yaml:"column_mapping"`
}

type Factory struct{}

type SchemaConfig struct {
	Driver        string            `json:"driver" yaml:"driver"`
	DSN           string            `json:"dsn" yaml:"dsn"`
	Table         string            `json:"table" yaml:"table"`
	Schema        string            `json:"schema" yaml:"schema"`
	Catalog       string            `json:"catalog" yaml:"catalog"`
	SchemaName    string            `json:"schema_name" yaml:"schema_name"`
	SchemaVersion string            `json:"schema_version" yaml:"schema_version"`
	IncludeCols   []string          `json:"include_columns" yaml:"include_columns"`
	ExcludeCols   []string          `json:"exclude_columns" yaml:"exclude_columns"`
	ColumnMapping map[string]string `json:"column_mapping" yaml:"column_mapping"`
}

type SchemaFactory struct{}

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

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