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" validate:"nonzero"`
	ConnectionString string `json:"connection_string" validate:"nonzero"`
}

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)