mqtt

Documentation

Index

• Constants
• Variables
• func Connect(id, addr string, options ...interface{}) (pubsub.PubSub, error)
• type Client
  • func (this *Client) Close()
  • func (this *Client) Publish(topic pubsub.Topic, message []byte) error
  • func (this *Client) Subscribe(topic pubsub.Topic) (<-chan []byte, error)

Constants

const (
	QOS_ZERO = 0 //MQTT.QoS = MQTT.QOS_ZERO
	QOS_ONE  = 1 //MQTT.QoS = MQTT.QOS_ONE
	QOS_TWO  = 2 //MQTT.QoS = MQTT.QOS_TWO
)

Variables

var (
	ErrNotSupportedProtocol = errors.New("not-supported-protocol")
	ErrConnect              = errors.New("error-connect")
)

Functions

func Connect

func Connect(id, addr string, options ...interface{}) (pubsub.PubSub, error)

Types

type Client

type Client struct {
	BrokerAddr       string        `json:"broker_addr"`
	ClientId         string        `json:"client_id"`
	QoS              byte          `json:"qos"` //MQTT.QoS
	PublishTimeout   time.Duration `json:"publish_timeout"`
	SubscribeTimeout time.Duration `json:"subscribe_timeout"`
	// contains filtered or unexported fields
}

func (*Client) Close

func (this *Client) Close()

func (*Client) Publish

func (this *Client) Publish(topic pubsub.Topic, message []byte) error

func (*Client) Subscribe

func (this *Client) Subscribe(topic pubsub.Topic) (<-chan []byte, error)