postgres

Apr 12, 2024

Changes in this version

+ type MetricsAdapter struct

+ func (MetricsAdapter) BeforeQuery(_ context.Context, _ *pg.QueryEvent) (context.Context, error)

+ func (m MetricsAdapter) AfterQuery(ctx context.Context, event *pg.QueryEvent) error

+ type OpenTracingAdapter struct

+ func (OpenTracingAdapter) AfterQuery(ctx context.Context, event *pg.QueryEvent) error

+ func (OpenTracingAdapter) BeforeQuery(_ context.Context, _ *pg.QueryEvent) (context.Context, error)

+ type QueryLogger struct

+ func (QueryLogger) AfterQuery(ctx context.Context, event *pg.QueryEvent) error

+ func (QueryLogger) BeforeQuery(_ context.Context, _ *pg.QueryEvent) (context.Context, error)

Nov 15, 2022

Changes in this version

+ func IsErrConnectionFailed(err error) bool

Jul 4, 2022

Changes in this version

type Config

+ LogRead bool

+ LogWrite bool

type ConfigOption

+ func WithQueryLogging(logRead, logWrite bool) ConfigOption

Apr 7, 2022

Changes in this version

+ type ConfigOption func(cfg *Config)

+ func WithApplicationName(applicationName string) ConfigOption

+ func WithDatabase(database string) ConfigOption

+ func WithDialTimeout(dialTimeout time.Duration) ConfigOption

+ func WithHealthCheckResultTTL(healthCheckResultTTL time.Duration) ConfigOption

+ func WithHealthCheckTableName(healthCheckTableName string) ConfigOption

+ func WithHost(host string) ConfigOption

+ func WithIdleCheckFrequency(idleCheckFrequency time.Duration) ConfigOption

+ func WithIdleTimeout(idleTimeout time.Duration) ConfigOption

+ func WithMaxConnAge(maxConnAge time.Duration) ConfigOption

+ func WithMaxRetries(maxRetries int) ConfigOption

+ func WithMaxRetryBackoff(maxRetryBackoff time.Duration) ConfigOption

+ func WithMinIdleConns(minIdleConns int) ConfigOption

+ func WithMinRetryBackoff(minRetryBackoff time.Duration) ConfigOption

+ func WithPassword(password string) ConfigOption

+ func WithPoolSize(poolSize int) ConfigOption

+ func WithPoolTimeout(poolTimeout time.Duration) ConfigOption

+ func WithPort(port int) ConfigOption

+ func WithReadTimeout(readTimeout time.Duration) ConfigOption

+ func WithRetryStatementTimeout(retryStatementTimeout bool) ConfigOption

+ func WithUser(user string) ConfigOption

+ func WithWriteTimeout(writeTimeout time.Duration) ConfigOption

Oct 26, 2020

Changes in this version

+ type Config struct

+ ApplicationName string

+ Database string

+ DialTimeout time.Duration

+ HealthCheckResultTTL time.Duration

+ HealthCheckTableName string

+ Host string

+ IdleCheckFrequency time.Duration

+ IdleTimeout time.Duration

+ MaxConnAge time.Duration

+ MaxRetries int

+ MaxRetryBackoff time.Duration

+ MinIdleConns int

+ MinRetryBackoff time.Duration

+ Password string

+ PoolSize int

+ PoolTimeout time.Duration

+ Port int

+ ReadTimeout time.Duration

+ RetryStatementTimeout bool

+ User string

+ WriteTimeout time.Duration

Nov 29, 2019

Changes in this version

+ var ErrNotUnique = errors.New("not unique")

+ func DefaultConnectionPool() *pg.DB

+ type ConnectionPoolMetrics struct

+ func NewConnectionPoolMetrics() *ConnectionPoolMetrics

+ func (m *ConnectionPoolMetrics) Collect(ch chan<- prometheus.Metric)

+ func (m *ConnectionPoolMetrics) Describe(ch chan<- *prometheus.Desc)

+ func (m *ConnectionPoolMetrics) ObserveRegularly(ctx context.Context, db *pg.DB, poolName string) error

+ func (m *ConnectionPoolMetrics) ObserveWhenTriggered(trigger <-chan chan<- struct{}, db *pg.DB, poolName string) error

Nov 7, 2019

Changes in this version

+ type HealthCheck struct

+ Pool *pg.DB

+ func (h *HealthCheck) CleanUp() error

+ func (h *HealthCheck) HealthCheck() (bool, error)

+ func (h *HealthCheck) Init() error

Feb 11, 2019

Changes in this version

+ func ConnectionPool() *pg.DB

+ func CustomConnectionPool(opts *pg.Options) *pg.DB