Versions in this module Expand all Collapse all v1 v1.0.4 Mar 10, 2021 Changes in this version type Conversion + func (f Conversion) CustomTransformKeyValueToJson(edgexcontext *appcontext.Context, params ...interface{}) (continuePipeline bool, stringType interface{}) v1.0.3 Mar 5, 2021 Changes in this version type Conversion + func (f Conversion) CustomTransformToJson(edgexcontext *appcontext.Context, params ...interface{}) (continuePipeline bool, stringType interface{}) v1.0.0 Mar 3, 2021 Changes in this version + const BatchByCountOnly + const BatchByTimeAndCount + const BatchByTimeOnly + func ByteToFloat32(bytes []byte) float32 + func ByteToFloat64(bytes []byte) float64 + func BytesToInt(b []byte) int + func CreateShiftFlagMap(flag []string) map[string]string + func CreateShiftMap(value string) map[string]int + func Float32ToByte(float float32) []byte + func Float64ToByte(float float64) []byte + func FloatToString(input_num float32) string + 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 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 struct + func NewConversion() Conversion + func (f Conversion) CustomTransformToXML(edgexcontext *appcontext.Context, params ...interface{}) (continuePipeline bool, stringType interface{}) + 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 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 struct + FilterOut bool + FilterValues []string + func NewFilter(filterValues []string) 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 struct + MimeType string + PersistOnError bool + SecretHeaderName string + SecretPath string + URL string + func NewHTTPSender(url string, mimeType string, persistOnError bool) HTTPSender + func NewHTTPSenderWithSecretHeader(url string, mimeType string, persistOnError bool, httpHeaderSecretName string, ...) HTTPSender + func (sender HTTPSender) HTTPPost(edgexcontext *appcontext.Context, params ...interface{}) (bool, interface{}) + func (sender HTTPSender) HTTPPut(edgexcontext *appcontext.Context, params ...interface{}) (bool, interface{}) + type JSONLogic struct + Rule string + func NewJSONLogic(rule string) JSONLogic + func (logic JSONLogic) Evaluate(edgexcontext *appcontext.Context, params ...interface{}) (bool, interface{}) + type KeyCertPair struct + CertFile string + CertPEMBlock []byte + KeyFile string + KeyPEMBlock []byte + 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{}) + type MQTTSender struct + func NewMQTTSender(logging logger.LoggingClient, addr models.Addressable, ...) *MQTTSender + func (sender *MQTTSender) MQTTSend(edgexcontext *appcontext.Context, params ...interface{}) (bool, interface{}) + type MqttConfig struct + AutoReconnect bool + Password string + Qos byte + Retain bool + SkipCertVerify bool + User string + type OutputData struct + ResponseContentType string + func NewOutputData() OutputData + func (f OutputData) SetOutputData(edgexcontext *appcontext.Context, params ...interface{}) (bool, interface{}) + type Tags struct + func NewTags(tags map[string]string) Tags + func (t *Tags) AddTags(edgexcontext *appcontext.Context, params ...interface{}) (bool, interface{})
Go to main page