repo

Documentation

Index

• type EventRepo
  • func NewEventRepo(db *sqlx.DB) *EventRepo
  • func (e *EventRepo) AddEvent(ctx context.Context, event *model.ProductEvent, tx *sqlx.Tx) error
• type ProductRepo
  • func NewProductRepo(db *sqlx.DB) *ProductRepo
  • func (p *ProductRepo) AddProduct(ctx context.Context, pr *model.Product, tx *sqlx.Tx) error
  • func (p *ProductRepo) GetProduct(ctx context.Context, productID uint64, tx *sqlx.Tx) (model.Product, error)
  • func (p *ProductRepo) ListProducts(ctx context.Context) ([]model.Product, error)
  • func (p *ProductRepo) RemoveProduct(ctx context.Context, productID uint64, tx *sqlx.Tx) error

Types

type EventRepo

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

func NewEventRepo

func NewEventRepo(db *sqlx.DB) *EventRepo

func (*EventRepo) AddEvent

func (e *EventRepo) AddEvent(ctx context.Context, event *model.ProductEvent, tx *sqlx.Tx) error

type ProductRepo

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

func NewProductRepo

func NewProductRepo(db *sqlx.DB) *ProductRepo

func (*ProductRepo) AddProduct

func (p *ProductRepo) AddProduct(ctx context.Context, pr *model.Product, tx *sqlx.Tx) error

func (*ProductRepo) GetProduct

func (p *ProductRepo) GetProduct(ctx context.Context, productID uint64, tx *sqlx.Tx) (model.Product, error)

func (*ProductRepo) ListProducts

func (p *ProductRepo) ListProducts(ctx context.Context) ([]model.Product, error)

func (*ProductRepo) RemoveProduct

func (p *ProductRepo) RemoveProduct(ctx context.Context, productID uint64, tx *sqlx.Tx) error