- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 67 for spent (0.05 sec)
-
common-protos/k8s.io/apimachinery/pkg/apis/meta/v1/generated.proto
// In that case, the watch stream will begin with synthetic events to // produce the current state of objects in the collection. Once all such // events have been sent, a synthetic "Bookmark" event will be sent. // The bookmark will report the ResourceVersion (RV) corresponding to the // set of objects, and be marked with `"k8s.io/initial-events-end": "true"` annotation.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Mar 11 18:43:24 UTC 2024 - 53.3K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/apis/meta/v1/generated.proto
// In that case, the watch stream will begin with synthetic events to // produce the current state of objects in the collection. Once all such // events have been sent, a synthetic "Bookmark" event will be sent. // The bookmark will report the ResourceVersion (RV) corresponding to the // set of objects, and be marked with `"k8s.io/initial-events-end": "true"` annotation.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 28 15:34:11 UTC 2024 - 53.7K bytes - Viewed (0) -
cmd/test-utils_test.go
// need a sample HTTP request to be sent as argument so that the relevant handler is called, the handler registration is expected // to be done since its called from within the API handler tests, the reference to the registered HTTP handler has to be sent // as an argument.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:50:49 UTC 2024 - 76.9K bytes - Viewed (0) -
tests/integration/ambient/baseline_test.go
from.CallOrFail(t, echo.CallOptions{ Address: "111.111.222.222", Port: to.PortForName("http"), // If request is sent before service is processed it will hit 10s timeout, so fail faster Timeout: time.Millisecond * 500, }) }) }) } } }) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 00:07:28 UTC 2024 - 78.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/filters/priority-and-fairness_test.go
server, requestGetter := newHTTP2ServerWithClient(handler, time.Minute) defer server.Close() // This test involves two requests sent to the same priority level, which has 1 queue and // a concurrency limit of 1. The handler chain include the timeout filter. // Each request is sent from a separate goroutine, with a client-side timeout of 1m, on // the other hand, the server enforces a timeout of 5s (via the timeout filter).
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:40 UTC 2023 - 52.6K bytes - Viewed (0) -
pkg/controller/podautoscaler/horizontal.go
return } // Requests are always added to queue with resyncPeriod delay. If there's already // request for the HPA in the queue then a new request is always dropped. Requests spend resync // interval in queue so HPAs are processed every resync interval. a.queue.AddRateLimited(key) // Register HPA in the hpaSelectors map if it's not present yet. Attaching the Nothing selector
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 63.6K bytes - Viewed (0) -
pkg/controller/endpoint/endpoints_controller_test.go
waitForChanReceive(t, 1*time.Second, blockNextAction, "Service Add should have caused a request to be sent to the test server") controller.serviceStore.Delete(svc) controller.onServiceDelete(svc) waitForChanReceive(t, 1*time.Second, blockNextAction, "Service Delete should have caused a request to be sent to the test server") // If endpoints cache has not updated before service update is registered
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 06:51:56 UTC 2024 - 87.7K bytes - Viewed (0) -
src/net/http/transport.go
// "Idempotency-Key" or "X-Idempotency-Key" entry. If the idempotency key // value is a zero-length slice, the request is treated as idempotent but the // header is not sent on the wire. type Transport struct { idleMu sync.Mutex closeIdle bool // user has requested to close all idle conns
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jun 06 21:59:21 UTC 2024 - 91K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/testing/watcher_tests.go
} } w.Stop() testCheckStop(t, w) }) } } // RunOptionalTestWatchDispatchBookmarkEvents tests whether bookmark events are sent. // This feature is currently implemented in watch cache layer, so this is optional. // // TODO(#109831): ProgressNotify feature is effectively implementing the same //
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 63.8K bytes - Viewed (0) -
pkg/kubelet/pod_workers.go
func (p *podWorkers) ShouldPodRuntimeBeRemoved(uid types.UID) bool { p.podLock.Lock() defer p.podLock.Unlock() if status, ok := p.podSyncStatuses[uid]; ok { return status.IsTerminated() } // a pod that hasn't been sent to the pod worker yet should have no runtime components once we have // synced all content. return p.podsSynced } func (p *podWorkers) ShouldPodContentBeRemoved(uid types.UID) bool { p.podLock.Lock()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 02 13:22:37 UTC 2024 - 74.8K bytes - Viewed (0)