events

Documentation

Index

• func NewOrdersEventsConsumer(cfg KafkaReaderConfig, logger *logrus.Logger, service service.MailService) *ordersEventsConsumer
• func NewTokensDeliveryRequestsConsumer(cfg KafkaReaderConfig, logger *logrus.Logger, service service.MailService) *tokensDeliveryRequests
• type KafkaReaderConfig

Functions

func NewOrdersEventsConsumer

func NewOrdersEventsConsumer(
	cfg KafkaReaderConfig,
	logger *logrus.Logger,
	service service.MailService) *ordersEventsConsumer

func NewTokensDeliveryRequestsConsumer

func NewTokensDeliveryRequestsConsumer(
	cfg KafkaReaderConfig,
	logger *logrus.Logger,
	service service.MailService) *tokensDeliveryRequests

Types

type KafkaReaderConfig

type KafkaReaderConfig struct {
	Brokers          []string
	GroupID          string
	ReadBatchTimeout time.Duration
}