Documentation ¶
Index ¶
- Constants
- func ConnectNode(subscriptions map[string]mqtt.MessageHandler) error
- func CreateMQTTLogger(out io.Writer, formatter log.Formatter, level log.Level)
- func DisconnectNode() error
- func RegisterNode() error
- func SendEdgeAppLogs(msg EdgeAppLogMsg) error
- func SendHeartbeat(msg StatusMsg) error
- func SendNodePublicKey(nodePublicKey []byte) error
- type ContainerLogLineMsg
- type ContainerLogMsg
- type ContainerMsg
- type DeviceParamsMsg
- type EdgeAppLogMsg
- type EdgeAppMsg
- type StatusMsg
Constants ¶
View Source
const ( TopicOrchestration = "orchestration" TopicOrgPrivateKey = "orgKey" TopicNodeDelete = "delete" )
Variables ¶
This section is empty.
Functions ¶
func ConnectNode ¶
func ConnectNode(subscriptions map[string]mqtt.MessageHandler) error
func CreateMQTTLogger ¶ added in v1.1.4
func DisconnectNode ¶
func DisconnectNode() error
func RegisterNode ¶
func RegisterNode() error
func SendEdgeAppLogs ¶ added in v1.1.0
func SendEdgeAppLogs(msg EdgeAppLogMsg) error
func SendHeartbeat ¶
func SendNodePublicKey ¶ added in v1.1.0
Types ¶
type ContainerLogLineMsg ¶ added in v1.3.0
type ContainerLogMsg ¶ added in v1.3.0
type ContainerLogMsg struct { ContainerID string `json:"containerID"` Log []ContainerLogLineMsg `json:"log"` }
type ContainerMsg ¶ added in v1.1.0
type DeviceParamsMsg ¶ added in v1.1.0
type EdgeAppLogMsg ¶ added in v1.1.0
type EdgeAppLogMsg struct { ManifestID string `json:"manifestID"` ContainerLogs []ContainerLogMsg `json:"containerLog"` }
type EdgeAppMsg ¶ added in v1.1.0
type EdgeAppMsg struct { ManifestID string `json:"manifestID"` Status string `json:"status"` Containers []ContainerMsg `json:"containers"` }
type StatusMsg ¶ added in v1.1.0
type StatusMsg struct { Status string `json:"status"` EdgeApplications []EdgeAppMsg `json:"edgeApplications"` DeviceParams DeviceParamsMsg `json:"deviceParams"` AgentVersion string `json:"agentVersion"` }
Click to show internal directories.
Click to hide internal directories.