migration

type ApplyResult struct {
	Applied []MigrationRun `json:"applied"`
	Skipped []MigrationRun `json:"skipped"`
}

type Definition struct {
	ID          string   `json:"id"`
	Name        string   `json:"name"`
	Resource    string   `json:"resource"`
	FromVersion string   `json:"from_version"`
	ToVersion   string   `json:"to_version"`
	Description string   `json:"description"`
	Executor    Executor `json:"-"`
}

type Executor interface {
	Apply(ctx context.Context) (int64, error)
}

type ExecutorFunc func(ctx context.Context) (int64, error)

type MigrationRun struct {
	ID           string `json:"id"`
	Name         string `json:"name"`
	Resource     string `json:"resource"`
	FromVersion  string `json:"from_version"`
	ToVersion    string `json:"to_version"`
	Status       string `json:"status"`
	RowsMigrated int64  `json:"rows_migrated"`
	AppliedAtMS  int64  `json:"applied_at_ms"`
	UpdatedAtMS  int64  `json:"updated_at_ms"`
}

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

type StatusResult struct {
	Migrations []MigrationRun `json:"migrations"`
}

type Store interface {
	GetRun(ctx context.Context, id string) (MigrationRun, bool, error)
	RecordApplied(ctx context.Context, definition Definition, rowsMigrated int64, appliedAt time.Time) (MigrationRun, error)
}