postgres

Documentation

Index

• func NewCardRepository(connection *DBConnection, cfg config.Images) cards.CardRepository
• func NewCollectionRepository(connection *DBConnection, cfg config.Images) cards.CollectionRepository
• func NewDetectRepository(connection *DBConnection, cfg config.Images) cards.DetectRepository
• type DBConn
• type DBConnection
  • func Connect(ctx context.Context, config config.Database) (*DBConnection, error)
  • func (d *DBConnection) Close() error
  • func (d *DBConnection) WithTransaction(ctx context.Context, f func(conn *DBConnection) error) error

Functions

func NewCardRepository

func NewCardRepository(connection *DBConnection, cfg config.Images) cards.CardRepository

func NewCollectionRepository

func NewCollectionRepository(connection *DBConnection, cfg config.Images) cards.CollectionRepository

func NewDetectRepository

func NewDetectRepository(connection *DBConnection, cfg config.Images) cards.DetectRepository

Types

type DBConn

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

DBConn implemented by pgx.Conn and pgx.Tx.

type DBConnection

type DBConnection struct {
	Conn DBConn
	// contains filtered or unexported fields
}

func Connect

func Connect(ctx context.Context, config config.Database) (*DBConnection, error)

func (*DBConnection) Close

func (d *DBConnection) Close() error

func (*DBConnection) WithTransaction

func (d *DBConnection) WithTransaction(ctx context.Context, f func(conn *DBConnection) error) error