mqtt

Documentation

Index

• Constants
• func ClientId() string
• type Collector
  • func NewCollector() (*Collector, error)
  • func (c *Collector) Collect() <-chan shared.Message
  • func (c *Collector) Shutdown()

Constants

const (
	ClientName = "MQTT_NAME"
	Url        = "MQTT_URL"
	Username   = "MQTT_USERNAME"
	Password   = "MQTT_PASSWORD"
)

Functions

func ClientId

func ClientId() string

Types

type Collector

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

func NewCollector

func NewCollector() (*Collector, error)

func (*Collector) Collect

func (c *Collector) Collect() <-chan shared.Message

func (*Collector) Shutdown

func (c *Collector) Shutdown()