iceberg

type Config struct {
	SourceID        string        `json:"source_id" yaml:"source_id"`
	Driver          string        `json:"driver" yaml:"driver"`
	DSN             string        `json:"dsn" yaml:"dsn"`
	Catalog         string        `json:"catalog" yaml:"catalog"`
	Namespace       string        `json:"namespace" yaml:"namespace"`
	Table           string        `json:"table" yaml:"table"`
	Mode            string        `json:"mode" yaml:"mode"` // "batch" or "stream"
	Columns         []string      `json:"columns" yaml:"columns"`
	Filter          string        `json:"filter" yaml:"filter"`
	Query           string        `json:"query" yaml:"query"`
	StreamQuery     string        `json:"stream_query" yaml:"stream_query"`
	WatermarkColumn string        `json:"watermark_column" yaml:"watermark_column"`
	StartWatermark  string        `json:"start_watermark" yaml:"start_watermark"`
	WatermarkType   string        `json:"watermark_type" yaml:"watermark_type"`
	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"`
	Timeout         time.Duration `json:"timeout" yaml:"timeout"`
}

type Factory struct{}

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