msgbus

package

v0.0.0-...-4b2168a Latest Latest Go to latest Published: Jul 29, 2024 License: MIT Imports: 7 Imported by: 0

Details

Модуль msgbus реализует типы и методы для работы с шиной сообщений - Kafka

View Source

const (
	WriterAsync           = true //Не блокирующая запись
	WriterAutoTopicCreate = true //Авто создание топика
)

This section is empty.

This section is empty.

type KafkaBus struct {
	Reader  *kafka.Reader
	Writer  *kafka.Writer
	Metrics metric.Metrics
}

KafkaBus реализует шину сообщений на Kafka

func NewKfkBus(appConf config.Config, logger *log.Logger, metrics *metric.Metrics) *KafkaBus

NewKfkBus правильно инициализирует kafka reader/writer

func (kb *KafkaBus) Consume(ctx context.Context, stor types.Repository)

Consume реализует интерфейс MsgConsumer для непрерывного чтения сообщений из шины

func (kb *KafkaBus) Read(ctx context.Context) types.Message

Read реализует чтение сообщения из топика по текущему offset

func (kb *KafkaBus) Write(ctx context.Context, msg types.Message)

Write реализует запись сообщения в kafka topic