diff options
Diffstat (limited to 'weed/util/http/http_global_client_util.go')
| -rw-r--r-- | weed/util/http/http_global_client_util.go | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/weed/util/http/http_global_client_util.go b/weed/util/http/http_global_client_util.go index 38f129365..3a969fdc8 100644 --- a/weed/util/http/http_global_client_util.go +++ b/weed/util/http/http_global_client_util.go @@ -24,6 +24,7 @@ import ( ) var ErrNotFound = fmt.Errorf("not found") +var ErrTooManyRequests = fmt.Errorf("too many requests") var ( jwtSigningReadKey security.SigningKey @@ -332,6 +333,9 @@ func ReadUrlAsStream(ctx context.Context, fileUrl, jwt string, cipherKey []byte, if r.StatusCode == http.StatusNotFound { return true, fmt.Errorf("%s: %s: %w", fileUrl, r.Status, ErrNotFound) } + if r.StatusCode == http.StatusTooManyRequests { + return false, fmt.Errorf("%s: %s: %w", fileUrl, r.Status, ErrTooManyRequests) + } retryable = r.StatusCode >= 499 return retryable, fmt.Errorf("%s: %s", fileUrl, r.Status) } |