workq

Documentation

Index

• Variables
• func Initialize(config configs.Configuration) error
• type Message

Variables

var ProducerClient definition.WorkQueueProducer

ProducerClient ...

var TopicHandlers = make(map[enums.Daemon]definition.Consumer)

Functions

func Initialize

func Initialize(config configs.Configuration) error

Initialize ...

Types

type Message

type Message struct {
	Topic   string
	Payload []byte
}

Message ...