Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewAWSMQTTSender ¶
func NewAWSMQTTSender(logging logger.LoggingClient, config *AWSMQTTConfig) *sdkTransforms.MQTTSender
NewAWSMQTTSender return a mqtt sender capable of sending the event's value to the given MQTT broker
Types ¶
type AWSMQTTConfig ¶
type AWSMQTTConfig struct {
MQTTConfig sdkTransforms.MqttConfig
IoTHost string
IoTPort string
IoTDevice string
IoTTopic string
DeviceNames string
PersistOnError bool
KeyCertPair *sdkTransforms.KeyCertPair
}
AWSMQTTConfig holds AWS IoT specific information
func LoadAWSMQTTConfig ¶
func LoadAWSMQTTConfig(sdk *appsdk.AppFunctionsSDK) (*AWSMQTTConfig, error)
LoadAWSMQTTConfig Loads the mqtt configuration necessary to connect to AWS cloud
type Conversion ¶
type Conversion struct {
}
Conversion Struct
func (Conversion) TransformToAWS ¶
func (f Conversion) TransformToAWS(edgexcontext *appcontext.Context, params ...interface{}) (continuePipeline bool, stringType interface{})
TransformToAWS converts the event into AWS readable format
Source Files
Click to show internal directories.
Click to hide internal directories.