Documentation
¶
Overview ¶
Package retranslator get events from database (consumer) and send to kafka (producer)
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct {
ChannelSize uint64
ConsumerCount uint64
ConsumeSize uint64
ConsumeTimeout time.Duration
ProducerCount uint64
WorkerCount uint64
Repo repo.EventRepo
Sender sender.EventSender
}
Config конфигурация Retranslator
type Retranslator ¶
type Retranslator interface {
Start()
Stop()
}
Retranslator считывает события из БД и отправляет в кафку
Click to show internal directories.
Click to hide internal directories.