postgres

Documentation

Index

• Variables
• func Migrate(ctx context.Context, req MigrateRequest) error
• func New(source migrations.Source, db target.DB, databaseName, tableName string) (*target.Target, error)
• type MigrateRequest
• type Postgres
  • func (p *Postgres) Add(migration migrations.Migration) error
  • func (p *Postgres) Lock() (migrations.Unlocker, error)
  • func (p *Postgres) Remove(migration migrations.Migration) error
• type TXExecer

Variables

var (
	ErrMissingDatabaseName = errors.New("missing database name")
)

Functions

func Migrate

func Migrate(ctx context.Context, req MigrateRequest) error

func New

func New(source migrations.Source, db target.DB, databaseName, tableName string) (*target.Target, error)

Types

type MigrateRequest

type MigrateRequest struct {
	DB           target.DB
	Source       migrations.Source
	DatabaseName string
	TableName    string
	Reporter     migrations.RunnerReporter
}

type Postgres

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

func (*Postgres) Add

func (p *Postgres) Add(migration migrations.Migration) error

func (*Postgres) Lock

func (p *Postgres) Lock() (migrations.Unlocker, error)

func (*Postgres) Remove

func (p *Postgres) Remove(migration migrations.Migration) error

type TXExecer

type TXExecer interface {
	Exec(query string, args ...interface{}) (sql.Result, error)
	Commit() error
	Rollback() error
}