transport

type MQTTMessage struct {
	Topic   string
	Payload []byte
}

type MQTTTransport interface {
	Transport
	// Publish sends payload to topic.
	Publish(topic string, payload []byte, qos byte, retain bool) error
	// Subscribe returns a buffered channel of messages matching filter. Each
	// call creates a separate subscription with its own channel; sends are
	// non-blocking and drop on full so a slow subscriber can never stall the
	// paho receive loop.
	Subscribe(filter string, qos byte) (<-chan MQTTMessage, error)
}

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

type Transport interface {
	Close() error // Close releases the connection and any associated resources.
}