broker

Documentation

Overview

Package broker contains logic for processing message brokers logic

Index

• type MessageConsumer
  • func NewKafkaMessageConsumer(r *kafka.Reader, messageRps repository.MessageRepository) MessageConsumer

Types

type MessageConsumer

type MessageConsumer interface {
	Consume(context.Context) error
}

MessageConsumer represents behavior of Message data consumer

func NewKafkaMessageConsumer

func NewKafkaMessageConsumer(r *kafka.Reader, messageRps repository.MessageRepository) MessageConsumer

NewKafkaMessageConsumer builds kafka Message consumer