Directories ¶
Path | Synopsis |
---|---|
Package amqp holds code required for reading messages from RabbitMQ.
|
Package amqp holds code required for reading messages from RabbitMQ. |
Package config holds structs and routines for loading application and pipes configuration.
|
Package config holds structs and routines for loading application and pipes configuration. |
Package producer holds interface for publishing messages to required destinations and implementation for sending messages to Kafka.
|
Package producer holds interface for publishing messages to required destinations and implementation for sending messages to Kafka. |
Package storage holds interface and Redis implementation for messages storage in case producer is not currently available.
|
Package storage holds interface and Redis implementation for messages storage in case producer is not currently available. |
Package workers holds the main application logic worker, that listens to read messages and sends then to producer.
|
Package workers holds the main application logic worker, that listens to read messages and sends then to producer. |
Click to show internal directories.
Click to hide internal directories.