migration

type ConnectionOptions struct {
	Enabled bool `json:"enabled"`
}

type Error struct {
	Op  string
	Err error
	Msg string
}

type FileLocker struct {
	Root    string
	Timeout time.Duration
}

type FileStateStore struct {
	Root string
}

type FingerprintInput struct {
	Driver   string
	Host     string
	Port     int
	Database string
	Schema   string
}

type LockOptions struct {
	Driver string `json:"driver"`
}

type Locker interface {
	Lock(ctx context.Context, key string) (unlock func() error, err error)
}

type Migration interface {
	Version() uint64
	Name() string
	Mode() Mode
	Scope() Scope
	Connection() string
	Up(ctx context.Context, db *gorm.DB) error
}

type Mode string

type Options struct {
	Enabled     bool                         `json:"enabled"`
	StartupMode StartupMode                  `json:"startup-mode"`
	FailFast    bool                         `json:"fail-fast"`
	Transaction TransactionMode              `json:"transaction"`
	LockTimeout string                       `json:"lock-timeout"`
	State       StateOptions                 `json:"state"`
	Lock        LockOptions                  `json:"lock"`
	Connections map[string]ConnectionOptions `json:"connections"`
	// contains filtered or unexported fields
}

type Plan struct {
	Namespace         string
	Connection        string
	TargetFingerprint string
	Dirty             bool
	Items             []PlanItem
	Executable        []PlanItem
	Problems          []PlanItem
}

type PlanItem struct {
	Kind        PlanItemKind
	Identity    string
	Version     uint64
	Name        string
	Mode        Mode
	Scope       Scope
	Checksum    string
	OldChecksum string
	Status      Status
	Error       string
}

type PlanItemKind string

type ProviderOption func(*ServiceProvider)

type Record struct {
	Namespace   string    `json:"namespace"`
	Connection  string    `json:"connection"`
	Version     uint64    `json:"version"`
	Name        string    `json:"name"`
	Mode        Mode      `json:"mode"`
	Scope       Scope     `json:"scope"`
	Checksum    string    `json:"checksum"`
	Status      Status    `json:"status"`
	StartedAt   time.Time `json:"startedAt,omitempty"`
	AppliedAt   time.Time `json:"appliedAt,omitempty"`
	ExecutionMS int64     `json:"executionMs,omitempty"`
	Error       string    `json:"error,omitempty"`
}

type RegisteredMigration struct {
	Migration Migration
	Checksum  string
}

type Registry struct {
	Namespace  string
	Migrations []RegisteredMigration
}

type ReversibleMigration interface {
	Migration
	Down(ctx context.Context, db *gorm.DB) error
}

type Runner struct {
	Namespace   string
	Connection  string
	Registry    *Registry
	DB          *gorm.DB
	Store       StateStore
	Locker      Locker
	Logger      log.Logger
	Options     Options
	Fingerprint string
}

type Scope string

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

type Snapshot struct {
	Namespace         string   `json:"namespace"`
	Connection        string   `json:"connection"`
	TargetFingerprint string   `json:"targetFingerprint"`
	Records           []Record `json:"records"`
}

type StartupMode string

type StateOptions struct {
	Driver string `json:"driver"`
	Path   string `json:"path"`
}

type StateStore interface {
	Load(ctx context.Context, key TargetKey) (Snapshot, error)
	MarkRunning(ctx context.Context, key TargetKey, record Record) error
	MarkApplied(ctx context.Context, key TargetKey, record Record) error
	MarkFailed(ctx context.Context, key TargetKey, record Record, cause error) error
}

type Status string

type TargetKey struct {
	Namespace         string
	Connection        string
	TargetFingerprint string
}

type TransactionAware interface {
	TransactionMode() TransactionMode
}

type TransactionMode string