migrations

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

type MigrationFunc func(ctx context.Context, state State, saveStateFunc SaveStateFunc) error

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

type ProgressCallback interface {
	// OnRunning is only called when a migration is actually being executed.
	OnRunning(migrationIndex int, migrationsCount int)

	// OnError is called when the migration process for one of the migrations
	// fails with an error.
	OnError(migrationIndex int, migrationsCount int, err error)

	// OnDone is always called once all migrations were successfully executed
	// even if no migrations were run.
	OnDone(migrationsCount int)
}

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

type SaveStateFunc func(state State) error

type State map[string]string

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

type Storage interface {
	// LoadState returns ErrStateNotFound if state has not been saved yet.
	LoadState(name string) (State, error)
	SaveState(name string, state State) error

	// LoadStatus returns ErrStatusNotFound if status has not been saved yet.
	LoadStatus(name string) (Status, error)
	SaveStatus(name string, status Status) error
}