routing

Documentation

Index

• Constants
• func CreateLocalCmdTopicLong(env *protocol.Envelope) string
• func CreateLocalCmdTopicShort(env *protocol.Envelope) string
• func CreateRemoteCloudTopic(deviceID string) string
• func CreateTelemetryTopic(deviceID, msgID string) string
• func NewAzureGwParams(deviceID, tenantID, hubName string) *routing.GwParams

Constants

const (
	// StatusConnectionNotAuthorized defines a not authorized connection status.
	StatusConnectionNotAuthorized = "CONNECTION_NOT_AUTHORIZED"
	// StatusConnectionTokenExpired defines a token expired connection status.
	StatusConnectionTokenExpired = "CONNECTION_TOKEN_EXPIRED"
)

Functions

func CreateLocalCmdTopicLong

func CreateLocalCmdTopicLong(env *protocol.Envelope) string

CreateLocalCmdTopicLong constructs the local MQTT topic for receiving C2D messages from an Azure IoT Hub device.

func CreateLocalCmdTopicShort

func CreateLocalCmdTopicShort(env *protocol.Envelope) string

CreateLocalCmdTopicShort constructs the local MQTT topic for receiving C2D messages from an Azure IoT Hub device.

func CreateRemoteCloudTopic

func CreateRemoteCloudTopic(deviceID string) string

CreateRemoteCloudTopic constructs the remote MQTT topic for receiving C2D messages from an Azure IoT Hub device.

func CreateTelemetryTopic

func CreateTelemetryTopic(deviceID, msgID string) string

CreateTelemetryTopic constructs the MQTT topic for sending telemetry data to an Azure IoT Hub device.

func NewAzureGwParams

func NewAzureGwParams(deviceID, tenantID, hubName string) *routing.GwParams

NewAzureGwParams creates the gateway parameters