providers

Documentation

Index

• Variables
• type PostgresMigrator
  • func NewPostgresMigrator(host string, port int, username string, password string, database string, ...) *PostgresMigrator
  • func NewPostgresMigratorFromConnectionString(connectionString string) *PostgresMigrator
  • func (m *PostgresMigrator) CommitTransaction()
  • func (m *PostgresMigrator) CreateMigrationsTable() error
  • func (m *PostgresMigrator) DeleteFromMigrationsTable(migrationName string, runID string) error
  • func (m *PostgresMigrator) FetchMigrationsByRunID(runID string) ([]string, error)
  • func (m *PostgresMigrator) InsertIntoMigrationsTable(migrationName string, runID string) error
  • func (m *PostgresMigrator) LastMigrationRunID() (string, error)
  • func (m *PostgresMigrator) MigrationAlreadyRun(migrationName string) bool
  • func (m *PostgresMigrator) RollbackTransaction()
  • func (m *PostgresMigrator) RunMigration(migrationQuery string) error
  • func (m *PostgresMigrator) StartTransaction()

Variables

var DefaultLogger = logger.New(
	log.New(os.Stdout, "\r\n", log.LstdFlags),
	logger.Config{
		SlowThreshold: time.Second,
		LogLevel:      logger.Info,
		Colorful:      false,
	},
)

Types

type PostgresMigrator

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

func NewPostgresMigrator

func NewPostgresMigrator(host string, port int, username string, password string, database string, sslEnabled bool) *PostgresMigrator

func NewPostgresMigratorFromConnectionString

func NewPostgresMigratorFromConnectionString(connectionString string) *PostgresMigrator

func (*PostgresMigrator) CommitTransaction

func (m *PostgresMigrator) CommitTransaction()

func (*PostgresMigrator) CreateMigrationsTable

func (m *PostgresMigrator) CreateMigrationsTable() error

func (*PostgresMigrator) DeleteFromMigrationsTable

func (m *PostgresMigrator) DeleteFromMigrationsTable(migrationName string, runID string) error

func (*PostgresMigrator) FetchMigrationsByRunID

func (m *PostgresMigrator) FetchMigrationsByRunID(runID string) ([]string, error)

func (*PostgresMigrator) InsertIntoMigrationsTable

func (m *PostgresMigrator) InsertIntoMigrationsTable(migrationName string, runID string) error

func (*PostgresMigrator) LastMigrationRunID

func (m *PostgresMigrator) LastMigrationRunID() (string, error)

func (*PostgresMigrator) MigrationAlreadyRun

func (m *PostgresMigrator) MigrationAlreadyRun(migrationName string) bool

func (*PostgresMigrator) RollbackTransaction

func (m *PostgresMigrator) RollbackTransaction()

func (*PostgresMigrator) RunMigration

func (m *PostgresMigrator) RunMigration(migrationQuery string) error

func (*PostgresMigrator) StartTransaction

func (m *PostgresMigrator) StartTransaction()