startup_postgres

Documentation

Index

• func ErrIsForeignKeyViolation(err error) bool
• func ErrIsUniqueViolation(err error) bool
• func InstallTracer(tracer Tracer)
• type Initializer
  • func DefaultMigration(table string) Initializer
  • func Migration(table, directory string) Initializer
• type PostgresOptions
  • func (opts *PostgresOptions) Connection() *sqlx.DB
  • func (opts *PostgresOptions) StartVacuumTask(db *sqlx.DB, table string, interval time.Duration, clock clock.Clock) io.Closer
• type Tracer
  • func GetTracer() Tracer

Functions

func ErrIsForeignKeyViolation

func ErrIsForeignKeyViolation(err error) bool

func ErrIsUniqueViolation

func ErrIsUniqueViolation(err error) bool

func InstallTracer

func InstallTracer(tracer Tracer)

Types

type Initializer

type Initializer func(db *sqlx.DB) error

func DefaultMigration

func DefaultMigration(table string) Initializer

DefaultMigration creates an Initializer that performs a database migration by looking for sql files in the default directories.

func Migration

func Migration(table, directory string) Initializer

Migration Runs a migration with the sql files from the given directory. The directory must exist. The migration library will use the given table name to store the migration progress

type PostgresOptions

type PostgresOptions struct {
	URL                string `long:"postgres" default:"postgres://postgres:postgres@localhost:5432?sslmode=disable" description:"Postgres server url."`
	PoolSize           int    `` /* 133-byte string literal not displayed */
	EnableQueryLogging bool   `long:"enable-query-logging" description:"Enable query logging."`

	ConnectionLifetime time.Duration `long:"postgres-lifetime" default:"10m" description:"Maximum time a connection in the pool can be used."`

	Inputs struct {
		// An optional initializer. This might be used to do
		// database migration or stuff.
		Initializer Initializer
	}
	// contains filtered or unexported fields
}

func (*PostgresOptions) Connection

func (opts *PostgresOptions) Connection() *sqlx.DB

func (*PostgresOptions) StartVacuumTask

func (opts *PostgresOptions) StartVacuumTask(db *sqlx.DB, table string, interval time.Duration, clock clock.Clock) io.Closer

type Tracer

type Tracer interface {
	pgx.QueryTracer
	pgx.PrepareTracer
	pgx.ConnectTracer

	TransactionStart(ctx context.Context) context.Context
	TransactionEnd(ctx context.Context)

	AcquireConnectionStart(ctx context.Context) context.Context
	AcquireConnectionEnd(ctx context.Context)
}

func GetTracer

func GetTracer() Tracer