mqtt

Documentation

Index

• type DebugLogger
  • func (DebugLogger) Printf(format string, v ...interface{})
  • func (DebugLogger) Println(v ...interface{})
• type ServiceMQTT
  • func (p *ServiceMQTT) Collect(pipeline.Collector) error
  • func (p *ServiceMQTT) Description() string
  • func (p *ServiceMQTT) Init(context pipeline.Context) (int, error)
  • func (p *ServiceMQTT) Start(c pipeline.Collector) error
  • func (p *ServiceMQTT) Stop() error

Types

type DebugLogger

type DebugLogger struct {
}

func (DebugLogger) Printf

func (DebugLogger) Printf(format string, v ...interface{})

func (DebugLogger) Println

func (DebugLogger) Println(v ...interface{})

type ServiceMQTT

type ServiceMQTT struct {
	Server          string
	Topics          []string
	QoS             int
	ClientID        string
	Username        string
	Password        string
	SSLCA           string // Path to CA file
	SSLCert         string // Path to host cert file
	SSLKey          string // Path to cert key file
	RetryMin        int
	RetryRatio      float64
	RetryMax        int
	CleanSession    bool
	OrderMatters    bool
	ClientIDAutoInc bool
	KeepAlive       int
	Version         int // 3 - MQTT 3.1 or 4 - MQTT 3.1.1
	// contains filtered or unexported fields
}

ServiceMQTT ...

func (*ServiceMQTT) Collect

func (p *ServiceMQTT) Collect(pipeline.Collector) error

Collect takes in an accumulator and adds the metrics that the Input gathers. This is called every "interval"

func (*ServiceMQTT) Description

func (p *ServiceMQTT) Description() string

func (*ServiceMQTT) Init

func (p *ServiceMQTT) Init(context pipeline.Context) (int, error)

func (*ServiceMQTT) Start

func (p *ServiceMQTT) Start(c pipeline.Collector) error

Start starts the ServiceInput's service, whatever that may be

func (*ServiceMQTT) Stop

func (p *ServiceMQTT) Stop() error

Stop stops the services and closes any necessary channels and connections