network

Documentation

Index

• Constants
• type ConnectionStatus
• type Message
  • func (m *Message) Id() uint16
  • func (m *Message) Payload() []byte
  • func (m *Message) Qos() Qos
  • func (m *Message) Retained() bool
  • func (m *Message) Topic() string
• type MqttClient
  • func NewMqttClient() *MqttClient
  • func (c *MqttClient) Close() error
  • func (c *MqttClient) Connect(host string, port int, username, password string, onCompletion func(error))
  • func (c *MqttClient) Incoming() <-chan *Message
  • func (c *MqttClient) IsConnected() bool
  • func (c *MqttClient) Publish(topic string, qos Qos, retained bool, message []byte, onCompletion func(error))
  • func (c *MqttClient) SetConnectionStatusFunc(f func(ConnectionStatus))
  • func (c *MqttClient) Subscribe(topic string, qos Qos, onCompletion func(error))
  • func (c *MqttClient) Unsubscribe(topic string, onCompletion func(error))
• type Qos

Constants

const (
	StatusConnected = iota
	StatusDisconnected
	StatusReconnecting
)

Types

type ConnectionStatus

type ConnectionStatus int

type Message

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

func (*Message) Id

func (m *Message) Id() uint16

func (*Message) Payload

func (m *Message) Payload() []byte

func (*Message) Qos

func (m *Message) Qos() Qos

func (*Message) Retained

func (m *Message) Retained() bool

func (*Message) Topic

func (m *Message) Topic() string

type MqttClient

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

func NewMqttClient

func NewMqttClient() *MqttClient

func (*MqttClient) Close

func (c *MqttClient) Close() error

func (*MqttClient) Connect

func (c *MqttClient) Connect(host string, port int, username, password string, onCompletion func(error))

func (*MqttClient) Incoming

func (c *MqttClient) Incoming() <-chan *Message

func (*MqttClient) IsConnected

func (c *MqttClient) IsConnected() bool

func (*MqttClient) Publish

func (c *MqttClient) Publish(topic string, qos Qos, retained bool, message []byte, onCompletion func(error))

func (*MqttClient) SetConnectionStatusFunc

func (c *MqttClient) SetConnectionStatusFunc(f func(ConnectionStatus))

func (*MqttClient) Subscribe

func (c *MqttClient) Subscribe(topic string, qos Qos, onCompletion func(error))

func (*MqttClient) Unsubscribe

func (c *MqttClient) Unsubscribe(topic string, onCompletion func(error))

type Qos

type Qos byte

const (
	QosAtMostOnce Qos = iota
	QosAtLeastOnce
	QosExatlyOnce
)