diff options
| author |  kim <grufwub@gmail.com> | 2025-04-28 11:20:24 +0000 |
|---|---|---|
| committer |  kim <gruf@noreply.codeberg.org> | 2025-04-28 11:20:24 +0000 |
| commit | 436765a6a2ddf400b6e06c9a7c3283b1351fcbcd (patch) | |
| tree | c1a0e969c23a74eaca258c709db1776763d576dd /vendor/github.com/minio/minio-go/v7/api-bucket-notification.go | |
| parent | [chore] Update build to use new woodpecker dind container, bump version numbe... (diff) | |
| download | gotosocial-436765a6a2ddf400b6e06c9a7c3283b1351fcbcd.tar.xz | |
bump dependencies: minio-go, go-sqlite3, goldmark, otel, x/image/webp (#4075)
Reviewed-on: https://codeberg.org/superseriousbusiness/gotosocial/pulls/4075
Co-authored-by: kim <grufwub@gmail.com>
Co-committed-by: kim <grufwub@gmail.com>
Diffstat (limited to 'vendor/github.com/minio/minio-go/v7/api-bucket-notification.go')
| -rw-r--r-- | vendor/github.com/minio/minio-go/v7/api-bucket-notification.go | 9 |
1 files changed, 1 insertions, 8 deletions
diff --git a/vendor/github.com/minio/minio-go/v7/api-bucket-notification.go b/vendor/github.com/minio/minio-go/v7/api-bucket-notification.go index 33811b98f..b1e5b0aae 100644 --- a/vendor/github.com/minio/minio-go/v7/api-bucket-notification.go +++ b/vendor/github.com/minio/minio-go/v7/api-bucket-notification.go @@ -157,13 +157,6 @@ func (c *Client) ListenBucketNotification(ctx context.Context, bucketName, prefi return } - // Continuously run and listen on bucket notification. - // Create a done channel to control 'ListObjects' go routine. - retryDoneCh := make(chan struct{}, 1) - - // Indicate to our routine to exit cleanly upon return. - defer close(retryDoneCh) - // Prepare urlValues to pass into the request on every loop urlValues := make(url.Values) urlValues.Set("ping", "10") @@ -172,7 +165,7 @@ func (c *Client) ListenBucketNotification(ctx context.Context, bucketName, prefi urlValues["events"] = events // Wait on the jitter retry loop. - for range c.newRetryTimerContinous(time.Second, time.Second*30, MaxJitter, retryDoneCh) { + for range c.newRetryTimerContinous(time.Second, time.Second*30, MaxJitter) { // Execute GET on bucket to list objects. resp, err := c.executeMethod(ctx, http.MethodGet, requestMetadata{ bucketName: bucketName, |