- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for NewTimeoutError (0.27 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/errors.go
} } func NewUnreachableError(key string, rv int64) *StorageError { return &StorageError{ Code: ErrCodeUnreachable, Key: key, ResourceVersion: rv, } } func NewTimeoutError(key, msg string) *StorageError { return &StorageError{ Code: ErrCodeTimeout, Key: key, AdditionalErrorMsg: msg, } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 08 15:39:10 UTC 2023 - 5.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/filters/timeout.go
} postTimeoutFn := func() { metrics.RecordRequestTermination(req, requestInfo, metrics.APIServerComponent, http.StatusGatewayTimeout) } return req, false, postTimeoutFn, apierrors.NewTimeoutError("request did not complete within the allotted timeout", 0) } return WithTimeout(handler, timeoutFunc) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 26 16:28:45 UTC 2024 - 8.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/validating/dispatcher.go
} // Check if the request has already timed out before spawning remote calls select { case <-ctx.Done(): // parent context is canceled or timed out, no point in continuing return apierrors.NewTimeoutError("request did not complete within requested timeout", 0) default: } wg := sync.WaitGroup{} errCh := make(chan error, 2*len(relevantHooks)) // double the length to handle extra errors for panics in the gofunc
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Aug 23 20:24:12 UTC 2023 - 13K bytes - Viewed (0) -
pkg/registry/core/pod/storage/eviction.go
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/apiserver/pkg/admission/plugin/webhook/mutating/dispatcher.go
} utilruntime.HandleError(callErr) select { case <-ctx.Done(): // parent context is canceled or timed out, no point in continuing return apierrors.NewTimeoutError("request did not complete within requested timeout", 0) default: // individual webhook timed out, but parent context did not, continue continue } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 28 08:48:22 UTC 2024 - 19.6K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/api/errors/errors_test.go
} if time, ok := SuggestsClientDelay(NewServerTimeout(resource("tests"), "doing something", 0)); time != 0 || !ok { t.Errorf("unexpected %d", time) } if time, ok := SuggestsClientDelay(NewTimeoutError("test reason", 10)); time != 10 || !ok { t.Errorf("unexpected %d", time) } if time, ok := SuggestsClientDelay(NewTooManyRequests("doing something", 10)); time != 10 || !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) -
cmd/kubeadm/app/util/apiclient/idempotency_test.go
node: v1.Node{ ObjectMeta: metav1.ObjectMeta{ Name: "testnode", Labels: map[string]string{v1.LabelHostname: ""}, }, }, success: false, fakeError: apierrors.NewTimeoutError("fake timeout", -1), }, { name: "patch node when conflict", lookupName: "testnode", node: v1.Node{ ObjectMeta: metav1.ObjectMeta{ Name: "testnode",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Feb 18 11:14:32 UTC 2024 - 33.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/store.go
} // Check if the request has already timed out before decode object select { case <-ctx.Done(): // parent context is canceled or timed out, no point in continuing return storage.NewTimeoutError(string(kv.Key), "request did not complete within requested timeout") default: } obj, err := decodeListItem(ctx, data, uint64(kv.ModRevision), s.codec, s.versioner, newItemFunc) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 11:56:42 UTC 2024 - 35.2K bytes - Viewed (0)