database

Oct 19, 2023

Changes in this version

type Config

+ Addrs []string

Feb 15, 2023

Changes in this version

type DBType

+ const CockroachDatabase

Jul 9, 2022

Changes in this version

type DBType

+ const PGXDatabase

May 8, 2022

Changes in this version

+ const DefaultRetryBackoffMultiplier

+ const DefaultRetryInitialBackoff

+ const DefaultRetryMaxBackoff

+ var ErrInvalidConfig = errors.New("invalid config")

+ var ErrMaxRetryAttempts = errors.New("max retry attempts has been reached")

type DB

+ func (db *DB) PingContext(ctx context.Context) error

+ func (db *DB) SetConnMaxIdleTime(d time.Duration)

+ func (db *DB) SetMaxIdleConns(n int)

+ func (db *DB) SetMaxOpenConns(n int)

type Option

+ func WithRetryPolicy(retryPolicy RetryPolicy) Option

+ type RetryPolicy struct

+ BackoffMultiplier float64

+ ErrIsRetryable func(err error) bool

+ InitialBackoff time.Duration

+ MaxAttempts int

+ MaxBackoff time.Duration

Feb 10, 2022

Changes in this version

type Config

+ Params map[string]string

Jan 30, 2022

Changes in this version

+ type Database interface

+ BeginTxx func(ctx context.Context, opts *sql.TxOptions) (*sqlx.Tx, error)

+ BindNamed func(query string, arg interface{}) (bound string, arglist []interface{}, err error)

+ Close func() error

+ ExecContext func(ctx context.Context, query string, args ...interface{}) (sql.Result, error)

+ GetContext func(ctx context.Context, dest interface{}, query string, args ...interface{}) error

+ NamedExecContext func(ctx context.Context, query string, arg interface{}) (sql.Result, error)

+ NamedQueryContext func(ctx context.Context, query string, arg interface{}) (*sqlx.Rows, error)

+ PrepareNamedContext func(ctx context.Context, query string) (*sqlx.NamedStmt, error)

+ PreparexContext func(ctx context.Context, query string) (*sqlx.Stmt, error)

+ QueryxContext func(ctx context.Context, query string, args ...interface{}) (*sqlx.Rows, error)

+ RunReadTxx func(ctx context.Context, fn TransactionFunc) error

+ RunTxx func(ctx context.Context, fn TransactionFunc) error

+ RunTxxWithOptions func(ctx context.Context, opts *sql.TxOptions, fn TransactionFunc) error

+ SelectContext func(ctx context.Context, dest interface{}, query string, args ...interface{}) error

Jan 19, 2022

Changes in this version

type DB

+ func (db *DB) RunReadTxx(ctx context.Context, fn TransactionFunc) error

+ func (db *DB) RunTxxWithOptions(ctx context.Context, opts *sql.TxOptions, fn TransactionFunc) error

Jan 13, 2022

Changes in this version

+ const DefaultRetryAttempts

type DB

+ DB *sqlx.DB

+ func (db *DB) BeginTxx(ctx context.Context, opts *sql.TxOptions) (*sqlx.Tx, error)

+ func (db *DB) Beginx() (*sqlx.Tx, error)

+ func (db *DB) BindNamed(query string, arg interface{}) (bound string, arglist []interface{}, err error)

+ func (db *DB) Close() error

+ func (db *DB) ExecContext(ctx context.Context, query string, args ...interface{}) (sql.Result, error)

+ func (db *DB) GetContext(ctx context.Context, dest interface{}, query string, args ...interface{}) error

+ func (db *DB) NamedExecContext(ctx context.Context, query string, arg interface{}) (sql.Result, error)

+ func (db *DB) NamedQueryContext(ctx context.Context, query string, arg interface{}) (*sqlx.Rows, error)

+ func (db *DB) PrepareNamedContext(ctx context.Context, query string) (*sqlx.NamedStmt, error)

+ func (db *DB) PreparexContext(ctx context.Context, query string) (*sqlx.Stmt, error)

+ func (db *DB) QueryxContext(ctx context.Context, query string, args ...interface{}) (*sqlx.Rows, error)

+ func (db *DB) SelectContext(ctx context.Context, dest interface{}, query string, args ...interface{}) error

type Option

+ func WithPQRetryFunc(maxAttempts int) Option

+ type QueryFunc func(ctx context.Context, db *sqlx.DB) error

Jan 10, 2022

Changes in this version

type Option

+ func WithMetricsHook(collector hooks.MetricCollector) Option

+ func WithPrometheusMetrics() Option

Jul 17, 2021

Changes in this version

type Config

+ func (cfg *Config) DSN() (connStr string)

Dec 19, 2020

Changes in this version

+ type Config struct

+ Addr string

+ CertPath string

+ Database string

+ ReadTimeout string

+ Type DBType

+ User string

+ WriteTimeout string

+ type DB struct

+ func New(cfg *Config, options ...Option) (db *DB, err error)

+ func (d *DB) RunTxx(ctx context.Context, fn TransactionFunc) error

+ type DBType string

+ const ClickhouseDatabase

+ const PostgresDatabase

+ const SQLiteDatabase

+ func (d DBType) String() string

+ type Option func(b *builder, cfg *hooks.Config)

+ func WithCockroachRetryFunc() Option

+ func WithCustomHook(hook dbhook.Hook) Option

+ func WithDefaultOptions(tracer opentracing.Tracer) Option

+ func WithReconnectHook() Option

+ func WithRetryFunc(f RetryFunc) Option

+ func WithSimplerrHook() Option

+ func WithTracingHook(tracer opentracing.Tracer) Option

+ type RetryFunc func(err error) bool

+ type TransactionFunc func(ctx context.Context, tx *sqlx.Tx) error