dbx

Jul 24, 2024

Changes in this version

+ func GetDatabase(dsn string) (string, error)

+ func GetHost(dsn string) (string, error)

Jul 23, 2024

Changes in this version

type DB

+ func (db *DB[T]) Copy() *DB[T]

Jul 23, 2024

Changes in this version

type DB

+ func (db *DB[T]) WithDefaultNodeStrategy(strategy GetNodeStragegy) *DB[T]

+ func (db *DB[T]) WithNodeWaitTimeout(timeout time.Duration) *DB[T]

+ func (db *DB[T]) WithReadFromNodeStrategy(strategy GetNodeStragegy) *DB[T]

+ func (db *DB[T]) WithWriteToNodeStrategy(strategy GetNodeStragegy) *DB[T]

Jul 23, 2024

Changes in this version

type DB

+ func (db *DB[T]) WithCtx(ctx context.Context) *DB[T]

Jul 23, 2024

Changes in this version

type DBxer

+ Close func()

Jul 22, 2024

Changes in this version

type DB

+ DefaultNodeStrategy GetNodeStragegy

+ ReadFromNodeStrategy GetNodeStragegy

+ WriteToNodeStrategy GetNodeStragegy

+ func (db *DB[T]) GetConn(ctx context.Context, strategy GetNodeStragegy) (T, error)

+ func (db *DB[T]) GetDefaultConn(ctx context.Context) (T, error)

+ func (db *DB[T]) GetReadFromConn(ctx context.Context) (T, error)

+ func (db *DB[T]) GetWriteToConn(ctx context.Context) (T, error)

type DBxer

+ GetConn func(ctx context.Context, strategy GetNodeStragegy) (TConn, error)

+ GetDefaultConn func(ctx context.Context) (TConn, error)

+ GetReadFromConn func(ctx context.Context) (TConn, error)

+ GetWriteToConn func(ctx context.Context) (TConn, error)

+ type GetNodeStragegy struct

+ Criteria cluster.NodeStateCriteria

+ Wait bool

+ func NoWait(criteria cluster.NodeStateCriteria) GetNodeStragegy

+ func NoWaitAlive() GetNodeStragegy

+ func NoWaitPrimary() GetNodeStragegy

+ func NoWaitPrimaryPreferred() GetNodeStragegy

+ func NoWaitStandby() GetNodeStragegy

+ func NoWaitStandbyPreferred() GetNodeStragegy

+ func WaitForAlive() GetNodeStragegy

+ func WaitForPrimary() GetNodeStragegy

+ func WaitForPrimaryPreferred() GetNodeStragegy

+ func WaitForStandby() GetNodeStragegy

+ func WaitForStandbyPreferred() GetNodeStragegy

type Option

+ func WithDefaultNodeStrategy[T any](strategy GetNodeStragegy) Option[T]

+ func WithReadFromNodeStrategy[T any](strategy GetNodeStragegy) Option[T]

+ func WithWriteToNodeStrategy[T any](strategy GetNodeStragegy) Option[T]

Jul 22, 2024

Changes in this version

+ func Scan[T any](rows Rows, pointers func(*T) []interface{}) ([]T, error)

+ type ConnOpener func(ctx context.Context, driverName string, dsn string) (T, error)

+ type DB struct

+ Cluster *cluster.Cluster[T]

+ Ctx context.Context

+ DefaultNode cluster.NodeStateCriteria

+ NodeWaitTimeout time.Duration

+ ReadFromNode cluster.NodeStateCriteria

+ WriteToNode cluster.NodeStateCriteria

+ func NewDB[T any](driverName string, dsns []string, connOpener ConnOpener[T], ...) (*DB[T], error)

+ func (db *DB[T]) Close()

+ func (db *DB[T]) WaitForConn(ctx context.Context, criteria cluster.NodeStateCriteria) (T, error)

+ func (db *DB[T]) WaitForDefaultConn(ctx context.Context) (T, error)

+ func (db *DB[T]) WaitForReadFromConn(ctx context.Context) (T, error)

+ func (db *DB[T]) WaitForWriteToConn(ctx context.Context) (T, error)

+ type DBxer interface

+ DoTx func(f func(db DBxer[TConn, TTx, TTxOptions]) error, opts TTxOptions) error

+ DoTxContext func(ctx context.Context, ...) error

+ Tx func() (TTx, error)

+ WaitForConn func(ctx context.Context, criteria cluster.NodeStateCriteria) (TConn, error)

+ WaitForDefaultConn func(ctx context.Context) (TConn, error)

+ WaitForReadFromConn func(ctx context.Context) (TConn, error)

+ WaitForWriteToConn func(ctx context.Context) (TConn, error)

+ type Option func(*DB[T])

+ func WithClusterOptions[T any](options ...cluster.ClusterOption[T]) Option[T]

+ func WithCtx[T any](ctx context.Context) Option[T]

+ func WithDefaultNode[T any](criteria cluster.NodeStateCriteria) Option[T]

+ func WithNodeWaitTimeout[T any](timeout time.Duration) Option[T]

+ func WithReadFromNode[T any](criteria cluster.NodeStateCriteria) Option[T]

+ func WithWriteToNode[T any](criteria cluster.NodeStateCriteria) Option[T]

+ type Row interface

+ Err func() error

+ Scan func(dest ...any) error

+ type Rows interface

+ Next func() bool