events

Documentation

Index

• func NewOrdersEvents(cfg KafkaConfig, logger *logrus.Logger) *ordersEvents
• type KafkaConfig
• type OrdersEventsMQ

Functions

func NewOrdersEvents

func NewOrdersEvents(cfg KafkaConfig, logger *logrus.Logger) *ordersEvents

Types

type KafkaConfig

type KafkaConfig struct {
	Brokers []string
}

type OrdersEventsMQ

type OrdersEventsMQ interface {
	OrderCreated(ctx context.Context, email string, order models.Order) error
}