- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 42 for waitc (1.1 sec)
-
api/openapi-spec/v3/apis__coordination.k8s.io__v1_openapi.json
"type": "string" }, "leaseDurationSeconds": { "description": "leaseDurationSeconds is a duration that candidates for a lease need to wait to force acquire it. This is measure against time of last observed renewTime.", "format": "int32", "type": "integer" }, "leaseTransitions": {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 08 04:18:56 UTC 2024 - 136.6K bytes - Viewed (0) -
pkg/scheduler/internal/queue/scheduling_queue_test.go
if len(q.nominator.nominatedPods["node1"]) != 1 { t.Errorf("Expected medPriorityPodInfo to be present in nomindatePods: %v", q.nominator.nominatedPods["node1"]) } }() q.Add(logger, medPriorityPodInfo.Pod) wg.Wait() } func TestPriorityQueue_Update(t *testing.T) { c := testingclock.NewFakeClock(time.Now()) queuePlugin := "queuePlugin" skipPlugin := "skipPlugin" queueingHintMap := QueueingHintMapPerProfile{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 146.9K bytes - Viewed (0) -
pilot/pkg/networking/core/cluster_builder_test.go
model.TrafficDirectionOutbound, "v1", "foo.com", 8080, service, dr, ) eps := eb.FromServiceEndpoints() mu.Lock() actual = eps mu.Unlock() wg.Done() }() } wg.Wait() sortEndpoints(actual) if v := cmp.Diff(expected, actual, protocmp.Transform()); v != "" { t.Fatalf("Expected (-) != actual (+):\n%s", v) } } func TestBuildPassthroughClusters(t *testing.T) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 110.4K bytes - Viewed (0) -
src/reflect/all_test.go
i := x.Choose(len(cases)) j := x.Choose(len(cases)) cases[i], cases[j] = cases[j], cases[i] info[i], info[j] = info[j], info[i] } if helper != nil { // We wait before kicking off a goroutine to satisfy a blocked select. // The pause needs to be big enough to let the select block before // we run the helper, but if we lose that race once in a while it's okay: the
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 218.8K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ClosingFuture.java
} checkState(whenClosed == null); return whenClosed = new CountDownLatch(1); } } } /** * Returns an object that can be used to wait until this objects' deferred closeables have all had * {@link Runnable}s that close them submitted to each one's closing {@link Executor}. */ @VisibleForTesting CountDownLatch whenClosedCountDown() {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue May 07 12:37:15 UTC 2024 - 98.3K bytes - Viewed (0) -
doc/go1.17_spec.html
immediately, yielding the element type's <a href="#The_zero_value">zero value</a> after any previously sent values have been received. </p> <pre> v1 := <-ch v2 = <-ch f(<-ch) <-strobe // wait until clock pulse and discard received value </pre> <p> A receive expression used in an <a href="#Assignments">assignment</a> or initialization of the special form </p> <pre> x, ok = <-ch
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Apr 11 20:22:45 UTC 2024 - 211.6K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/ClosingFuture.java
} checkState(whenClosed == null); return whenClosed = new CountDownLatch(1); } } } /** * Returns an object that can be used to wait until this objects' deferred closeables have all had * {@link Runnable}s that close them submitted to each one's closing {@link Executor}. */ @VisibleForTesting CountDownLatch whenClosedCountDown() {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Apr 01 16:15:01 UTC 2024 - 98.7K bytes - Viewed (0) -
api/openapi-spec/v3/apis__storage.k8s.io__v1alpha1_openapi.json
"description": "If specified, the time in seconds before the operation should be retried. Some errors may indicate the client must take an alternate action - for those errors this field may indicate how long to wait before taking the alternate action.", "format": "int32", "type": "integer" }, "uid": {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 08 04:18:56 UTC 2024 - 117.5K bytes - Viewed (0) -
api/openapi-spec/v3/apis__scheduling.k8s.io__v1_openapi.json
"description": "If specified, the time in seconds before the operation should be retried. Some errors may indicate the client must take an alternate action - for those errors this field may indicate how long to wait before taking the alternate action.", "format": "int32", "type": "integer" }, "uid": {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 08 04:18:56 UTC 2024 - 116.6K bytes - Viewed (0) -
api/openapi-spec/v3/apis__certificates.k8s.io__v1alpha1_openapi.json
"description": "If specified, the time in seconds before the operation should be retried. Some errors may indicate the client must take an alternate action - for those errors this field may indicate how long to wait before taking the alternate action.", "format": "int32", "type": "integer" }, "uid": {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 08 04:18:56 UTC 2024 - 119K bytes - Viewed (0)