pgxutils

Documentation

Index

• Constants
• func AfterConnectMap(conn *pgx.Conn) error
• func NewPgxPool(config *PostgresConfig) (*pgx.ConnPool, error)
• func NewPgxPoolAfterConnect(config *PostgresConfig, afterConnectMap func(*pgx.Conn) error, debug bool) (*pgx.ConnPool, error)
• func NewPgxPoolAfterConnectZap(config *PostgresZapConfig, afterConnectMap func(*pgx.Conn) error, debug bool) (*pgx.ConnPool, error)
• type PostgresConfig
  • func (postgresConfig *PostgresConfig) SetLogger(logger zerolog.Logger)
  • func (postgresConfig *PostgresConfig) SetZapLogger(logger *zap.Logger)
• type PostgresZapConfig

Constants

const (
	PgxMaxConnect = 5
)

Functions

func AfterConnectMap

func AfterConnectMap(conn *pgx.Conn) error

func NewPgxPool

func NewPgxPool(config *PostgresConfig) (*pgx.ConnPool, error)

func NewPgxPoolAfterConnect

func NewPgxPoolAfterConnect(config *PostgresConfig, afterConnectMap func(*pgx.Conn) error, debug bool) (*pgx.ConnPool, error)

func NewPgxPoolAfterConnectZap

func NewPgxPoolAfterConnectZap(config *PostgresZapConfig, afterConnectMap func(*pgx.Conn) error, debug bool) (*pgx.ConnPool, error)

Types

type PostgresConfig

type PostgresConfig struct {
	User     string     `json:"User"`
	Password string     `json:"Password"`
	Database string     `json:"Database"`
	Port     int        `json:"Port"`
	Host     string     `json:"Host"`
	Logger   pgx.Logger `json:"-"`
}

func (*PostgresConfig) SetLogger

func (postgresConfig *PostgresConfig) SetLogger(logger zerolog.Logger)

func (*PostgresConfig) SetZapLogger

func (postgresConfig *PostgresConfig) SetZapLogger(logger *zap.Logger)

type PostgresZapConfig

type PostgresZapConfig struct {
	User     string             `json:"User"`
	Password string             `json:"Password"`
	Database string             `json:"Database"`
	Port     int                `json:"Port"`
	Host     string             `json:"Host"`
	Logger   *zapadapter.Logger `json:"-"`
}