postgres

Documentation

Index

• type PostgresRepository
  • func NewPostgresRepository(ctx context.Context, db database.Database, history_table *string) *PostgresRepository
  • func (r *PostgresRepository) AssertSchemaHistoryTable() error
  • func (r *PostgresRepository) CheckSchemaHistoryTable() (bool, error)
  • func (r *PostgresRepository) DoInLock(fn func() error) error
  • func (r *PostgresRepository) DoInTransaction(fn func() error) error
  • func (r *PostgresRepository) ExecuteHook(hook *migrations.Hook) error
  • func (r *PostgresRepository) ExecuteMigration(migration *migrations.Migration) []error
  • func (r *PostgresRepository) GetFailingMigrations() ([]*migrations.Migration, error)
  • func (r *PostgresRepository) GetLatestMigration() (uint16, error)
  • func (r *PostgresRepository) Repair(migrations []*migrations.Migration) []error
  • func (r *PostgresRepository) RollbackMigration(migration *migrations.Migration) error
  • func (r *PostgresRepository) ValidateMigrations(migrations []*migrations.Migration) []error

Types

type PostgresRepository

type PostgresRepository struct {
	database.Repository
	// contains filtered or unexported fields
}

func NewPostgresRepository

func NewPostgresRepository(ctx context.Context, db database.Database, history_table *string) *PostgresRepository

func (*PostgresRepository) AssertSchemaHistoryTable

func (r *PostgresRepository) AssertSchemaHistoryTable() error

func (*PostgresRepository) CheckSchemaHistoryTable

func (r *PostgresRepository) CheckSchemaHistoryTable() (bool, error)

func (*PostgresRepository) DoInLock

func (r *PostgresRepository) DoInLock(fn func() error) error

func (*PostgresRepository) DoInTransaction

func (r *PostgresRepository) DoInTransaction(fn func() error) error

func (*PostgresRepository) ExecuteHook

func (r *PostgresRepository) ExecuteHook(hook *migrations.Hook) error

func (*PostgresRepository) ExecuteMigration

func (r *PostgresRepository) ExecuteMigration(migration *migrations.Migration) []error

func (*PostgresRepository) GetFailingMigrations

func (r *PostgresRepository) GetFailingMigrations() ([]*migrations.Migration, error)

func (*PostgresRepository) GetLatestMigration

func (r *PostgresRepository) GetLatestMigration() (uint16, error)

func (*PostgresRepository) Repair

func (r *PostgresRepository) Repair(migrations []*migrations.Migration) []error

func (*PostgresRepository) RollbackMigration

func (r *PostgresRepository) RollbackMigration(migration *migrations.Migration) error

func (*PostgresRepository) ValidateMigrations

func (r *PostgresRepository) ValidateMigrations(migrations []*migrations.Migration) []error