runner

Documentation

Index

• type Base
  • func New(conn *db.DB) (*Base, error)
  • func (r *Base) Down(ctx context.Context, tx db.Tx, size int) error
  • func (r *Base) SetElements(elements Elements)
  • func (r *Base) SetLogger(l logger.Logger)
  • func (s *Base) Up(ctx context.Context, tx db.Tx, size int) error
• type Elements
  • func (s *Elements) Len() int
  • func (s *Elements) Less(i, j int) bool
  • func (s *Elements) Swap(i, j int)
• type Migration
• type Yaml
  • func NewYaml(conn *sqlx.DB, pathGlob string) (*Yaml, error)
  • func (y Yaml) Down(ctx context.Context, tx db.Tx, size int) error
  • func (y Yaml) Up(ctx context.Context, tx db.Tx, size int) error

Types

type Base

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

func New

func New(conn *db.DB) (*Base, error)

func (*Base) Down

func (r *Base) Down(ctx context.Context, tx db.Tx, size int) error

func (*Base) SetElements

func (r *Base) SetElements(elements Elements)

func (*Base) SetLogger

func (r *Base) SetLogger(l logger.Logger)

func (*Base) Up

func (s *Base) Up(ctx context.Context, tx db.Tx, size int) error

type Elements

type Elements []Migration

func (*Elements) Len

func (s *Elements) Len() int

func (*Elements) Less

func (s *Elements) Less(i, j int) bool

func (*Elements) Swap

func (s *Elements) Swap(i, j int)

type Migration

type Migration interface {
	Up(ctx context.Context, tx db.Tx) error
	Down(ctx context.Context, tx db.Tx) error
	Version() (string, error)
	Path() string
	Kind() (constants.MigrationKind, error)
}

type Yaml

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

func NewYaml

func NewYaml(conn *sqlx.DB, pathGlob string) (*Yaml, error)

func (Yaml) Down

func (y Yaml) Down(ctx context.Context, tx db.Tx, size int) error

func (Yaml) Up

func (y Yaml) Up(ctx context.Context, tx db.Tx, size int) error