product

Documentation

Index

• Variables
• type EventRepo
• type ProductRepo
• type Service
  • func NewService(productRepo ProductRepo, eventRepo EventRepo, db *sqlx.DB) *Service
  • func (s *Service) CreateProduct(ctx context.Context, productDto dto.CreateProductCommand) (dto.Product, error)
  • func (s *Service) DeleteProduct(ctx context.Context, productID uint64) (dto.Product, error)
  • func (s *Service) GetProductById(ctx context.Context, id uint64) (dto.Product, error)
  • func (s *Service) GetProducts(ctx context.Context) ([]dto.Product, error)

Variables

var ProductNotFound = errors.New("products not found")

Types

type EventRepo

type EventRepo interface {
	AddEvent(ctx context.Context, event *model.ProductEvent, tx *sqlx.Tx) error
}

type ProductRepo

type ProductRepo interface {
	AddProduct(ctx context.Context, product *model.Product, tx *sqlx.Tx) error
	GetProduct(ctx context.Context, productID uint64, tx *sqlx.Tx) (model.Product, error)
	ListProducts(ctx context.Context) ([]model.Product, error)
	RemoveProduct(ctx context.Context, productID uint64, tx *sqlx.Tx) error
}

type Service

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

func NewService

func NewService(
	productRepo ProductRepo,
	eventRepo EventRepo,
	db *sqlx.DB) *Service

func (*Service) CreateProduct

func (s *Service) CreateProduct(
	ctx context.Context,
	productDto dto.CreateProductCommand,
) (dto.Product, error)

func (*Service) DeleteProduct

func (s *Service) DeleteProduct(ctx context.Context, productID uint64) (dto.Product, error)

func (*Service) GetProductById

func (s *Service) GetProductById(ctx context.Context, id uint64) (dto.Product, error)

func (*Service) GetProducts

func (s *Service) GetProducts(ctx context.Context) ([]dto.Product, error)