pg

Documentation

Index

• func MustNewPGXPool(ctx context.Context, dsn string) *pgxpool.Pool
• func NewProductRepository(db *pgxpool.Pool) repository.ProductRepository
• type ProductRepository
  • func (p ProductRepository) Deactivate(ctx context.Context, id uuid.UUID) error
  • func (p ProductRepository) GetById(ctx context.Context, id uuid.UUID) (*domain.Product, error)
  • func (p ProductRepository) Save(ctx context.Context, product *domain.Product) error
  • func (p ProductRepository) Search(ctx context.Context, options domain.SearchOptions, limit, offset uint64) ([]*domain.Product, error)
  • func (p ProductRepository) Update(ctx context.Context, product *domain.Product) error

Functions

func MustNewPGXPool

func MustNewPGXPool(ctx context.Context, dsn string) *pgxpool.Pool

func NewProductRepository

func NewProductRepository(db *pgxpool.Pool) repository.ProductRepository

Types

type ProductRepository

type ProductRepository struct {
	// contains filtered or unexported fields
}

func (ProductRepository) Deactivate

func (p ProductRepository) Deactivate(ctx context.Context, id uuid.UUID) error

func (ProductRepository) GetById

func (p ProductRepository) GetById(ctx context.Context, id uuid.UUID) (*domain.Product, error)

func (ProductRepository) Save

func (p ProductRepository) Save(ctx context.Context, product *domain.Product) error

func (ProductRepository) Search

func (p ProductRepository) Search(ctx context.Context, options domain.SearchOptions, limit, offset uint64) ([]*domain.Product, error)

func (ProductRepository) Update

func (p ProductRepository) Update(ctx context.Context, product *domain.Product) error