pipeline

Documentation

Index

• type Pipeline
  • func New(log *util.Logger, cc Settings) (*Pipeline, error)
  • func (p *Pipeline) Process(in []byte) ([]byte, error)
  • func (p *Pipeline) WithDecode(decode string) (*Pipeline, error)
  • func (p *Pipeline) WithJq(jq string) (*Pipeline, error)
  • func (p *Pipeline) WithRegex(regex, dflt string) (*Pipeline, error)
  • func (p *Pipeline) WithUnpack(unpack string) (*Pipeline, error)
• type Settings

Types

type Pipeline

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

func New

func New(log *util.Logger, cc Settings) (*Pipeline, error)

func (*Pipeline) Process

func (p *Pipeline) Process(in []byte) ([]byte, error)

func (*Pipeline) WithDecode

func (p *Pipeline) WithDecode(decode string) (*Pipeline, error)

WithDecode adds data decoding

func (*Pipeline) WithJq

func (p *Pipeline) WithJq(jq string) (*Pipeline, error)

WithJq adds a jq query applied to the mqtt listener payload

func (*Pipeline) WithRegex

func (p *Pipeline) WithRegex(regex, dflt string) (*Pipeline, error)

WithRegex adds a regex query applied to the mqtt listener payload

func (*Pipeline) WithUnpack

func (p *Pipeline) WithUnpack(unpack string) (*Pipeline, error)

WithUnpack adds data unpacking

type Settings

type Settings struct {
	Regex   string
	Default string
	Jq      string
	Unpack  string
	Decode  string
}