database

Documentation

Index

• type Database
• type Option
  • func ConnAttempts(attempts int32) Option
  • func ConnTimeout(timeout time.Duration) Option
  • func Isolation(isolation pgx.TxIsoLevel) Option
  • func MaxPoolSize(size int32) Option
• type Postgres
  • func New(cfg *config.Config, opts ...Option) (*Postgres, error)
  • func (p *Postgres) Close()

Types

type Database

type Database interface {
	Query(ctx context.Context, sql string, args ...any) (pgx.Rows, error)
	QueryRow(ctx context.Context, sql string, args ...any) pgx.Row
	Exec(ctx context.Context, sql string, arguments ...any) (pgconn.CommandTag, error)
}

Postgres -.

type Option

type Option func(*Postgres)

Option -.

func ConnAttempts

func ConnAttempts(attempts int32) Option

ConnAttempts -.

func ConnTimeout

func ConnTimeout(timeout time.Duration) Option

ConnTimeout -.

func Isolation

func Isolation(isolation pgx.TxIsoLevel) Option

Isolation Level -.

func MaxPoolSize

func MaxPoolSize(size int32) Option

MaxPoolSize -.

type Postgres

type Postgres struct {
	Builder squirrel.StatementBuilderType
	Pool    *pgxpool.Pool
	// contains filtered or unexported fields
}

Postgres -.

func New

func New(cfg *config.Config, opts ...Option) (*Postgres, error)

New -.

func (*Postgres) Close

func (p *Postgres) Close()