postgres

Documentation

Index

• func CreateConfig(connectionConfig *ConnectionConfig, poolConfig *PoolConfig) (*pgxpool.Config, error)
• type ConnectionConfig
• type Connector
  • func NewPgConnector(config *pgxpool.Config, pingTimeout time.Duration, ...) (*Connector, error)
  • func (p *Connector) CloseConnection()
  • func (p *Connector) GetPool() *pgxpool.Pool
  • func (p *Connector) Ping() error
• type PgConnector
• type PoolConfig

Functions

func CreateConfig

func CreateConfig(
	connectionConfig *ConnectionConfig,
	poolConfig *PoolConfig,
) (*pgxpool.Config, error)

CreateConfig creates pgxpool.Config from ConnectionConfig and PoolConfig (if exists)

Returns error if connectionConfig is nil

Types

type ConnectionConfig

type ConnectionConfig struct {
	Host     string `form:"host"`
	Port     string `form:"port"`
	DbName   string `form:"dbname"`
	User     string `form:"user"`
	Password string `form:"password"`
	SslMode  string `form:"sslmode"`
}

type Connector

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

func NewPgConnector

func NewPgConnector(
	config *pgxpool.Config,
	pingTimeout time.Duration,
	connectTimeout time.Duration,
) (*Connector, error)

func (*Connector) CloseConnection

func (p *Connector) CloseConnection()

func (*Connector) GetPool

func (p *Connector) GetPool() *pgxpool.Pool

func (*Connector) Ping

func (p *Connector) Ping() error

type PgConnector

type PgConnector interface {
	GetPool() *pgxpool.Pool
	CloseConnection()
	Ping() error
}

type PoolConfig

type PoolConfig struct {
	MaxOpenConns          int           `form:"pool_max_open_conns"`
	MaxIdleConns          int           `form:"pool_max_idle_conns"`
	MaxConnLifetime       time.Duration `form:"pool_max_conn_lifetime"`
	MaxConnIdleTime       time.Duration `form:"pool_max_conn_idle_time"`
	HealthCheckPeriod     time.Duration `form:"pool_health_check_period"`
	MaxConnLifetimeJitter time.Duration `form:"pool_max_conn_lifetime_jitter"`
}