Skip to content

Commit

Permalink
pubsub/azuresb: update to use latest Azure beta release BREAKING_CHAN…
Browse files Browse the repository at this point in the history
…GE_OK (#3118)
  • Loading branch information
vangent committed Aug 3, 2022
1 parent 1a88ed9 commit 5589018
Show file tree
Hide file tree
Showing 16 changed files with 507 additions and 333 deletions.
48 changes: 38 additions & 10 deletions docstore/mongodocstore/go.sum

Large diffs are not rendered by default.

7 changes: 4 additions & 3 deletions go.mod
Expand Up @@ -32,12 +32,14 @@ require (
github.com/Azure/azure-amqp-common-go/v3 v3.2.2
github.com/Azure/azure-pipeline-go v0.2.3
github.com/Azure/azure-sdk-for-go v59.3.0+incompatible
github.com/Azure/azure-service-bus-go v0.11.5
github.com/Azure/azure-sdk-for-go/sdk/messaging/azservicebus v0.4.0
github.com/Azure/azure-storage-blob-go v0.14.0
github.com/Azure/go-amqp v0.16.4
github.com/Azure/go-amqp v0.17.4
github.com/Azure/go-autorest/autorest v0.11.22
github.com/Azure/go-autorest/autorest/adal v0.9.17
github.com/Azure/go-autorest/autorest/azure/auth v0.5.9
github.com/Azure/go-autorest/autorest/to v0.4.0 // indirect
github.com/Azure/go-autorest/autorest/validation v0.3.1 // indirect
github.com/GoogleCloudPlatform/cloudsql-proxy v1.29.0
github.com/aws/aws-sdk-go v1.43.31
github.com/aws/aws-sdk-go-v2 v1.16.2
Expand All @@ -64,7 +66,6 @@ require (
github.com/googleapis/gax-go/v2 v2.2.0
github.com/klauspost/compress v1.15.1 // indirect
github.com/lib/pq v1.10.4
github.com/mitchellh/mapstructure v1.4.3 // indirect
go.opencensus.io v0.23.0
go.uber.org/atomic v1.9.0 // indirect
go.uber.org/multierr v1.8.0 // indirect
Expand Down
68 changes: 52 additions & 16 deletions go.sum

Large diffs are not rendered by default.

6 changes: 4 additions & 2 deletions internal/testing/alldeps
Expand Up @@ -14,7 +14,10 @@ contrib.go.opencensus.io/integrations/ocsql
github.com/Azure/azure-amqp-common-go/v3
github.com/Azure/azure-pipeline-go
github.com/Azure/azure-sdk-for-go
github.com/Azure/azure-service-bus-go
github.com/Azure/azure-sdk-for-go/sdk/azcore
github.com/Azure/azure-sdk-for-go/sdk/internal
github.com/Azure/azure-sdk-for-go/sdk/messaging/azservicebus
github.com/Azure/azure-sdk-for-go/sdk/messaging/internal
github.com/Azure/azure-storage-blob-go
github.com/Azure/go-amqp
github.com/Azure/go-autorest/autorest
Expand Down Expand Up @@ -155,4 +158,3 @@ google.golang.org/grpc
google.golang.org/protobuf
gopkg.in/pipe.v2
gopkg.in/square/go-jose.v2
nhooyr.io/websocket
5 changes: 2 additions & 3 deletions internal/website/content/howto/pubsub/publish.md
Expand Up @@ -191,15 +191,14 @@ create an [AWS session][] with the same region as your topic:

### Azure Service Bus {#azure}

The Go CDK can publish to an [Azure Service Bus][] topic over [AMQP 1.0][].
The Go CDK can publish to an [Azure Service Bus][] topic.
The URL for publishing is the topic name. `pubsub.OpenTopic` will use the
environment variable `SERVICEBUS_CONNECTION_STRING` to obtain the Service Bus
connection string. The connection string can be obtained
[from the Azure portal][Azure connection string].

{{< goexample "gocloud.dev/pubsub/azuresb.Example_openTopicFromURL" >}}

[AMQP 1.0]: https://www.amqp.org/
[Azure connection string]: https://docs.microsoft.com/en-us/azure/service-bus-messaging/service-bus-dotnet-how-to-use-topics-subscriptions#get-the-connection-string
[Azure Service Bus]: https://azure.microsoft.com/en-us/services/service-bus/

Expand All @@ -213,7 +212,7 @@ then pass it to `azuresb.OpenTopic`. There are also helper functions in the
{{< goexample "gocloud.dev/pubsub/azuresb.ExampleOpenTopic" >}}

[`azuresb.OpenTopic`]: https://godoc.org/gocloud.dev/pubsub/azuresb#OpenTopic
[Azure Service Bus library]: https://github.com/Azure/azure-service-bus-go
[Azure Service Bus library]: https://pkg.go.dev/github.com/Azure/azure-sdk-for-go/sdk/messaging/azservicebus

### RabbitMQ {#rabbitmq}

Expand Down
6 changes: 3 additions & 3 deletions internal/website/content/howto/pubsub/subscribe.md
Expand Up @@ -171,8 +171,8 @@ first create an [AWS session][] with the same region as your topic:

### Azure Service Bus {#azure}

The Go CDK can recieve messages from an [Azure Service Bus][] subscription
over [AMQP 1.0][]. The URL for subscribing is the topic name with the
The Go CDK can recieve messages from an [Azure Service Bus][] subscription.
The URL for subscribing is the topic name with the
subscription name in the `subscription` query parameter.
`pubsub.OpenSubscription` will use the environment variable
`SERVICEBUS_CONNECTION_STRING` to obtain the Service Bus Connection String
Expand All @@ -195,7 +195,7 @@ package to make this easier.
{{< goexample "gocloud.dev/pubsub/azuresb.ExampleOpenSubscription" >}}

[`azuresb.OpenSubscription`]: https://godoc.org/gocloud.dev/pubsub/azuresb#OpenSubscription
[Azure Service Bus library]: https://github.com/Azure/azure-service-bus-go
[Azure Service Bus library]: https://pkg.go.dev/github.com/Azure/azure-sdk-for-go/sdk/messaging/azservicebus

### RabbitMQ {#rabbitmq}

Expand Down
4 changes: 2 additions & 2 deletions internal/website/data/examples.json

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

0 comments on commit 5589018

Please sign in to comment.