- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for NewTooManyRequests (0.17 sec)
-
pkg/registry/core/pod/storage/eviction.go
// budgets, we can sometimes compute a sensible suggested value. But // even without that, we can give a suggestion (even if small) that // prevents well-behaved clients from hammering us. err := errors.NewTooManyRequests("Cannot evict pod as it would violate the pod's disruption budget.", 10)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Aug 08 11:58:48 UTC 2023 - 18.2K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/api/errors/errors_test.go
t.Errorf("unexpected %d", time) } if time, ok := SuggestsClientDelay(NewTooManyRequests("doing something", 10)); time != 10 || !ok { t.Errorf("unexpected %d", time) } if time, ok := SuggestsClientDelay(NewTooManyRequests("doing something", 1)); time != 1 || !ok { t.Errorf("unexpected %d", time) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Oct 28 07:31:28 UTC 2023 - 19.5K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/api/errors/errors.go
Reason: metav1.StatusReasonBadRequest, Message: reason, }} } // NewTooManyRequests creates an error that indicates that the client must try again later because // the specified endpoint is not accepting requests. More specific details should be provided // if client should know why the failure was limited. func NewTooManyRequests(message string, retryAfterSeconds int) *StatusError { return &StatusError{metav1.Status{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 21 03:41:32 UTC 2022 - 30.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go
if utilfeature.DefaultFeatureGate.Enabled(features.ResilientWatchCacheInitialization) { var ok bool readyGeneration, ok = c.ready.checkAndReadGeneration() if !ok { return nil, errors.NewTooManyRequests("storage is (re)initializing", 1) } } else { readyGeneration, err = c.ready.waitAndReadGeneration(ctx) if err != nil { return nil, errors.NewServiceUnavailable(err.Error()) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 51.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_whitebox_test.go
if err == nil || err.Error() != apierrors.NewServiceUnavailable(context.Canceled.Error()).Error() { t.Errorf("Unexpected error: %#v", err) } } else { if err == nil || err.Error() != apierrors.NewTooManyRequests("storage is (re)initializing", 1).Error() { t.Errorf("Unexpected error: %#v", err) } } } func TestWatcherNotGoingBackInTime(t *testing.T) { backingStorage := &dummyStorage{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 82.9K bytes - Viewed (0)