Versions in this module Expand all Collapse all v0 v0.1.0 Mar 20, 2017 Changes in this version + type DefaultMessageProducer struct + func (p *DefaultMessageProducer) ConnectivityCheck() (string, error) + func (p *DefaultMessageProducer) SendMessage(uuid string, message Message) (err error) + func (p *DefaultMessageProducer) SendRawMessage(uuid string, message string) (err error) + type Message struct + Body string + Headers map[string]string + type MessageProducer interface + ConnectivityCheck func() (string, error) + SendMessage func(string, Message) error + func NewMessageProducer(config MessageProducerConfig) MessageProducer + func NewMessageProducerWithHTTPClient(config MessageProducerConfig, httpClient *http.Client) MessageProducer + type MessageProducerConfig struct + Addr string + Authorization string + Queue string + Topic string + type MessageRecord struct + Key string + Value string + type MessageWithRecords struct + Records []MessageRecord v0.1.0-rc.1 Feb 21, 2017