Versions in this module Expand all Collapse all v0 v0.1.1 Jan 13, 2026 v0.1.0 Jan 12, 2026 Changes in this version + func Migrate(ctx context.Context, manager Manager, opts ...Option) (returnErr error) + type Config struct + MigrationDeadlineMillis int + MigrationHeartbeatFailureRetryCount int + MigrationHeartbeatIntervalMillis int + MigrationUnlockDeadlineMillis int + type Manager interface + AcquireDBLock func(ctx context.Context) error + AcquireMigrationLock func(ctx context.Context) error + EnsureDataStores func(ctx context.Context) error + ListStatuses func(ctx context.Context) ([]PersistedStatus, error) + MigrationLockHeartbeat func(ctx context.Context) error + PersistStatus func(ctx context.Context, order Order, status Status) error + ReleaseDBLock func(ctx context.Context) error + ReleaseMigrationLock func(ctx context.Context) error + type Option func(cfg *migrateConfig) + func WithConfigProvider(callback func() (*Config, error)) Option + func WithRegistry(reg *Registry) Option + type Order int + type PersistedStatus struct + Order Order + Status Status + type Registration struct + Enabled bool + Migrate func(context.Context, Status) error + Order Order + type Registry struct + func NewRegistry() *Registry + func (r *Registry) MustRegister(registration *Registration) + func (r *Registry) OrderedRegistrations() []*Registration + type Status string + const Completed + const Failed + const Pending + const Started
Go to main page