Versions in this module Expand all Collapse all v0 v0.1.0 Mar 10, 2026 Changes in this version + type Client struct + func New(ctx context.Context) (*Client, error) + func (c *Client) Close() + func (c *Client) Exec(ctx context.Context, query string, args ...any) (sql.Result, error) + func (c *Client) Ping(ctx context.Context) error + func (c *Client) Port() int + func (c *Client) Query(ctx context.Context, query string, args ...any) (*sql.Rows, error) + func (c *Client) QueryRow(ctx context.Context, query string, args ...any) *sql.Row + func (c *Client) WithTx(ctx context.Context, fn func(tx *sql.Tx) error) error + type Config struct + AsyncQueueSize int + AsyncWorkers int + ConnectTimeout time.Duration + DBName string + Host string + MaxConnIdleTime time.Duration + MaxConnLifetime time.Duration + MaxConns int32 + MinConns int32 + Password string + Port int + URL string + User string + func ConfigFromEnv() (Config, error) + func DefaultConfig() Config + type Executor struct + func NewExecutor(db *Client) *Executor + func (e *Executor) Close() + func (e *Executor) Submit(ctx context.Context, task Task) (<-chan error, error) + type Task func(ctx context.Context, db *Client) error
Go to main page