migration

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

type ColumnDef struct {
	Name       string
	Definition string // full column definition (type + constraints)
}

type DistributedLock interface {
	// Acquire obtains the lock for the given key. The returned release function
	// must be called to release the lock. The lock is held until release is called
	// or the context is cancelled.
	Acquire(ctx context.Context, key string) (release func(), err error)
}

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

type MigrationStore interface {
	// Applied returns all applied migrations for the given schema, ordered by version.
	Applied(ctx context.Context, schemaName string) ([]AppliedMigration, error)
	// Record stores an applied migration record.
	Record(ctx context.Context, schemaName string, version int, checksum string) error
}

type PendingMigration struct {
	SchemaName  string
	FromVersion int
	ToVersion   int
	UpSQL       string
}

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

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

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

type SchemaDiff struct {
	FromVersion int
	ToVersion   int
	UpSQL       string
	DownSQL     string
}

type SchemaProvider interface {
	// SchemaName returns a unique identifier for this schema (e.g., "workflow_executions").
	SchemaName() string
	// SchemaVersion returns the current version of the schema.
	SchemaVersion() int
	// SchemaSQL returns the full DDL for the current schema version.
	SchemaSQL() string
	// SchemaDiffs returns ordered diffs for migrating between versions.
	SchemaDiffs() []SchemaDiff
}

type TableDef struct {
	Name    string
	Columns []ColumnDef
	Indexes []string // raw CREATE INDEX statements
}