driver

Jan 9, 2025

Changes in this version

+ type KVClient interface

+ Close func() error

+ PingContext func(ctx context.Context) error

+ type KVReader interface

+ GetContext func(ctx context.Context, key string) (any, error)

+ type KVWriter interface

+ SetContext func(ctx context.Context, key string, value any) error

+ type SQL map[string]*sql.DB

+ func NewSQL(config map[string]config.SQL) (SQL, error)

+ func (d SQL) Get(name ...string) some.Some[*sql.DB]

+ func (d SQL) GetNoDefault(name ...string) some.Some[*sql.DB]

+ type SQLExecutor interface

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

+ type SQLPreparation interface

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

+ type SQLQuerier interface

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

+ PingContext func(ctx context.Context) error

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

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

+ type SQLTx interface

+ Commit func() error

+ Rollback func() error