pgsql

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

type ClientConfig struct {
	DSN string `json:"dsn"`
}

type LockConn interface {
	QueryRow(ctx context.Context, sql string, args ...any) pgx.Row
	Exec(ctx context.Context, sql string, arguments ...any) (pgconn.CommandTag, error)
}

type PoolConfig struct {
	DSN      string `json:"dsn"`      // DSN database connection string
	MinConns int32  `json:"minConns"` // MinConns minimum number of pool connections
	MaxConns int32  `json:"maxConns"` // MaxConns max number of pool connections

	// ConnLifeTime is the duration in seconds since creation after which a connection will be automatically closed
	ConnLifeTime int `json:"connLifeTime"`
	// ConnIdleTime is the duration in seconds after which an idle connection will be automatically closed by the health check
	ConnIdleTime int `json:"connIdleTime"`
	// HealthCheckInterval is the duration in seconds between checks of the health of idle connections
	HealthCheckInterval int `json:"healthCheckInterval"`
	// ConnTimeout is the max duration in seconds of a database operation until timeout is reached
	ConnTimeout int `json:"connTimeout"`

	// optional method override
	BeforeConnect func(context.Context, *pgx.ConnConfig) error
	AfterConnect  func(context.Context, *pgx.Conn) error
	BeforeAcquire func(context.Context, *pgx.Conn) bool
	AfterRelease  func(*pgx.Conn) bool
	BeforeClose   func(*pgx.Conn)
}