- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for NewServerTimeout (0.48 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/errors/storage.go
switch { case storage.IsNotFound(err): return errors.NewNotFound(qualifiedResource, "") case storage.IsUnreachable(err), storage.IsRequestTimeout(err): return errors.NewServerTimeout(qualifiedResource, "list", 2) // TODO: make configurable or handled at a higher level case storage.IsInternalError(err): return errors.NewInternalError(err) default: return err } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 08 15:39:10 UTC 2023 - 4.2K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/api/errors/errors_test.go
t.Errorf("unexpected %d", time) } if time, ok := SuggestsClientDelay(NewServerTimeout(resource("tests"), "doing something", 10)); time != 10 || !ok { t.Errorf("unexpected %d", time) } if time, ok := SuggestsClientDelay(NewServerTimeout(resource("tests"), "doing something", 0)); time != 0 || !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/apiserver/pkg/server/filters/timeout_test.go
doPanic := make(chan interface{}, 1) writeErrors := make(chan error, 1) gotPanic := make(chan interface{}, 1) timeout := make(chan time.Time, 1) resp := "test response" timeoutErr := apierrors.NewServerTimeout(schema.GroupResource{Group: "foo", Resource: "bar"}, "get", 0) record := &recorder{} var ctx context.Context withDeadline := func(handler http.Handler) http.Handler {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 26 16:28:45 UTC 2024 - 18.4K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/api/errors/errors.go
}, Message: fmt.Sprintf("%s is not supported on resources of kind %q", action, qualifiedResource.String()), }} } // NewServerTimeout returns an error indicating the requested action could not be completed due to a // transient error, and the client should try again. func NewServerTimeout(qualifiedResource schema.GroupResource, operation 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) -
cmd/kubeadm/app/phases/kubeconfig/kubeconfig_test.go
setupAdminClient: func(client *clientsetfake.Clientset) { client.PrependReactor("create", "clusterrolebindings", func(action clientgotesting.Action) (bool, runtime.Object, error) { return true, nil, apierrors.NewServerTimeout( schema.GroupResource{}, "create", 0) }) }, expectedError: true, }, { name: "admin.conf: CRB exists, return a client from admin.conf",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 17:04:18 UTC 2024 - 39.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/webhook/webhook_test.go
switch count++; count { case 1: // Timeout error with retry supplied w.WriteHeader(http.StatusGatewayTimeout) json.NewEncoder(w).Encode(apierrors.NewServerTimeout(gr, "get", 2)) case 2: // Internal server error w.WriteHeader(http.StatusInternalServerError) json.NewEncoder(w).Encode(apierrors.NewInternalError(fmt.Errorf("nope"))) case 3:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 29 15:48:39 UTC 2023 - 25.8K 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.NewServerTimeout(schema.GroupResource{}, "fake server timeout", 1), }, { name: "patch node when the service is unavailable", lookupName: "testnode", node: v1.Node{ ObjectMeta: metav1.ObjectMeta{
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/endpoints/apiserver_test.go
} } func TestGetRetryAfter(t *testing.T) { storage := map[string]rest.Storage{} simpleStorage := SimpleRESTStorage{ errors: map[string]error{"get": apierrors.NewServerTimeout(schema.GroupResource{Resource: "simples"}, "id", 2)}, } storage["simple"] = &simpleStorage handler := handle(storage) server := httptest.NewServer(handler) defer server.Close()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 01 20:15:22 UTC 2023 - 158.7K bytes - Viewed (0)