diff options
| author | dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com> | 2024-02-14 12:28:15 +0000 |
|---|---|---|
| committer | Taras Madan <tarasmadan@google.com> | 2024-02-14 13:03:08 +0000 |
| commit | a2c48ea3dc6f807b8befbf2895431d43d7fc81ab (patch) | |
| tree | 1b241f766987e29ecee8d30bb47655fed9075b36 /vendor/cloud.google.com/go/pubsub/pullstream.go | |
| parent | c93187e8318d1a6289b2b2ad297dd6b6cfef6cf7 (diff) | |
mod: bump cloud.google.com/go/pubsub from 1.33.0 to 1.36.1
Bumps [cloud.google.com/go/pubsub](https://github.com/googleapis/google-cloud-go) from 1.33.0 to 1.36.1.
- [Release notes](https://github.com/googleapis/google-cloud-go/releases)
- [Changelog](https://github.com/googleapis/google-cloud-go/blob/main/CHANGES.md)
- [Commits](https://github.com/googleapis/google-cloud-go/compare/pubsub/v1.33.0...pubsub/v1.36.1)
---
updated-dependencies:
- dependency-name: cloud.google.com/go/pubsub
dependency-type: direct:production
update-type: version-update:semver-minor
...
Signed-off-by: dependabot[bot] <support@github.com>
Diffstat (limited to 'vendor/cloud.google.com/go/pubsub/pullstream.go')
| -rw-r--r-- | vendor/cloud.google.com/go/pubsub/pullstream.go | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/vendor/cloud.google.com/go/pubsub/pullstream.go b/vendor/cloud.google.com/go/pubsub/pullstream.go index d6f5eb636..bfdc11e2a 100644 --- a/vendor/cloud.google.com/go/pubsub/pullstream.go +++ b/vendor/cloud.google.com/go/pubsub/pullstream.go @@ -16,7 +16,9 @@ package pubsub import ( "context" + "fmt" "io" + "net/url" "sync" "time" @@ -42,6 +44,8 @@ type streamingPullFunc func(context.Context, ...gax.CallOption) (pb.Subscriber_S func newPullStream(ctx context.Context, streamingPull streamingPullFunc, subName string, maxOutstandingMessages, maxOutstandingBytes int, maxDurationPerLeaseExtension time.Duration) *pullStream { ctx = withSubscriptionKey(ctx, subName) + hds := []string{"x-goog-request-params", fmt.Sprintf("%s=%v", "subscription", url.QueryEscape(subName))} + ctx = gax.InsertMetadataIntoOutgoingContext(ctx, hds...) ctx, cancel := context.WithCancel(ctx) return &pullStream{ ctx: ctx, |