mqtt

type Cache struct {
	// contains filtered or unexported fields
}

type Connection struct {
	// contains filtered or unexported fields
}

type ConnectionOptions struct {
	BrokerURLs         []string
	Topic              string
	KeepAlive          time.Duration
	ClientID           string
	Username, Password string
	OnMessage          func(m *paho.Publish)
}

type Decoder struct {
	// contains filtered or unexported fields
}

type DecoderSink interface {
	Update(msg *mqttv1.ResourceMessage) error
	Delete(uid types.UID) error
}

type DecoderSinkList []DecoderSink

type EventClient struct {
	// Buffered channel of outbound messages.
	Channel chan event.GenericEvent
}

type EventHub struct {
	// contains filtered or unexported fields
}