db

Documentation

Index

• type Config
  • func DefaultConfig() Config
• type Db
  • func New(c Config, l *zap.Logger) (*Db, error)
  • func (db *Db) Check(ctx context.Context) error
  • func (db *Db) Grace(_ context.Context) error
  • func (db *Db) Name() string
  • func (db *Db) Start(ctx context.Context) error
• type TxFunc
• type TxManager
  • func (m *TxManager[T]) Do(ctx context.Context, fn TxFunc[T]) error

Types

type Config

type Config struct {
	DSN             string
	MaxConns        int32
	MinConns        int32
	MaxConnLifetime time.Duration
	MaxConnIdleTime time.Duration
}

func DefaultConfig

func DefaultConfig() Config

type Db

type Db struct {
	*pgxpool.Pool
	// contains filtered or unexported fields
}

func New

func New(c Config, l *zap.Logger) (*Db, error)

func (*Db) Check

func (db *Db) Check(ctx context.Context) error

func (*Db) Grace

func (db *Db) Grace(_ context.Context) error

func (*Db) Name

func (db *Db) Name() string

func (*Db) Start

func (db *Db) Start(ctx context.Context) error

type TxFunc

type TxFunc[T any] func(ctx context.Context, q T) error

type TxManager

type TxManager[T any] struct {
	Begin func(ctx context.Context) (
		T,
		func(ctx context.Context) error,
		func(ctx context.Context) error,
		error,
	)
}

func (*TxManager[T]) Do

func (m *TxManager[T]) Do(ctx context.Context, fn TxFunc[T]) error