Documentation
¶
Index ¶
- type Client
- 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
- type Executor
- type Task
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
type Config ¶
type Config struct {
URL string
MinConns int32
MaxConns int32
MaxConnLifetime time.Duration
MaxConnIdleTime time.Duration
ConnectTimeout time.Duration
Host string
Port int
DBName string
User string
Password string
AsyncWorkers int
AsyncQueueSize int
}
func ConfigFromEnv ¶
func DefaultConfig ¶
func DefaultConfig() Config
type Executor ¶
type Executor struct {
// contains filtered or unexported fields
}
func NewExecutor ¶
Click to show internal directories.
Click to hide internal directories.