retranslator

Documentation

Overview

Package retranslator get events from database (consumer) and send to kafka (producer)

Index

• type Config
• type Retranslator
  • func NewRetranslator(cfg Config) Retranslator

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 считывает события из БД и отправляет в кафку

func NewRetranslator

func NewRetranslator(cfg Config) Retranslator

NewRetranslator конструктор