command

Documentation

Index

• type CommandHandler
• type CreateCategory
• type CreateCategoryHandler
  • func NewCreateCategoryHandler(sf sonyflake.IDGenerator, logger logger.Logger, ...) CreateCategoryHandler
• type CreateProduct
• type CreateProductHandler
  • func NewCreateProductHandler(sf sonyflake.IDGenerator, logger logger.Logger, ...) CreateProductHandler
• type PurchaseProduct
• type PurchasedProduct
• type RollbackProductInventory
• type RollbackProductInventoryHandler
  • func NewRollbackProductInventoryHandler(logger logger.Logger, productRepo domain.ProductRepository) RollbackProductInventoryHandler
• type UpdateProductDetail
• type UpdateProductDetailHandler
  • func NewUpdateProductDetailHandler(logger logger.Logger, productRepo domain.ProductRepository) UpdateProductDetailHandler
• type UpdateProductInventory
• type UpdateProductInventoryHandler
  • func NewUpdateProductInventoryHandler(logger logger.Logger, productRepo domain.ProductRepository) UpdateProductInventoryHandler

Types

type CommandHandler

type CommandHandler[C any] interface {
	Handle(ctx context.Context, cmd C) error
}

type CreateCategory

type CreateCategory struct {
	Name        string
	Description string
}

type CreateCategoryHandler

type CreateCategoryHandler CommandHandler[CreateCategory]

func NewCreateCategoryHandler

func NewCreateCategoryHandler(sf sonyflake.IDGenerator, logger logger.Logger, categoryRepo domain.CategoryRepository) CreateCategoryHandler

type CreateProduct

type CreateProduct struct {
	Name        string
	BrandName   string
	Description string
	Price       uint64
	CategoryID  uint64
	Inventory   uint64
}

type CreateProductHandler

type CreateProductHandler CommandHandler[CreateProduct]

func NewCreateProductHandler

func NewCreateProductHandler(sf sonyflake.IDGenerator, logger logger.Logger, productRepo domain.ProductRepository) CreateProductHandler

type PurchaseProduct

type PurchaseProduct struct {
	ID       uint64
	Quantity uint64
}

type PurchasedProduct

type PurchasedProduct struct {
	ID       uint64
	Quantity uint64
}

type RollbackProductInventory

type RollbackProductInventory struct {
	IdempotencyKey    uint64
	PurchasedProducts *[]PurchasedProduct
}

type RollbackProductInventoryHandler

type RollbackProductInventoryHandler CommandHandler[RollbackProductInventory]

func NewRollbackProductInventoryHandler

func NewRollbackProductInventoryHandler(logger logger.Logger, productRepo domain.ProductRepository) RollbackProductInventoryHandler

type UpdateProductDetail

type UpdateProductDetail struct {
	ProductID   uint64
	Name        string
	BrandName   string
	Description string
	Price       uint64
}

type UpdateProductDetailHandler

type UpdateProductDetailHandler CommandHandler[UpdateProductDetail]

func NewUpdateProductDetailHandler

func NewUpdateProductDetailHandler(logger logger.Logger, productRepo domain.ProductRepository) UpdateProductDetailHandler

type UpdateProductInventory

type UpdateProductInventory struct {
	IdempotencyKey    uint64
	PurchasedProducts *[]PurchasedProduct
}

type UpdateProductInventoryHandler

type UpdateProductInventoryHandler CommandHandler[UpdateProductInventory]

func NewUpdateProductInventoryHandler

func NewUpdateProductInventoryHandler(logger logger.Logger, productRepo domain.ProductRepository) UpdateProductInventoryHandler