wanderer

May 14, 2021

Changes in this version

+ type Driver string

+ var DriverPostgreSQL Driver = "postgres"

Oct 13, 2020

Changes in this version

+ var StatusDiscarded = "discarded"

+ var StatusExecutingDown = "executing(down)"

+ var StatusExecutingUp = "executing(up)"

+ var StatusFailedDown = "failed(down)"

+ var StatusFailedUp = "failed(up)"

+ var StatusSucceededDown = "succeeded(down)"

+ var StatusSucceededUp = "succeeded(up)"

type Migration

+ Direction string

+ Name string

+ Scope string

+ Transitions [1]*Transition

type WhereMigrations

+ AndWhereTransitions *WhereTransitions

+ Name string

+ ScopeIn []string

+ ScopeNotIn []string

+ VersionedAfter *time.Time

+ VersionedBefore *time.Time

type WhereTransitions

+ MigrationID string

Sep 1, 2020

Changes in this version

type Direction

+ Direction string

+ MigrationID string

+ type Meta struct

+ Count uint16

+ Pagination *Pagination

+ Where *WhereMigrations

type Migration

+ Directions map[string]*Direction

type Options

+ Enabled bool

+ type Pagination struct

+ Current uint16

+ First uint16

+ Last uint16

+ Next *uint16

+ Previous *uint16

type Wanderer

+ AddDirections func(*Toolkit, []*Direction) error

+ AddMigrations func(*Toolkit, []*Migration) error

+ AddTransitions func(*Toolkit, []*Transition) error

+ FindDirection func(*Toolkit, string) (*Direction, error)

+ FindDirections func(*Toolkit, *WhereMigrations) ([]*Direction, *Meta, error)

+ FindMigration func(*Toolkit, string) (*Migration, error)

+ FindMigrations func(*Toolkit, *WhereMigrations) ([]*Migration, *Meta, error)

+ FindTransition func(*Toolkit, string) (*Transition, error)

+ FindTransitions func(*Toolkit, *WhereMigrations) ([]*Transition, *Meta, error)

+ type WhereDirections struct

+ AndWhereTransitions *WhereTransitions

+ CreatedAfter *time.Time

+ CreatedBefore *time.Time

+ DirectionsIn []string

+ DirectionsNotIn []string

+ MigrationID string

+ type WhereMigrations struct

+ AndWhereDirections *WhereDirections

+ CreatedAfter *time.Time

+ CreatedBefore *time.Time

+ InterfaceKindsIn []string

+ InterfaceKindsNotIn []string

+ InterfaceStringsIn []string

+ InterfaceStringsNotIn []string

+ Limit uint16

+ Offset uint16

+ type WhereTransitions struct

+ CreatedAfter *time.Time

+ CreatedBefore *time.Time

+ DirectionID string

+ MaxAttempts uint16

+ MinAttempts uint16

+ StatusIn []string

+ StatusNotIn []string

+ type WithMigrate interface

+ Migrate func(*Toolkit, []*Migration) error

+ type WithMigrations interface

+ Migrations func() ([]*Migration, error)

May 25, 2020

Changes in this version

+ var AvailableAdapters = map[string]bool

+ var Defaults = &Options

+ var InterfaceWanderer = "wanderer"

+ var StatusAcknowledged = "acknowledged"

+ var StatusAwaiting = "awaiting"

+ var StatusExecuting = "executing"

+ var StatusFailed = "failed"

+ var StatusRollbacked = "rollbacked"

+ var StatusSucceeded = "succeeded"

+ var ValidDirections = map[string]bool

+ type Direction struct

+ CreatedAt time.Time

+ Filename string

+ ID string

+ SHA256 []byte

+ Transitions [1]*Transition

+ type Migration struct

+ CreatedAt time.Time

+ ID string

+ InterfaceKind string

+ InterfaceString string

+ Run map[string]*Direction

+ Version string

+ type Options struct

+ Connection string

+ Context context.Context

+ From string

+ Load Wanderer

+ func (opts *Options) ValidateAndLoad() (Wanderer, error)

+ type Toolkit struct

+ Lock *mutex.Lock

+ Logger *logrus.Logger

+ WD string

+ type Transition struct

+ Attempt uint16

+ CreatedAt time.Time

+ DirectionID string

+ Error error

+ ID string

+ LockID string

+ MigrationID string

+ StateAfter string

+ StateBefore *string

+ type Wanderer interface

+ Ack func(*Toolkit, []*Migration) error

+ Find func(*Toolkit, *WhereMigration) ([]*Migration, error)

+ Migrate func(*Toolkit, *Migration) error

+ Migrations func() ([]*Migration, error)

+ Mutex func() mutex.Mutex

+ Options func() *Options

+ String func() string

+ Update func(*Toolkit, []*Migration) error

+ type WhereMigration struct

+ Direction string

+ StatusIn []string

+ StatusNotIn []string

+ Version string

+ func (where *WhereMigration) Validate() error