mqtt

package
v0.2.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 16, 2015 License: MIT Imports: 11 Imported by: 0

Documentation

Index

Constants

View Source
const ClientIdPrefix = "telegraf"
View Source
const MaxClientIdLen = 8
View Source
const MaxRetryCount = 3

Variables

This section is empty.

Functions

This section is empty.

Types

type MQTT

type MQTT struct {
	Servers     []string `toml:"servers"`
	Username    string
	Password    string
	Database    string
	Timeout     internal.Duration
	TopicPrefix string

	Client *paho.Client
	Opts   *paho.ClientOptions
	sync.Mutex
}

func (*MQTT) Close

func (m *MQTT) Close() error

func (*MQTT) Connect

func (m *MQTT) Connect() error

func (*MQTT) CreateOpts

func (m *MQTT) CreateOpts() (*paho.ClientOptions, error)

func (*MQTT) Description

func (m *MQTT) Description() string

func (*MQTT) SampleConfig

func (m *MQTT) SampleConfig() string

func (*MQTT) Write

func (m *MQTT) Write(points []*client.Point) error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL