postgresdb

Documentation

Index

• type PostgresConfig
  • func (pgcfg PostgresConfig) String() string
• type PostgresDB
  • func New(connString string) *PostgresDB
  • func (db *PostgresDB) Connect() error
  • func (db *PostgresDB) Name() string
  • func (db *PostgresDB) RetryableError(err error) bool
  • func (db *PostgresDB) SqlDB() *sql.DB

Types

type PostgresConfig

type PostgresConfig struct {
	Host     string
	Port     string
	User     string
	Password string
	Database string
	SSLMode  string
}

PostgresConfig contains config for postgres connection

func (PostgresConfig) String

func (pgcfg PostgresConfig) String() string

type PostgresDB

type PostgresDB struct {
	*sql.DB
	// contains filtered or unexported fields
}

PostgresDB is a sql.DB with reconnect functionality.

func New

func New(connString string) *PostgresDB

New creates a new PostgresDB instance.

func (*PostgresDB) Connect

func (db *PostgresDB) Connect() error

Connect checks database connection and connects if not connected.

func (*PostgresDB) Name

func (db *PostgresDB) Name() string

func (*PostgresDB) RetryableError

func (db *PostgresDB) RetryableError(err error) bool

RetryableError determines if a transaction should be retried after failing due to the specified error. When true, sleeps for a short random time before returning.

func (*PostgresDB) SqlDB

func (db *PostgresDB) SqlDB() *sql.DB