database

Documentation

Index

• Variables
• func New(ctx context.Context, cnf *config.Config) (*poolDB, error)
• func NewSingle(ctx context.Context, cnf *config.Config) (*singleDB, error)
• func Transaction(ctx context.Context, f func(c context.Context) error) error
• func WithDB(ctx context.Context, db DB) context.Context
• type DB
  • func FromContext(ctx context.Context) DB

Variables

var ErrTxAlreadyStarted = errors.New("transaction already started")

Functions

func New

func New(ctx context.Context, cnf *config.Config) (*poolDB, error)

func NewSingle

func NewSingle(ctx context.Context, cnf *config.Config) (*singleDB, error)

func Transaction

func Transaction(ctx context.Context, f func(c context.Context) error) error

func WithDB

func WithDB(ctx context.Context, db DB) context.Context

Types

type DB

type DB interface {
	Queries() *sqlc.Queries
	Close()
	Ping(ctx context.Context) error
}

func FromContext

func FromContext(ctx context.Context) DB