bus

Jul 7, 2016

Changes in this version

type Connection

+ Disconnect func() error

type ConnectionOptions

+ AutoReconnect bool

type MQTTConnection

+ func (mqc *MQTTConnection) Disconnect() error

Jun 1, 2016

Changes in this version

+ type Backoff struct

+ func NewBackoff() *Backoff

+ func (b *Backoff) Reset()

+ func (b *Backoff) Wait()

+ type Connection interface

+ Connect func(options ConnectionOptions) error

+ Publish func(topic string, payload []byte) error

+ Subscribe func(topic string, handler SubscriptionHandler) error

+ type ConnectionOptions struct

+ EventsHandler EventHandler

+ Host string

+ OnDisconnect *DisconnectMessage

+ Password string

+ Port int

+ SSLCertPath string

+ SSLEnabled bool

+ Userid string

+ type DisconnectMessage struct

+ Body string

+ Topic string

+ type Event int

+ const ConnectedEvent

+ type EventHandler func(conn Connection, event Event)

+ type MQTTConnection struct

+ func (mqc *MQTTConnection) Connect(options ConnectionOptions) error

+ func (mqc *MQTTConnection) Publish(topic string, payload []byte) error

+ func (mqc *MQTTConnection) Subscribe(topic string, handler SubscriptionHandler) error

+ type MessagePublisher interface

+ Publish func(topic string, message []byte) error

+ type SubscriptionHandler func(conn Connection, topic string, message []byte)

Apr 22, 2016

Changes in this version

+ const CommandTopicTemplate

+ const ExecuteTopicTemplate

+ const RelayDiscoveryTopic

+ type DisconnectCallback func(error)

+ type Handlers struct

+ CommandHandler MessageCallback

+ DisconnectHandler DisconnectCallback

+ ExecutionHandler MessageCallback

+ type Link struct

+ func (link *Link) DirectiveReplyTo() string

+ func (link *Link) Halt()

+ func (link *Link) Publish(topic string, payload []byte) error

+ func (link *Link) Run() error

+ type MessageBus interface

+ DirectiveReplyTo func() string

+ Halt func()

+ Publish func(topic string, payload []byte) error

+ Run func() error

+ func NewLink(id string, cogConfig *config.CogInfo, handlers Handlers, wg sync.WaitGroup) (MessageBus, error)

+ type MessageCallback func(bus MessageBus, topic string, payload []byte)