transformation

type AdminTable struct {
	Database string
	Table    string
}

type Config struct {
	Type     Type              `yaml:"type"`     // Required: "incremental" or "scheduled"
	Database string            `yaml:"database"` // Optional, can fall back to default
	Table    string            `yaml:"table"`    // Required
	Env      map[string]string `yaml:"env,omitempty"`
}

type Dependency struct {
	// IsGroup indicates if this is an OR group (array) or a single dependency (string)
	IsGroup bool
	// SingleDep holds the dependency ID for single dependencies
	SingleDep string
	// GroupDeps holds multiple dependency IDs for OR groups
	GroupDeps []string
}

type Exec struct {
	Config  `yaml:",inline"`
	Exec    string  `yaml:"exec"`
	Handler Handler `yaml:"-"` // Type-specific handler
}

type ExecParser struct{}

type Handler interface {
	// Type returns the transformation type
	Type() Type

	// Config returns the typed configuration
	Config() any

	// Validate validates the configuration
	Validate() error

	// ShouldTrackPosition indicates if this type tracks positions
	ShouldTrackPosition() bool

	// GetTemplateVariables returns template variables for this transformation
	GetTemplateVariables(ctx context.Context, taskInfo TaskInfo) map[string]any

	// GetAdminTable returns the admin table configuration for this type
	GetAdminTable() AdminTable

	// RecordCompletion records the completion of a transformation
	RecordCompletion(ctx context.Context, adminService any, modelID string, taskInfo TaskInfo) error
}

type HandlerFactory func(data []byte, adminTable AdminTable) (Handler, error)

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

type SQL struct {
	BaseConfig Config  `yaml:",inline"` // Base configuration
	Handler    Handler // Type-specific handler
	Content    string  `yaml:"-"` // SQL content
}

type TaskInfo struct {
	Position  uint64
	Interval  uint64
	Timestamp time.Time
	Direction string
}

type Type string