mqtt

type Client interface {
	// Publish will publish the payload to a particular topic.
	Publish(ctx context.Context, topic string, qos byte, retain bool, payload interface{}) error

	io.Closer
}

type DefaultDialer struct{}

type Dependency struct {
	Dialer Dialer
}

type Dialer interface {
	// Dial will connect to the given brokers and return a Client.
	Dial(ctx context.Context, brokers []string, options Options) (Client, error)
}

type ErrorDialer struct{}

type Options struct {
	ClientID string
	Username string
	Password string
	Timeout  time.Duration
}