pg

Documentation

Index

• Constants
• func IsNetworkError(err error) bool
• type CircuitBreaker
• type Client
  • func New(params ClientParams) (Client, error)
  • func (c Client) Break()
  • func (c Client) BreakOnNetworkError(err error) bool
  • func (c Client) GetCircuitBreaker() CircuitBreaker
  • func (c Client) IsAvailable() bool
  • func (c Client) Open(config gorm.Config) (*gorm.DB, error)
  • func (c Client) Shutdown(ctx context.Context) error
• type ClientParams
  • func (cp ClientParams) String() string

Constants

const SlowQueryThreshold = 250 * time.Millisecond

Functions

func IsNetworkError

func IsNetworkError(err error) bool

Types

type CircuitBreaker

type CircuitBreaker interface {
	IsAvailable() bool
	Break()
	BreakOnNetworkError(err error) bool
}

type Client

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

func New

func New(params ClientParams) (Client, error)

func (Client) Break

func (c Client) Break()

func (Client) BreakOnNetworkError

func (c Client) BreakOnNetworkError(err error) bool

func (Client) GetCircuitBreaker

func (c Client) GetCircuitBreaker() CircuitBreaker

func (Client) IsAvailable

func (c Client) IsAvailable() bool

func (Client) Open

func (c Client) Open(config gorm.Config) (*gorm.DB, error)

func (Client) Shutdown

func (c Client) Shutdown(ctx context.Context) error

type ClientParams

type ClientParams struct {
	User     string
	Password string
	Host     string
	Port     uint
	DBName   string

	MaxIdleConns *int
	MaxOpenConns *int

	CircuitBreakerCheckInterval *time.Duration
}

func (ClientParams) String

func (cp ClientParams) String() string