client

Documentation

Index

• type Client
  • func NewHTTPClient(ctx context.Context, cfg *mqtt.ClientConfig) (Client, error)
  • func NewMqttClient(cfg *mqtt.ClientConfig) (Client, error)
• type HTTPClient
  • func (h *HTTPClient) Close() error
  • func (h *HTTPClient) ResetClient(cfg *mqtt.ClientConfig)
  • func (h *HTTPClient) SendOrDrop(method string, pkt *mqtt.Publish) error
  • func (h *HTTPClient) SendPubAck(pkt mqtt.Packet) error
  • func (h *HTTPClient) SetReconnectCallback(callback mqtt.ReconnectCallback)
  • func (h *HTTPClient) Start(obs mqtt.Observer)
• type MqttClient
  • func (m *MqttClient) Close() error
  • func (m *MqttClient) ResetClient(cfg *mqtt.ClientConfig)
  • func (m *MqttClient) SendOrDrop(method string, pkt *mqtt.Publish) error
  • func (m *MqttClient) SendPubAck(pkt mqtt.Packet) error
  • func (m *MqttClient) SetReconnectCallback(callback mqtt.ReconnectCallback)
  • func (m *MqttClient) Start(obs mqtt.Observer)

Types

type Client

type Client interface {
	SendOrDrop(method string, pkt *mqtt.Publish) error
	SendPubAck(pkt mqtt.Packet) error
	Start(obs mqtt.Observer)
	ResetClient(cfg *mqtt.ClientConfig)
	SetReconnectCallback(callback mqtt.ReconnectCallback)
	io.Closer
}

func NewHTTPClient

func NewHTTPClient(ctx context.Context, cfg *mqtt.ClientConfig) (Client, error)

func NewMqttClient

func NewMqttClient(cfg *mqtt.ClientConfig) (Client, error)

type HTTPClient

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

func (*HTTPClient) Close

func (h *HTTPClient) Close() error

Close closes client

func (*HTTPClient) ResetClient

func (h *HTTPClient) ResetClient(cfg *mqtt.ClientConfig)

func (*HTTPClient) SendOrDrop

func (h *HTTPClient) SendOrDrop(method string, pkt *mqtt.Publish) error

func (*HTTPClient) SendPubAck

func (h *HTTPClient) SendPubAck(pkt mqtt.Packet) error

func (*HTTPClient) SetReconnectCallback

func (h *HTTPClient) SetReconnectCallback(callback mqtt.ReconnectCallback)

func (*HTTPClient) Start

func (h *HTTPClient) Start(obs mqtt.Observer)

type MqttClient

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

func (*MqttClient) Close

func (m *MqttClient) Close() error

func (*MqttClient) ResetClient

func (m *MqttClient) ResetClient(cfg *mqtt.ClientConfig)

func (*MqttClient) SendOrDrop

func (m *MqttClient) SendOrDrop(method string, pkt *mqtt.Publish) error

func (*MqttClient) SendPubAck

func (m *MqttClient) SendPubAck(pkt mqtt.Packet) error

func (*MqttClient) SetReconnectCallback

func (m *MqttClient) SetReconnectCallback(callback mqtt.ReconnectCallback)

func (*MqttClient) Start

func (m *MqttClient) Start(obs mqtt.Observer)