Documentation ¶
Overview ¶
Package notification service communication module. Communication takes place via rabbit.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Connect ¶
func Connect(cfg Config) (*amqp.Connection, error)
Connect creates a connection to rabbit. IMPORTANT: does not declare a queue or anything else, the calling code must do so.
func New ¶
func New(ch channel, opt ...Option) app.Notification
New creates a new instance of the app.NotificationTask object. Accepts the parameter interface type object, which is basically implemented *amqp.Channel. Accepts the interface for convenient testing.
Types ¶
type Option ¶
type Option func(*client)
Option for building rabbit client.
func GeneratorID ¶
GeneratorID set options for connect rabbit.
Click to show internal directories.
Click to hide internal directories.