events

Documentation

Index

• Constants
• func PublishToRedis(rds redisKind, cartItemID, productID string)
• type EventListener
  • func (l *EventListener) ListenCartItemDataPopulationMessages()
  • func (l *EventListener) ListenFlushCartEvents()

Constants

const (
	// FlushCartChannelName stores redis channel name for flush cart items.
	FlushCartChannelName = "FLUSH_CART_CHANNEL"

	// CartItemPopulatedChannelName is channel name for data populated from products service.
	CartItemPopulatedChannelName = "CART_ITEM_POPULATED"
)

const (
	// PopulateCartItemChannelName channel name for cart item product info population requests.
	PopulateCartItemChannelName = "POPULATE_CART_ITEM"
)

Functions

func PublishToRedis

func PublishToRedis(rds redisKind, cartItemID, productID string)

PublishToRedis publishes product data need to populate message to Redis pub/sub.

Types

type EventListener

type EventListener struct {
	FlushCartMessageChan     <-chan *redis.Message
	ProductInfoPopulatedChan <-chan *redis.Message
	Repository               database.Repository
}

EventListener is a struct which contains flush cart and product data populated messages channels.

func (*EventListener) ListenCartItemDataPopulationMessages

func (l *EventListener) ListenCartItemDataPopulationMessages()

ListenCartItemDataPopulationMessages listens messages from product data populated channel. Updates cart item with populated product data.

func (*EventListener) ListenFlushCartEvents

func (l *EventListener) ListenFlushCartEvents()

ListenFlushCartEvents listens messages from given channel and if payload matches flushes cart content.