Versions in this module Expand all Collapse all v0 v0.0.4 Jul 19, 2022 Changes in this version + const Scheme + func OpenSubscription(conn *amqp.Connection, name string, opts *SubscriptionOptions) *pubsub.Subscription + func OpenTopic(conn *amqp.Connection, name string, opts *TopicOptions) *pubsub.Topic + type MultiError []error + func (m MultiError) Error() string + type SubscriptionOptions struct + type TopicOptions struct + type URLOpener struct + Connection *amqp.Connection + 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)
Go to main page