nats

May 10, 2017

Changes in this version

+ type Message *nats.Msg

Feb 16, 2017

Changes in this version

+ const Data

+ const Error

+ type Driver struct

+ func NewDriver(a *Adaptor, topic string) *Driver

+ func (m *Driver) Connection() gobot.Connection

+ func (m *Driver) Halt() error

+ func (m *Driver) Name() string

+ func (m *Driver) On(n string, f func(d interface{})) error

+ func (m *Driver) Publish(data interface{}) bool

+ func (m *Driver) SetName(name string)

+ func (m *Driver) SetTopic(topic string)

+ func (m *Driver) Start() error

+ func (m *Driver) Topic() string

Dec 21, 2016

Changes in this version

+ type Adaptor struct

+ Host string

+ func NewAdaptor(host string, clientID int) *Adaptor

+ func NewAdaptorWithAuth(host string, clientID int, username string, password string) *Adaptor

+ func (a *Adaptor) Connect() (err error)

+ func (a *Adaptor) Disconnect() (err error)

+ func (a *Adaptor) Finalize() (err error)

+ func (a *Adaptor) Name() string

+ func (a *Adaptor) On(event string, f func(s []byte)) bool

+ func (a *Adaptor) Publish(topic string, message []byte) bool

+ func (a *Adaptor) SetName(n string)

Oct 10, 2016

Changes in this version

+ type NatsAdaptor struct

+ Host string

+ func NewNatsAdaptor(name string, host string, clientID int) *NatsAdaptor

+ func NewNatsAdaptorWithAuth(name string, host string, clientID int, username string, password string) *NatsAdaptor

+ func (a *NatsAdaptor) Connect() (errs []error)

+ func (a *NatsAdaptor) Disconnect() (err error)

+ func (a *NatsAdaptor) Finalize() (errs []error)

+ func (a *NatsAdaptor) Name() string

+ func (a *NatsAdaptor) On(event string, f func(s []byte)) bool

+ func (a *NatsAdaptor) Publish(topic string, message []byte) bool