mqtt

package
v0.58.3 Latest Latest
Warning

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

Go to latest
Published: Jan 7, 2020 License: MIT Imports: 17 Imported by: 1

Documentation

Index

Constants

View Source
const (
	ToMQTTKind           = "toMQTT"
	DefaultToMQTTTimeout = 1 * time.Second
)

Variables

View Source
var DefaultToMQTTUserAgent = "fluxd/dev"

DefaultToMQTTUserAgent is the default user agent used by ToMqtt

Functions

This section is empty.

Types

type ToMQTTOpSpec

type ToMQTTOpSpec struct {
	Broker       string        `json:"broker"`
	Name         string        `json:"name"`
	Topic        string        `json:"topic"`
	Message      string        `json:"message"`
	ClientID     string        `json:"clientid"`
	Username     string        `json:"username"`
	Password     string        `json:"password"`
	QoS          int           `json:"qos"`
	NameColumn   string        `json:"nameColumn"` // either name or name_column must be set, if none is set try to use the "_measurement" column.
	Timeout      time.Duration `json:"timeout"`    // default to something reasonable if zero
	NoKeepAlive  bool          `json:"noKeepAlive"`
	TimeColumn   string        `json:"timeColumn"`
	TagColumns   []string      `json:"tagColumns"`
	ValueColumns []string      `json:"valueColumns"`
}

func (ToMQTTOpSpec) Kind

func (*ToMQTTOpSpec) ReadArgs

func (o *ToMQTTOpSpec) ReadArgs(args flux.Arguments) error

ReadArgs loads a flux.Arguments into ToMQTTOpSpec. It sets several default values. If the time_column isn't set, it defaults to execute.TimeColLabel. If the value_column isn't set it defaults to a []string{execute.DefaultValueColLabel}.

func (*ToMQTTOpSpec) UnmarshalJSON

func (o *ToMQTTOpSpec) UnmarshalJSON(b []byte) (err error)

UnmarshalJSON unmarshals and validates toMQTTOpSpec into JSON.

type ToMQTTProcedureSpec

type ToMQTTProcedureSpec struct {
	plan.DefaultCost
	Spec *ToMQTTOpSpec
}

func (*ToMQTTProcedureSpec) Copy

func (*ToMQTTProcedureSpec) Kind

type ToMQTTTransformation

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

func (*ToMQTTTransformation) Finish

func (t *ToMQTTTransformation) Finish(id execute.DatasetID, err error)

func (*ToMQTTTransformation) Process

func (t *ToMQTTTransformation) Process(id execute.DatasetID, tbl flux.Table) error

func (*ToMQTTTransformation) RetractTable

func (t *ToMQTTTransformation) RetractTable(id execute.DatasetID, key flux.GroupKey) error

func (*ToMQTTTransformation) UpdateProcessingTime

func (t *ToMQTTTransformation) UpdateProcessingTime(id execute.DatasetID, pt execute.Time) error

func (*ToMQTTTransformation) UpdateWatermark

func (t *ToMQTTTransformation) UpdateWatermark(id execute.DatasetID, pt execute.Time) error

Jump to

Keyboard shortcuts

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