service

Documentation

Index

• type InventoryService
  • func NewInventoryService(repo repository.InventoryRepository, rc *events.RabbitClient, ...) (*InventoryService, error)
  • func (s *InventoryService) CheckAvailability(ctx context.Context, productID int, quantity uint) (bool, error)
  • func (s *InventoryService) CreateInventoryItem(ctx context.Context, productID int, quantity int) (*model.InventoryItem, error)
  • func (s *InventoryService) DecrementInventory(ctx context.Context, productID int, quantity uint) error
  • func (s *InventoryService) GetInventoryByProductID(ctx context.Context, productID int) (*model.InventoryItem, error)
  • func (s *InventoryService) IncrementInventory(ctx context.Context, productID int, quantity uint) error
  • func (s *InventoryService) Listen(ctx context.Context, topic events.Topic, key events.RoutingKey) error
  • func (s *InventoryService) Publish(ctx context.Context, topic events.Topic, key events.RoutingKey, ...) error

Types

type InventoryService

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

func NewInventoryService

func NewInventoryService(repo repository.InventoryRepository, rc *events.RabbitClient, l *zerolog.Logger) (*InventoryService, error)

func (*InventoryService) CheckAvailability

func (s *InventoryService) CheckAvailability(ctx context.Context, productID int, quantity uint) (bool, error)

func (*InventoryService) CreateInventoryItem

func (s *InventoryService) CreateInventoryItem(ctx context.Context, productID int, quantity int) (*model.InventoryItem, error)

func (*InventoryService) DecrementInventory

func (s *InventoryService) DecrementInventory(ctx context.Context, productID int, quantity uint) error

func (*InventoryService) GetInventoryByProductID

func (s *InventoryService) GetInventoryByProductID(ctx context.Context, productID int) (*model.InventoryItem, error)

func (*InventoryService) IncrementInventory

func (s *InventoryService) IncrementInventory(ctx context.Context, productID int, quantity uint) error

func (*InventoryService) Listen

func (s *InventoryService) Listen(ctx context.Context, topic events.Topic, key events.RoutingKey) error

func (*InventoryService) Publish

func (s *InventoryService) Publish(ctx context.Context, topic events.Topic, key events.RoutingKey, e events.EventData) error