lib

type Mqtt interface {
	Publish(topic, msg string) (err error)
}

type Mqtt4 struct {
	Debug bool
	// contains filtered or unexported fields
}

type Mqtt5 struct {
	Debug bool
	// contains filtered or unexported fields
}

type RequestEnvelope struct {
	CorrelationId      string                                   `json:"correlation_id"`
	Payload            platform_connector_lib.CommandRequestMsg `json:"payload"`
	Time               int64                                    `json:"timestamp"`
	CompletionStrategy string                                   `json:"completion_strategy"`
}