pgsql

package module
v3.0.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 8, 2026 License: MIT Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func IsDuplicateKey

func IsDuplicateKey(err error) bool

Types

type PoolConfig

type PoolConfig struct {
	MaxOpenConnections    int
	MaxIdleConnections    int
	ConnectionMaxLifetime time.Duration
	ConnectionMaxIdleTime time.Duration
}

func DefaultPoolConfig

func DefaultPoolConfig() *PoolConfig

func NewPoolConfig

func NewPoolConfig(
	maxOpenConnections int,
	maxIdleConnections int,
	connectionMaxLifetime time.Duration,
	connectionMaxIdleTime time.Duration,
) *PoolConfig

type PostBuildHook

type PostBuildHook func(
	ctx context.Context,
	connector *pgdriver.Connector,
) error

type Provider

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

func NewProvider

func NewProvider(
	providerOptions ...ProviderOption,
) *Provider

func (*Provider) Open

func (instance *Provider) Open(params bunorm.ConnectionParams, logger loggingcontract.Logger) (*bun.DB, error)

type ProviderOption

type ProviderOption func(provider *Provider)

func WithPoolConfig

func WithPoolConfig(poolConfig *PoolConfig) ProviderOption

func WithPostBuildHook

func WithPostBuildHook(hook PostBuildHook) ProviderOption

func WithRetryConfig

func WithRetryConfig(retryConfig *RetryConfig) ProviderOption

func WithTimeoutConfig

func WithTimeoutConfig(timeoutConfig *TimeoutConfig) ProviderOption

type RetryConfig

type RetryConfig struct {
	MaxAttempts       uint32
	InitialDelay      time.Duration
	MaxDelay          time.Duration
	BackoffMultiplier float64
}

func DefaultRetryConfig

func DefaultRetryConfig() *RetryConfig

func NewRetryConfig

func NewRetryConfig(
	maxAttempts uint32,
	initialDelay time.Duration,
	maxDelay time.Duration,
	backoffMultiplier float64,
) *RetryConfig

type TimeoutConfig

type TimeoutConfig struct {
	ConnectTimeout time.Duration
}

func DefaultTimeoutConfig

func DefaultTimeoutConfig() *TimeoutConfig

func NewTimeoutConfig

func NewTimeoutConfig(
	connectTimeout time.Duration,
) *TimeoutConfig

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL