mqtt

type MQTTTargetProvider struct {
	Config          MQTTTargetProviderConfig
	Context         *contexts.ManagerContext
	MQTTClient      gmqtt.Client
	GetChan         chan ProxyResponse
	RemoveChan      chan ProxyResponse
	NeedsUpdateChan chan ProxyResponse
	NeedsRemoveChan chan ProxyResponse
	ApplyChan       chan ProxyResponse
	Initialized     bool
}

type MQTTTargetProviderConfig struct {
	Name               string `json:"name"`
	BrokerAddress      string `json:"brokerAddress"`
	ClientID           string `json:"clientID"`
	RequestTopic       string `json:"requestTopic"`
	ResponseTopic      string `json:"responseTopic"`
	TimeoutSeconds     int    `json:"timeoutSeconds,omitempty"`
	KeepAliveSeconds   int    `json:"keepAliveSeconds,omitempty"`
	PingTimeoutSeconds int    `json:"pingTimeoutSeconds,omitempty"`
}

type ProxyResponse struct {
	IsOK    bool
	State   v1alpha2.State
	Payload interface{}
}

type TwoComponentSlices struct {
	Current []model.ComponentSpec `json:"current"`
	Desired []model.ComponentSpec `json:"desired"`
}