Versions in this module Expand all Collapse all v0 v0.24.1 Jan 27, 2022 Changes in this version + const SNSScheme + const SQSScheme + var Set = wire.NewSet(wire.Struct(new(URLOpener), "ConfigProvider")) + func OpenSNSTopic(ctx context.Context, sess client.ConfigProvider, topicARN string, ...) *pubsub.Topic + func OpenSNSTopicV2(ctx context.Context, client *snsv2.Client, topicARN string, opts *TopicOptions) *pubsub.Topic + func OpenSQSTopic(ctx context.Context, sess client.ConfigProvider, qURL string, ...) *pubsub.Topic + func OpenSQSTopicV2(ctx context.Context, client *sqsv2.Client, qURL string, opts *TopicOptions) *pubsub.Topic + func OpenSubscription(ctx context.Context, sess client.ConfigProvider, qURL string, ...) *pubsub.Subscription + func OpenSubscriptionV2(ctx context.Context, client *sqsv2.Client, qURL string, ...) *pubsub.Subscription + func OpenTopic(ctx context.Context, sess client.ConfigProvider, topicARN string, ...) *pubsub.Topic + type BodyBase64Encoding int + const Always + const Never + const NonUTF8Only + type SubscriptionOptions struct + Raw bool + WaitTime time.Duration + type TopicOptions struct + BodyBase64Encoding BodyBase64Encoding + type URLOpener struct + ConfigProvider client.ConfigProvider + SubscriptionOptions SubscriptionOptions + TopicOptions TopicOptions + UseV2 bool + 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