Documentation ¶
Index ¶
- Constants
- Variables
- type ToMQTTOpSpec
- type ToMQTTProcedureSpec
- type ToMQTTTransformation
- func (t *ToMQTTTransformation) Finish(id execute.DatasetID, err error)
- func (t *ToMQTTTransformation) Process(id execute.DatasetID, tbl flux.Table) error
- func (t *ToMQTTTransformation) RetractTable(id execute.DatasetID, key flux.GroupKey) error
- func (t *ToMQTTTransformation) UpdateProcessingTime(id execute.DatasetID, pt execute.Time) error
- func (t *ToMQTTTransformation) UpdateWatermark(id execute.DatasetID, pt execute.Time) error
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) Kind() flux.OperationKind
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 (o *ToMQTTProcedureSpec) Copy() plan.ProcedureSpec
func (*ToMQTTProcedureSpec) Kind ¶
func (o *ToMQTTProcedureSpec) Kind() plan.ProcedureKind
type ToMQTTTransformation ¶
type ToMQTTTransformation struct { execute.ExecutionNode // contains filtered or unexported fields }
func NewToMQTTTransformation ¶
func NewToMQTTTransformation(d execute.Dataset, cache execute.TableBuilderCache, spec *ToMQTTProcedureSpec) *ToMQTTTransformation
func (*ToMQTTTransformation) Finish ¶
func (t *ToMQTTTransformation) Finish(id execute.DatasetID, err error)
func (*ToMQTTTransformation) RetractTable ¶
func (*ToMQTTTransformation) UpdateProcessingTime ¶
func (*ToMQTTTransformation) UpdateWatermark ¶
Click to show internal directories.
Click to hide internal directories.