transforms

Documentation

Index

• type Conversion
  • func (f Conversion) TransformToJSON(edgexcontext *appcontext.Context, params ...interface{}) (continuePipeline bool, stringType interface{})
  • func (f Conversion) TransformToXML(edgexcontext *appcontext.Context, params ...interface{}) (continuePipeline bool, stringType interface{})
• type Filter
  • func (f Filter) FilterByDeviceName(edgexcontext *appcontext.Context, params ...interface{}) (continuePipeline bool, result interface{})
  • func (f Filter) FilterByValueDescriptor(edgexcontext *appcontext.Context, params ...interface{}) (continuePipeline bool, result interface{})
• type HTTPSender
  • func (sender HTTPSender) HTTPPost(edgexcontext *appcontext.Context, params ...interface{}) (bool, interface{})
• type MQTTSender
  • func NewMQTTSender(logging logger.LoggingClient, addr models.Addressable, certFile string, ...) *MQTTSender
  • func (sender MQTTSender) MQTTSend(edgexcontext *appcontext.Context, params ...interface{}) (bool, interface{})
• type MqttConfig
  • func NewMqttConfig() *MqttConfig
  • func (mqttConfig MqttConfig) SetAutoreconnect(reconnect bool)
  • func (mqttConfig MqttConfig) SetQos(qos byte)
  • func (mqttConfig MqttConfig) SetRetain(retain bool)

Types

type Conversion

type Conversion struct {
}

Conversion houses various built in conversion transforms (XML, JSON, CSV)

func (Conversion) TransformToJSON

func (f Conversion) TransformToJSON(edgexcontext *appcontext.Context, params ...interface{}) (continuePipeline bool, stringType interface{})

TransformToJSON ...

func (Conversion) TransformToXML

func (f Conversion) TransformToXML(edgexcontext *appcontext.Context, params ...interface{}) (continuePipeline bool, stringType interface{})

TransformToXML ...

type Filter

type Filter struct {
	FilterValues []string
}

Filter houses various the parameters for which filter transforms filter on

func (Filter) FilterByDeviceName

func (f Filter) FilterByDeviceName(edgexcontext *appcontext.Context, params ...interface{}) (continuePipeline bool, result interface{})

FilterByDeviceName filters events received from CoreData based off the specified DeviceIDs. This function returns an Event

func (Filter) FilterByValueDescriptor

func (f Filter) FilterByValueDescriptor(edgexcontext *appcontext.Context, params ...interface{}) (continuePipeline bool, result interface{})

FilterByValueDescriptor - filters events received from CoreData based on specified value descriptors This function returns an Event

type HTTPSender

type HTTPSender struct {
	URL      string
	MimeType string
}

HTTPSender ...

func (HTTPSender) HTTPPost

func (sender HTTPSender) HTTPPost(edgexcontext *appcontext.Context, params ...interface{}) (bool, interface{})

HTTPPost ...

type MQTTSender

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

func NewMQTTSender

func NewMQTTSender(logging logger.LoggingClient, addr models.Addressable, certFile string, key string, config *MqttConfig) *MQTTSender

NewMQTTSender - create new mqtt sender

func (MQTTSender) MQTTSend

func (sender MQTTSender) MQTTSend(edgexcontext *appcontext.Context, params ...interface{}) (bool, interface{})

MQTTSend ...

type MqttConfig

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

MqttConfig contains mqtt client parameters

func NewMqttConfig

func NewMqttConfig() *MqttConfig

NewMqttConfig returns a new MqttConfig with default values

func (MqttConfig) SetAutoreconnect

func (mqttConfig MqttConfig) SetAutoreconnect(reconnect bool)

SetAutoreconnect enables or disables the automatic client reconnection to broker

func (MqttConfig) SetQos

func (mqttConfig MqttConfig) SetQos(qos byte)

SetQos changes mqtt qos(0,1,2) for all messages

func (MqttConfig) SetRetain

func (mqttConfig MqttConfig) SetRetain(retain bool)

SetRetain enables or disables mqtt retain option