mqtt

type Client interface {
	Publish(topic string, payload interface{}) error
	Subscribe(ctx context.Context, topic string) (rxgo.Observable, error)
	SubscribeReturnMessage(ctx context.Context, topic string) (rxgo.Observable, error)
	IsConnected() bool
	Close()
}

type ClientOptions struct {
	Server    string // tcp://host:port
	TLSConfig *ClientOptions_TLSConfig
	ClientID  string
}

type ClientOptions_TLSConfig struct {
	Cert   []byte
	Key    []byte
	RootCa []byte
}

type Message struct {
	Topic   string
	Payload []byte
}