Versions in this module Expand all Collapse all v0 v0.29.0 Jun 5, 2023 Changes in this version type SubscriptionOptions + WaitTime time.Duration v0.18.0 Feb 28, 2020 Changes in this version + const Scheme + func OpenSubscription(conn Subscriber, topicName string, _ *SubscriptionOptions) (*pubsub.Subscription, error) + func OpenTopic(conn Publisher, name string, _ *TopicOptions) (*pubsub.Topic, error) + type Publisher interface + Publish func(topic string, payload interface{}) error + Stop func() error + func NewPublisher(cli mqtt.Client) Publisher + type Subscriber interface + Close func() error + Subscribe func(topic string, handler mqtt.MessageHandler) error + UnSubscribe func(topic string) error + func NewSubscriber(cli mqtt.Client) Subscriber + type SubscriptionOptions struct + type TopicOptions struct + type URLOpener struct + PubConn Publisher + SubConn Subscriber + SubscriptionOptions SubscriptionOptions + TopicOptions TopicOptions + func (o *URLOpener) OpenSubscriptionURL(ctx context.Context, u *url.URL) (*pubsub.Subscription, error) + func (o *URLOpener) OpenTopicURL(ctx context.Context, u *url.URL) (*pubsub.Topic, error)