bus

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

type Connection interface {
	Connect(options ConnectionOptions) error
	Disconnect() error
	Publish(topic string, payload []byte) error
	Subscribe(topic string, handler SubscriptionHandler) error
}

type ConnectionOptions struct {
	Userid        string
	Password      string
	Host          string
	Port          int
	SSLEnabled    bool
	SSLCertPath   string
	EventsHandler EventHandler
	AutoReconnect bool
	OnDisconnect  *DisconnectMessage
}

type DisconnectMessage struct {
	Topic string
	Body  string
}

type Event int

type EventHandler func(conn Connection, event Event)

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

type MessagePublisher interface {
	Publish(topic string, message []byte) error
}

type SubscriptionHandler func(conn Connection, topic string, message []byte)