retranslator

Documentation

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   int

	Repo   repo.EventRepo
	Sender sender.EventSender
}

type Retranslator

type Retranslator interface {
	Start()
	Close()
}

func NewRetranslator

func NewRetranslator(cfg Config) Retranslator