- Sort Score
- Result 10 results
- Languages All
Results 21 - 27 of 27 for requestTimeout (0.18 sec)
-
cmd/kube-apiserver/app/options/options_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 17:57:37 UTC 2024 - 12.7K bytes - Viewed (0) -
pkg/wasm/convert.go
timeout = remote.GetHttpUri().Timeout.AsDuration() } f, err := cache.Get(httpURI.GetUri(), GetOptions{ Checksum: remote.Sha256, ResourceName: resourceName, ResourceVersion: resourceVersion, RequestTimeout: timeout, PullSecret: pullSecret, PullPolicy: pullPolicy, }) if err != nil { *status = fetchFailure return fmt.Errorf("cannot fetch Wasm module %v: %w", remote.GetHttpUri().GetUri(), err)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 20:06:41 UTC 2024 - 13.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/config_test.go
// avoid nil panics NonLongRunningRequestWaitGroup: &waitgroup.SafeWaitGroup{}, RequestInfoResolver: &request.RequestInfoFactory{}, RequestTimeout: 10 * time.Second, LongRunningFunc: func(_ *http.Request, _ *request.RequestInfo) bool { return false }, lifecycleSignals: newLifecycleSignals(),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 18:59:21 UTC 2024 - 13.1K bytes - Viewed (0) -
pkg/wasm/cache.go
var dChecksum string // Hex-Encoded sha256 checksum of binary. var binaryFetcher func() ([]byte, error) insecure := c.allowInsecure(u.Host) ctx, cancel := context.WithTimeout(context.Background(), opts.RequestTimeout) defer cancel() switch u.Scheme { case "http", "https": // Download the Wasm module with http fetcher. b, err = c.httpFetcher.Fetch(ctx, key.downloadURL, insecure) if err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 20:06:41 UTC 2024 - 13.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/genericapiserver.go
// wait for the delayed stopCh before closing the handler chain (it rejects everything after Wait has been called). <-notAcceptingNewRequestCh.Signaled() // Wait for all requests to finish, which are bounded by the RequestTimeout variable. // once NonLongRunningRequestWaitGroup.Wait is invoked, the apiserver is // expected to reject any incoming request with a {503, Retry-After}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 18:59:21 UTC 2024 - 42.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/filters/priority-and-fairness_test.go
// a real apiserver. // the specified user is added as the authenticated user to the request context. func newHandlerChain(t *testing.T, handler http.Handler, filter utilflowcontrol.Interface, userName string, requestTimeout time.Duration) http.Handler { requestInfoFactory := &apirequest.RequestInfoFactory{APIPrefixes: sets.NewString("apis", "api"), GrouplessAPIPrefixes: sets.NewString("api")}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:40 UTC 2023 - 52.6K bytes - Viewed (0) -
cmd/api-errors.go
Description: "Cannot respond to plain-text request from TLS-encrypted server", HTTPStatusCode: http.StatusBadRequest, }, ErrRequestTimedout: { Code: "RequestTimeout", Description: "A timeout occurred while trying to lock a resource, please reduce your request rate", HTTPStatusCode: http.StatusServiceUnavailable, }, ErrClientDisconnected: {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 22:26:38 UTC 2024 - 92.1K bytes - Viewed (1)