executor

Sep 4, 2025

Changes in this version

+ type ClickHouse interface

+ Exec func(context.Context, string, ...any) error

+ Query func(context.Context, string, ...any) (driver.Rows, error)

+ type Config struct

+ ClickHouse ClickHouse

+ Formatter *format.Formatter

+ HousekeeperVersion string

+ type ExecutionResult struct

+ Error error

+ ExecutionTime time.Duration

+ Revision *migrator.Revision

+ StatementsApplied int

+ Status ExecutionStatus

+ TotalStatements int

+ Version string

+ type ExecutionStatus string

+ const StatusFailed

+ const StatusSkipped

+ const StatusSuccess

+ type Executor struct

+ func New(config Config) *Executor

+ func (e *Executor) ComputeHashes(migration *migrator.Migration) (string, []string)

+ func (e *Executor) Execute(ctx context.Context, migrations []*migrator.Migration) ([]*ExecutionResult, error)

+ func (e *Executor) IsBootstrapped(ctx context.Context) (bool, error)