beater

package

v0.0.0-...-66ef0f3 Latest Latest Go to latest Published: Feb 11, 2020 License: Apache-2.0 Imports: 12 Imported by: 1

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

func DecodePayload(payload []byte) common.MapStr

DecodePayload will try to decode the payload. If every check fails, it will return the payload as a string

func New(b *beat.Beat, cfg *common.Config) (beat.Beater, error)

New function creates our mqtt beater

func ParseTopics(topics []string) map[string]byte

ParseTopics will parse the config file and return a map with topic:QoS

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

Mqttbeat represent a mqtt beat object

func (bt *Mqttbeat) Run(b *beat.Beat) error

Run is used to start this beater, once configured and connected

func (bt *Mqttbeat) Stop()

Stop is used to close this beater