application

Documentation

Index

• type CatcherService
  • func NewCatcherService(udpReceiver *adapters.UDPReceiver, kafkaWriter *adapters.KafkaWriter, ...) *CatcherService
  • func (c *CatcherService) ReceiveAndPublishMessages() error

Types

type CatcherService

type CatcherService struct {
	UDPReceiver    *adapters.UDPReceiver
	KafkaWriter    *adapters.KafkaWriter
	HashCalculator ports.MessageHashCalculator
	Cfg            config.Queue
	EnableHash     bool
}

func NewCatcherService

func NewCatcherService(udpReceiver *adapters.UDPReceiver, kafkaWriter *adapters.KafkaWriter,
	calculator ports.MessageHashCalculator, cfg config.Queue, enableHash bool) *CatcherService

func (*CatcherService) ReceiveAndPublishMessages

func (c *CatcherService) ReceiveAndPublishMessages() error