db

Documentation

Index

• Constants
• func NewPgxPool(ctx context.Context, cfg PgConfig) (*pgxpool.Pool, error)
• func StartMigration(pgc PgConfig, source source.Driver) error
• type MigrationConfig
  • func PGtoMigrateConfig(pgc PgConfig, source source.Driver) MigrationConfig
• type MigrationHandler
  • func NewHandler(cfg MigrationConfig) (*MigrationHandler, error)
  • func (h *MigrationHandler) Printf(format string, v ...interface{})
  • func (h *MigrationHandler) Verbose() bool
• type Model
• type PgConfig
  • func GetPgConfig(username, password, database string) PgConfig

Constants

const MigrationsTable = "schema_migrations"

MigrationsTable table created by migration lib to track state of migration

Functions

func NewPgxPool

func NewPgxPool(ctx context.Context, cfg PgConfig) (*pgxpool.Pool, error)

NewPgxPool get a concurrency safe pool of connection

func StartMigration

func StartMigration(pgc PgConfig, source source.Driver) error

StartMigration starts migration for alarms server from a k8s job.

Types

type MigrationConfig

type MigrationConfig struct {
	Host            string
	Port            string
	User            string
	Password        string
	Database        string
	MigrationsTable string
	Source          source.Driver
}

MigrationConfig PG config for migration

func PGtoMigrateConfig

func PGtoMigrateConfig(pgc PgConfig, source source.Driver) MigrationConfig

PGtoMigrateConfig convert postgres conn config to migration conn config

type MigrationHandler

type MigrationHandler struct {
	Migrate *migrate.Migrate
}

func NewHandler

func NewHandler(cfg MigrationConfig) (*MigrationHandler, error)

NewHandler configure the migration data

func (*MigrationHandler) Printf

func (h *MigrationHandler) Printf(format string, v ...interface{})

Printf is the implementation of migrate lib's logger interface

func (*MigrationHandler) Verbose

func (h *MigrationHandler) Verbose() bool

Verbose is the implementation of migrate lib's logger interface

type Model

type Model interface {
	PrimaryKey() string
	TableName() string
	OnConflict() string
}

type PgConfig

type PgConfig struct {
	Host     string
	Port     string
	User     string
	Password string
	Database string
}

func GetPgConfig

func GetPgConfig(username, password, database string) PgConfig

GetPgConfig common postgres config for alarms server