kafka

Documentation

Index

• type OrderEndedConsumer
  • func NewOrderEndedConsumer(logger *slog.Logger, service *service.OrderHistory, config *config.Kafka) *OrderEndedConsumer
  • func (consumer *OrderEndedConsumer) Consume(ctx context.Context) error

Types

type OrderEndedConsumer

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

func NewOrderEndedConsumer

func NewOrderEndedConsumer(
	logger *slog.Logger,
	service *service.OrderHistory,
	config *config.Kafka,
) *OrderEndedConsumer

func (*OrderEndedConsumer) Consume

func (consumer *OrderEndedConsumer) Consume(ctx context.Context) error