db

Documentation

Index

• func GetConnectionPool(dbConfig Config) (*sqlx.DB, error)
• type Config
• type RetriableConnector
  • func (r *RetriableConnector) GetConnectionPool(dbConfig Config) (*sqlx.DB, error)
• type RetriableError
  • func (r RetriableError) Error() string
• type SleeperFunc
  • func (sf SleeperFunc) Sleep(duration time.Duration)

Functions

func GetConnectionPool

func GetConnectionPool(dbConfig Config) (*sqlx.DB, error)

Types

type Config

type Config struct {
	Type     string `json:"type"`
	Host     string `json:"host"`
	Port     int    `json:"port"`
	Username string `json:"username"`
	Password string `json:"password"`
	Name     string `json:"name"`
	SSLMode  string `json:"ssl_mode"`
}

type RetriableConnector

type RetriableConnector struct {
	Connector     func(Config) (*sqlx.DB, error)
	Sleeper       sleeper
	RetryInterval time.Duration
	MaxRetries    int
}

func (*RetriableConnector) GetConnectionPool

func (r *RetriableConnector) GetConnectionPool(dbConfig Config) (*sqlx.DB, error)

type RetriableError

type RetriableError struct {
	Inner error
	Msg   string
}

func (RetriableError) Error

func (r RetriableError) Error() string

type SleeperFunc

type SleeperFunc func(time.Duration)

func (SleeperFunc) Sleep

func (sf SleeperFunc) Sleep(duration time.Duration)