Documentation
¶
Index ¶
- func IsDuplicateKey(err error) bool
- type ConnectionConfig
- func (instance *ConnectionConfig) Database() string
- func (instance *ConnectionConfig) Host() string
- func (instance *ConnectionConfig) Password() string
- func (instance *ConnectionConfig) Port() string
- func (instance *ConnectionConfig) SafeContext() map[string]any
- func (instance *ConnectionConfig) User() string
- type PoolConfig
- type PostBuildHook
- type Provider
- func (instance *Provider) Open(params bunorm.ConnectionParams, logger loggingcontract.Logger) (*bun.DB, error)
- func (instance *Provider) WithPoolConfig(poolConfig *PoolConfig) *Provider
- func (instance *Provider) WithRetryConfig(retryConfig *RetryConfig) *Provider
- func (instance *Provider) WithTimeoutConfig(timeoutConfig *TimeoutConfig) *Provider
- type ProviderOption
- type RetryConfig
- type TimeoutConfig
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func IsDuplicateKey ¶
Types ¶
type ConnectionConfig ¶
type ConnectionConfig struct {
// contains filtered or unexported fields
}
func NewConnectionConfig ¶
func (*ConnectionConfig) Database ¶
func (instance *ConnectionConfig) Database() string
func (*ConnectionConfig) Host ¶
func (instance *ConnectionConfig) Host() string
func (*ConnectionConfig) Password ¶
func (instance *ConnectionConfig) Password() string
func (*ConnectionConfig) Port ¶
func (instance *ConnectionConfig) Port() string
func (*ConnectionConfig) SafeContext ¶
func (instance *ConnectionConfig) SafeContext() map[string]any
func (*ConnectionConfig) User ¶
func (instance *ConnectionConfig) User() string
type PoolConfig ¶
type PoolConfig struct {
MaxOpenConnections int
MaxIdleConnections int
ConnectionMaxLifetime time.Duration
ConnectionMaxIdleTime time.Duration
}
func DefaultPoolConfig ¶
func DefaultPoolConfig() *PoolConfig
func NewPoolConfig ¶
type PostBuildHook ¶
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)
func (*Provider) WithPoolConfig ¶
func (instance *Provider) WithPoolConfig(poolConfig *PoolConfig) *Provider
func (*Provider) WithRetryConfig ¶
func (instance *Provider) WithRetryConfig(retryConfig *RetryConfig) *Provider
func (*Provider) WithTimeoutConfig ¶
func (instance *Provider) WithTimeoutConfig(timeoutConfig *TimeoutConfig) *Provider
type ProviderOption ¶
type ProviderOption func(provider *Provider)
func WithPostBuildHook ¶
func WithPostBuildHook(hook PostBuildHook) ProviderOption
type RetryConfig ¶
type RetryConfig struct {
MaxAttempts uint32
InitialDelay time.Duration
MaxDelay time.Duration
BackoffMultiplier float64
}
func DefaultRetryConfig ¶
func DefaultRetryConfig() *RetryConfig
func NewRetryConfig ¶
type TimeoutConfig ¶
func DefaultTimeoutConfig ¶
func DefaultTimeoutConfig() *TimeoutConfig
func NewTimeoutConfig ¶
func NewTimeoutConfig( connectTimeout time.Duration, ) *TimeoutConfig
Click to show internal directories.
Click to hide internal directories.