transforms

Nov 10, 2020

Changes in this version

type HTTPSender

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

type OutputData

+ ResponseContentType string

+ type Tags struct

+ func NewTags(tags map[string]string) Tags

+ func (t *Tags) AddTags(edgexcontext *appcontext.Context, params ...interface{}) (bool, interface{})

Jun 11, 2020

Changes in this version

type Filter

+ FilterOut bool

May 12, 2020

Changes in this version

+ const AuthModeCA

+ const AuthModeCert

+ const AuthModeNone

+ const AuthModeUsernamePassword

+ const BatchByCountOnly

+ const BatchByTimeAndCount

+ const BatchByTimeOnly

+ const MQTTSecretCACert

+ const MQTTSecretClientCert

+ const MQTTSecretClientKey

+ const MQTTSecretPassword

+ const MQTTSecretUsername

+ type BatchConfig struct

+ func NewBatchByCount(batchThreshold int) (*BatchConfig, error)

+ func NewBatchByTime(timeInterval string) (*BatchConfig, error)

+ func NewBatchByTimeAndCount(timeInterval string, batchThreshold int) (*BatchConfig, error)

+ func (batch *BatchConfig) Batch(edgexcontext *appcontext.Context, params ...interface{}) (bool, interface{})

+ type BatchMode int

type HTTPSender

+ SecretHeaderName string

+ SecretPath string

+ func NewHTTPSenderWithSecretHeader(url string, mimeType string, persistOnError bool, httpHeaderSecretName string, ...) HTTPSender

+ type JSONLogic struct

+ Rule string

+ func NewJSONLogic(rule string) JSONLogic

+ func (logic JSONLogic) Evaluate(edgexcontext *appcontext.Context, params ...interface{}) (bool, interface{})

+ type MQTTSecretConfig struct

+ AuthMode string

+ AutoReconnect bool

+ BrokerAddress string

+ ClientId string

+ QoS byte

+ Retain bool

+ SecretPath string

+ SkipCertVerify bool

+ Topic string

+ type MQTTSecretSender struct

+ func NewMQTTSecretSender(mqttConfig MQTTSecretConfig, persistOnError bool) *MQTTSecretSender

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

Nov 11, 2019

Changes in this version

+ type Compression struct

+ func NewCompression() Compression

+ func (compression *Compression) CompressWithGZIP(edgexcontext *appcontext.Context, params ...interface{}) (bool, interface{})

+ func (compression *Compression) CompressWithZLIB(edgexcontext *appcontext.Context, params ...interface{}) (bool, interface{})

type Conversion

+ func NewConversion() Conversion

+ type CoreData struct

+ DeviceName string

+ ReadingName string

+ func NewCoreData() *CoreData

+ func (cdc *CoreData) MarkAsPushed(edgexcontext *appcontext.Context, params ...interface{}) (bool, interface{})

+ func (cdc *CoreData) PushToCoreData(edgexcontext *appcontext.Context, params ...interface{}) (bool, interface{})

+ type Encryption struct

+ InitializationVector string

+ Key string

+ func NewEncryption(key string, initializationVector string) Encryption

+ func (aesData Encryption) EncryptWithAES(edgexcontext *appcontext.Context, params ...interface{}) (bool, interface{})

type Filter

+ func NewFilter(filterValues []string) Filter

type HTTPSender

+ PersistOnError bool

+ func NewHTTPSender(url string, mimeType string, persistOnError bool) HTTPSender

+ type KeyCertPair struct

+ CertFile string

+ CertPEMBlock []byte

+ KeyFile string

+ KeyPEMBlock []byte

type MqttConfig

+ AutoReconnect bool

+ Password string

+ Qos byte

+ Retain bool

+ SkipCertVerify bool

+ User string

+ type OutputData struct

+ func NewOutputData() OutputData

+ func (f OutputData) SetOutputData(edgexcontext *appcontext.Context, params ...interface{}) (bool, interface{})

Jun 19, 2019

Changes in this version

+ type Conversion struct

+ 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 struct

+ FilterValues []string

+ 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 struct

+ MimeType string

+ URL string

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

+ type MQTTSender struct

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

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

+ type MqttConfig struct

+ func NewMqttConfig() *MqttConfig

+ func (mqttConfig MqttConfig) SetAutoreconnect(reconnect bool)

+ func (mqttConfig MqttConfig) SetQos(qos byte)

+ func (mqttConfig MqttConfig) SetRetain(retain bool)