consumer

Documentation

Index

• type InventoryConsumer
  • func NewInventoryConsumer(ch *amqp.Channel, stocksModel model.StocksModel, ...) *InventoryConsumer
  • func (c *InventoryConsumer) Start(ctx context.Context) error
  • func (c *InventoryConsumer) Stop() error

Types

type InventoryConsumer

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

func NewInventoryConsumer

func NewInventoryConsumer(
	ch *amqp.Channel,
	stocksModel model.StocksModel,
	stockLocksModel model.StockLocksModel,
	stockRecordsModel model.StockRecordsModel,
) *InventoryConsumer

func (*InventoryConsumer) Start

func (c *InventoryConsumer) Start(ctx context.Context) error

func (*InventoryConsumer) Stop

func (c *InventoryConsumer) Stop() error