migrate

type AppliedMigration struct {
	Version   int
	AppliedAt time.Time
	Checksum  string
}

type CDCRestarter interface {
	Stop(ctx context.Context) error
	Start(ctx context.Context) error
}

type ColumnDef struct {
	Name       string `json:"name"               yaml:"name"`
	Type       string `json:"type"               yaml:"type"`
	Nullable   bool   `json:"nullable,omitempty" yaml:"nullable,omitempty"`
	PrimaryKey bool   `json:"primaryKey,omitempty" yaml:"primaryKey,omitempty"`
	Unique     bool   `json:"unique,omitempty"   yaml:"unique,omitempty"`
	Default    string `json:"default,omitempty"  yaml:"default,omitempty"`
}

type ConnectorAction struct {
	Action string `json:"action"` // "restart", "reconfigure"
	Name   string `json:"name"`
}

type EvolutionStep struct {
	Target      string         `json:"target"` // source_db, cdc_connector, schema_registry, lakehouse
	Action      string         `json:"action"` // alter_table, restart_connector, register_schema, evolve_table
	SQL         string         `json:"sql,omitempty"`
	Config      map[string]any `json:"config,omitempty"`
	Rollback    string         `json:"rollback"`
	Description string         `json:"description"`
}

type ExpandContractChange struct {
	Type      string `json:"type"` // add_column, rename_column, change_type, drop_column
	OldColumn string `json:"oldColumn"`
	NewColumn string `json:"newColumn"`
	NewType   string `json:"newType"`
	Transform string `json:"transform"` // SQL expr (references NEW.<col>); defaults set per type
}

type ExpandContractPlan struct {
	Table        string
	Changes      []ExpandContractChange
	ExpandSQL    []string // DDL + triggers to apply during expand phase
	ContractSQL  []string // DDL to apply during contract phase
	VerifySQL    string   // SQL to verify all rows have been migrated
	TriggerNames []string // generated trigger names (for status checking)
	NewColumns   []string // new column names added during expand
}

type IndexDef struct {
	Name    string   `json:"name,omitempty"   yaml:"name,omitempty"`
	Columns []string `json:"columns"          yaml:"columns"`
	Unique  bool     `json:"unique,omitempty" yaml:"unique,omitempty"`
}

type LakehouseEvolver interface {
	EvolveTable(ctx context.Context, namespace []string, table string, change map[string]any) error
}

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

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

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

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

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

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

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

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

type MigrationPlan struct {
	Changes []SchemaChange
	Safe    bool // true if all changes are non-breaking
}

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

type MigrationScript struct {
	Version     int
	Description string
	UpSQL       string
	DownSQL     string
}

type MigrationState struct {
	Version int
	Applied []AppliedMigration
	Pending []MigrationScript
}

type SQLExecutor interface {
	ExecContext(ctx context.Context, query string, args ...any) (sql.Result, error)
	QueryContext(ctx context.Context, query string, args ...any) (*sql.Rows, error)
}

type SchemaAction struct {
	Action        string `json:"action"` // "register", "check_compat"
	Subject       string `json:"subject"`
	Schema        string `json:"schema"`
	Compatibility string `json:"compatibility"`
}

type SchemaChange struct {
	Type        string // add_column, add_table, add_index, widen_type, drop_column, narrow_type, drop_index
	Description string
	SQL         string
	Breaking    bool
}

type SchemaDefinition struct {
	Table   string      `json:"table"             yaml:"table"`
	Columns []ColumnDef `json:"columns"           yaml:"columns"`
	Indexes []IndexDef  `json:"indexes,omitempty" yaml:"indexes,omitempty"`
}

type SchemaEvolutionPlan struct {
	SourceDB       SchemaChange // DDL to apply in the source database
	CDCConnector   ConnectorAction
	SchemaRegistry SchemaAction
	Lakehouse      TableUpdate
	Safe           bool
	Steps          []EvolutionStep
}

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

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

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

type SchemaModuleConfig struct {
	Strategy         string       `json:"strategy"         yaml:"strategy"`         // declarative, scripted, or both
	Target           string       `json:"target"           yaml:"target"`           // database module reference
	Schemas          []SchemaPath `json:"schemas"          yaml:"schemas"`          // YAML schema file paths
	MigrationsDir    string       `json:"migrationsDir"    yaml:"migrationsDir"`    // directory of NNN_*.sql files
	LockTable        string       `json:"lockTable"        yaml:"lockTable"`        // defaults to schema_migrations
	OnBreakingChange string       `json:"onBreakingChange" yaml:"onBreakingChange"` // block, warn, blue_green
}

type SchemaPath struct {
	Path string `json:"path" yaml:"path"`
}

type SchemaRegistryProvider interface {
	RegisterSubject(ctx context.Context, subject, schema string) (int, error)
	CheckCompatibility(ctx context.Context, subject, schema string) (bool, error)
	GetSchemaFields(ctx context.Context, subject string) ([]string, int, error)
}

type TableUpdate struct {
	Action    string           `json:"action"` // "add_column", "widen_type"
	Table     string           `json:"table"`
	Namespace []string         `json:"namespace"`
	Changes   []map[string]any `json:"changes"`
}