dbresolver

package module

Go to main page

Versions in this module

v2

v2.1.2-beta

Jan 17, 2024

v2.1.1-beta

Jan 17, 2024

v2.1.0

Sep 20, 2023

Changes in this version

+ type Conn interface

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

+ Close func() error

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

+ PingContext func(ctx context.Context) error

+ PrepareContext func(ctx context.Context, query string) (Stmt, error)

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

+ QueryRowContext func(ctx context.Context, query string, args ...interface{}) *sql.Row

+ Raw func(f func(driverConn interface{}) error) (err error)

+ type DefaultQueryTypeChecker struct

+ func (c DefaultQueryTypeChecker) Check(query string) QueryType

type Option

+ QueryTypeChecker QueryTypeChecker

type OptionFunc

+ func WithQueryTypeChecker(checker QueryTypeChecker) OptionFunc

+ type QueryType int

+ const QueryTypeRead

+ const QueryTypeUnknown

+ const QueryTypeWrite

+ type QueryTypeChecker interface

+ Check func(query string) QueryType

+ type Tx interface

+ Commit func() error

+ Exec func(query string, args ...interface{}) (sql.Result, error)

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

+ Prepare func(query string) (Stmt, error)

+ PrepareContext func(ctx context.Context, query string) (Stmt, error)

+ Query func(query string, args ...interface{}) (*sql.Rows, error)

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

+ QueryRow func(query string, args ...interface{}) *sql.Row

+ QueryRowContext func(ctx context.Context, query string, args ...interface{}) *sql.Row

+ Rollback func() error

+ Stmt func(stmt Stmt) Stmt

+ StmtContext func(ctx context.Context, stmt Stmt) Stmt

v2.0.1

Jun 17, 2023

Changes in this version

+ const Commit

+ const ReleaseTime

+ const Version

v2.0.0

Apr 13, 2023

retracted

Changes in this version

+ type DB interface

+ Begin func() (*sql.Tx, error)

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

+ Close func() error

+ Conn func(ctx context.Context) (*sql.Conn, error)

+ Driver func() driver.Driver

+ Exec func(query string, args ...interface{}) (sql.Result, error)

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

+ Ping func() error

+ PingContext func(ctx context.Context) error

+ Prepare func(query string) (Stmt, error)

+ PrepareContext func(ctx context.Context, query string) (Stmt, error)

+ PrimaryDBs func() []*sql.DB

+ Query func(query string, args ...interface{}) (*sql.Rows, error)

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

+ QueryRow func(query string, args ...interface{}) *sql.Row

+ QueryRowContext func(ctx context.Context, query string, args ...interface{}) *sql.Row

+ ReplicaDBs func() []*sql.DB

+ SetConnMaxIdleTime func(d time.Duration)

+ SetConnMaxLifetime func(d time.Duration)

+ SetMaxIdleConns func(n int)

+ SetMaxOpenConns func(n int)

+ Stats func() sql.DBStats

+ func New(opts ...OptionFunc) DB

+ type DBConnection interface

+ type DBLoadBalancer LoadBalancer[*sql.DB]

+ type LoadBalancer interface

+ Name func() LoadBalancerPolicy

+ Resolve func([]T) T

+ type LoadBalancerPolicy string

+ const RandomLB

+ const RoundRobinLB

+ type Option struct

+ DBLB DBLoadBalancer

+ PrimaryDBs []*sql.DB

+ ReplicaDBs []*sql.DB

+ StmtLB StmtLoadBalancer

+ type OptionFunc func(opt *Option)

+ func WithLoadBalancer(lb LoadBalancerPolicy) OptionFunc

+ func WithPrimaryDBs(primaryDBs ...*sql.DB) OptionFunc

+ func WithReplicaDBs(replicaDBs ...*sql.DB) OptionFunc

+ type RandomLoadBalancer struct

+ func (lb RandomLoadBalancer[T]) Name() LoadBalancerPolicy

+ func (lb RandomLoadBalancer[T]) Resolve(dbs []T) T

+ type RoundRobinLoadBalancer struct

+ func (lb *RoundRobinLoadBalancer[T]) Resolve(dbs []T) T

+ func (lb RoundRobinLoadBalancer[T]) Name() LoadBalancerPolicy

+ type Stmt interface

+ Close func() error

+ Exec func(...interface{}) (sql.Result, error)

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

+ Query func(...interface{}) (*sql.Rows, error)

+ QueryContext func(ctx context.Context, args ...interface{}) (*sql.Rows, error)

+ QueryRow func(args ...interface{}) *sql.Row

+ QueryRowContext func(ctx context.Context, args ...interface{}) *sql.Row

+ type StmtLoadBalancer LoadBalancer[*sql.Stmt]

v2.0.0-beta.2

Dec 23, 2022

retracted

v2.0.0-beta

Dec 12, 2022

retracted

v2.0.0-alpha.5

Dec 12, 2022

retracted

v2.0.0-alpha.4

Dec 11, 2022

retracted

v2.0.0-alpha.3

Dec 11, 2022

retracted

v2.0.0-alpha.2

Dec 10, 2022

retracted

v2.0.0-alpha

Dec 10, 2022

retracted

Other modules containing this package

github.com/bxcodec/dbresolver

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL