mqtt

Documentation

Index

• Variables
• func New(options ...BusOption) (casa.MessageBus, error)
• type Bus
  • func (b *Bus) Close() error
  • func (b *Bus) NewClient() casa.MessageClient
• type BusOption
  • func BrokerLogger(logger broker.Logger) BusOption
  • func ListenOn(urls ...string) BusOption
  • func TLS(cert tls.Certificate) BusOption
  • func Users(users map[string]string) BusOption
• type Client
  • func NewClient(url string, options ...ClientOption) (*Client, error)
  • func (c *Client) Close() error
  • func (c *Client) Handle(f func(msg *casa.Message, err error))
  • func (c *Client) PublishMessage(message casa.Message) error
  • func (c *Client) Subscribe(topic string) error
  • func (c *Client) Unsubscribe(topic string) error
• type ClientOption
  • func CleanSession(clean bool) ClientOption
  • func ClientID(id string) ClientOption
  • func ClientLogger(logger client.Logger) ClientOption
  • func KeepAlive(duration time.Duration) ClientOption
  • func Timeout(timeout time.Duration) ClientOption
  • func ValidateSubs(validate bool) ClientOption
  • func Will(message *casa.Message) ClientOption

Variables

var (
	ErrInvalidTopic = errors.New("Topic invalid for publishing")
	ErrInvalidSub   = errors.New("Topic invalid for subscribing")
)

var DefaultBackend = broker.NewMemoryBackend()

var (
	ErrNoURL = errors.New("No URL specified to listen on")
)

Functions

func New

func New(options ...BusOption) (casa.MessageBus, error)

Initialize a new Bus

Types

type Bus

type Bus struct {
	// contains filtered or unexported fields
}

func (*Bus) Close

func (b *Bus) Close() error

func (*Bus) NewClient

func (b *Bus) NewClient() casa.MessageClient

type BusOption

type BusOption func(*Bus) error

func BrokerLogger

func BrokerLogger(logger broker.Logger) BusOption

func ListenOn

func ListenOn(urls ...string) BusOption

func TLS

func TLS(cert tls.Certificate) BusOption

func Users

func Users(users map[string]string) BusOption

type Client

type Client struct {
	// contains filtered or unexported fields
}

func NewClient

func NewClient(url string, options ...ClientOption) (*Client, error)

func (*Client) Close

func (c *Client) Close() error

func (*Client) Handle

func (c *Client) Handle(f func(msg *casa.Message, err error))

func (*Client) PublishMessage

func (c *Client) PublishMessage(message casa.Message) error

func (*Client) Subscribe

func (c *Client) Subscribe(topic string) error

func (*Client) Unsubscribe

func (c *Client) Unsubscribe(topic string) error

type ClientOption

type ClientOption func(*Client) error

func CleanSession

func CleanSession(clean bool) ClientOption

func ClientID

func ClientID(id string) ClientOption

func ClientLogger

func ClientLogger(logger client.Logger) ClientOption

func KeepAlive

func KeepAlive(duration time.Duration) ClientOption

func Timeout

func Timeout(timeout time.Duration) ClientOption

func ValidateSubs

func ValidateSubs(validate bool) ClientOption

func Will

func Will(message *casa.Message) ClientOption