Documentation
¶
Index ¶
- Variables
- func CtxWithTimeout(timeout time.Duration) (context.Context, context.CancelFunc)
- type Config
- type Database
- func (db *Database) Close()
- func (db *Database) Execute(ctx context.Context, sql string, args ...any) (int64, error)
- func (db *Database) Name() string
- func (db *Database) Pool() *pgxpool.Pool
- func (db *Database) Query(ctx context.Context, sql string, args ...any) (Rows, error)
- func (db *Database) QueryRow(ctx context.Context, sql string, args ...any) Row
- func (db *Database) Transaction(ctx context.Context, fn func(*Transaction) error) error
- type Logger
- type Row
- type Rows
- type Transaction
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrNoRows = pgx.ErrNoRows
Functions ¶
func CtxWithTimeout ¶
Types ¶
type Config ¶
type Config struct {
Name string `dm:"name"`
Host string `dm:"host"`
Port int `dm:"port"`
Username string `dm:"username"`
Password string `dm:"password"`
MaxConns int `dm:"max_conns"`
MinConns int `dm:"min_conns"`
MaxConnLifetime time.Duration `dm:"max_conn_lifetime"`
MaxConnIdleTime time.Duration `dm:"max_conn_idle_time"`
HealthCheckPeriod time.Duration `dm:"health_check_period"`
ConnectTimeout time.Duration `dm:"connect_timeout"`
Logger Logger
}
type Database ¶
type Database struct {
// contains filtered or unexported fields
}
func NewDatabase ¶
func (*Database) Transaction ¶
type Transaction ¶
type Transaction struct {
// contains filtered or unexported fields
}
Click to show internal directories.
Click to hide internal directories.