mqtt

Documentation

Index

• Constants
• type Params
• type Publisher
  • func NewPublisher(params []byte) (*Publisher, error)
  • func (m *Publisher) Connect() error
  • func (m *Publisher) Disconnect()
  • func (p *Publisher) Publish(b []byte)
• type Subscriber
  • func NewSubscriber(params []byte) (*Subscriber, error)
  • func (m *Subscriber) Connect() error
  • func (m *Subscriber) Disconnect()
  • func (s *Subscriber) Subscribe(events chan<- []byte) error

Constants

const MQTT = "mqtt"

Types

type Params

type Params struct {
	Broker        string `json:"broker"`
	User          string `json:"user"`
	Password      string `json:"password"`
	Topic         string `json:"topic"`
	AutoReconnect bool   `json:"autoReconnect"`
	KeepAlive     bool   `json:"keepAlive"`
}

type Publisher

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

func NewPublisher

func NewPublisher(params []byte) (*Publisher, error)

func (*Publisher) Connect

func (m *Publisher) Connect() error

func (*Publisher) Disconnect

func (m *Publisher) Disconnect()

func (*Publisher) Publish

func (p *Publisher) Publish(b []byte)

type Subscriber

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

func NewSubscriber

func NewSubscriber(params []byte) (*Subscriber, error)

func (*Subscriber) Connect

func (m *Subscriber) Connect() error

func (*Subscriber) Disconnect

func (m *Subscriber) Disconnect()

func (*Subscriber) Subscribe

func (s *Subscriber) Subscribe(events chan<- []byte) error