- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for NewServerTimeout (0.37 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) -
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) -
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)