- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 99 for chanOf (0.14 sec)
-
pkg/controller/garbagecollector/garbagecollector_test.go
// Wait until sync discovers the change time.Sleep(1 * time.Second) // Deployments monitor kept assertMonitors(t, gc, "pods", "deployments", "secrets") // Put the resources back to normal and ensure garbage collector sync recovers fakeDiscoveryClient.setPreferredResources(serverResources, nil) // Wait until sync discovers the change time.Sleep(1 * time.Second)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 111.6K bytes - Viewed (0) -
src/database/sql/sql_test.go
db.SetConnMaxLifetime(10 * time.Second) conn, err := db.conn(ctx, alwaysNewConn) if err != nil { t.Fatal(err) } afterPutConn := make(chan struct{}) waitingForConn := make(chan struct{}) go func() { defer close(afterPutConn) conn, err := db.conn(ctx, alwaysNewConn) if err == nil { db.putConn(conn, err, false) } else {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 18:42:28 UTC 2024 - 111.6K bytes - Viewed (0) -
pkg/kubelet/kubelet.go
// containers have failed health checks func (kl *Kubelet) syncLoopIteration(ctx context.Context, configCh <-chan kubetypes.PodUpdate, handler SyncHandler, syncCh <-chan time.Time, housekeepingCh <-chan time.Time, plegCh <-chan *pleg.PodLifecycleEvent) bool { select { case u, open := <-configCh: // Update from a config source; dispatch it to the right handler // callback.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 126.1K bytes - Viewed (0) -
pkg/proxy/nftables/proxier_test.go
expectedNewlyActiveUDPServices: map[proxy.ServicePortName]bool{}, expectedLocalEndpoints: map[types.NamespacedName]int{}, }, { // Case[1]: no change, named port, local name: "no change, named port, local", previousEndpoints: namedPortLocal, currentEndpoints: namedPortLocal, oldEndpoints: map[proxy.ServicePortName][]endpointExpectation{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Apr 27 01:31:57 UTC 2024 - 173.5K bytes - Viewed (0) -
tensorflow/compiler/jit/extract_outside_compilation_pass.cc
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Tue Mar 12 06:33:33 UTC 2024 - 104.7K bytes - Viewed (0) -
pkg/controller/podautoscaler/horizontal_test.go
assert.True(t, tc.statusUpdated, "the status should have been updated") if tc.verifyEvents { assert.Equal(t, tc.specReplicas != tc.expectedDesiredReplicas, tc.eventCreated, "an event should have been created only if we expected a change in replicas") } tc.verifyRecordedMetric(t, m) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 14:24:16 UTC 2024 - 199.3K bytes - Viewed (0) -
api/openapi-spec/v3/apis__policy__v1_openapi.json
means that all running pods (status.phase=\"Running\"), but not yet healthy are considered disrupted and can be evicted regardless of whether the criteria in a PDB is met. This means perspective running pods of a disrupted application might not get a chance to become healthy. Healthy pods will be subject to the PDB for eviction.\n\nAdditional policies may be added in the future. Clients making eviction decisions should disallow eviction of unhealthy pods if they encounter an unrecognized policy in this...
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 08 04:18:56 UTC 2024 - 159.9K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/strategicpatch/patch_test.go
retainKeysMap: name: foo twoWay: retainKeysMap: value: bar modified: retainKeysMap: name: foo value: bar - description: retainKeys map can change a field when no retainKeys directive present original: retainKeysMap: name: foo value: a twoWay: retainKeysMap: value: b modified: retainKeysMap:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 31 16:45:45 UTC 2023 - 130.4K bytes - Viewed (0) -
api/openapi-spec/v3/apis__events.k8s.io__v1_openapi.json
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 08 04:18:56 UTC 2024 - 142.7K bytes - Viewed (0) -
cmd/metrics-v2.go
func (c *minioBucketCollector) Describe(ch chan<- *prometheus.Desc) { ch <- c.desc } // Collect is called by the Prometheus registry when collecting metrics. func (c *minioBucketCollector) Collect(out chan<- prometheus.Metric) { var wg sync.WaitGroup publish := func(in <-chan MetricV2) { defer wg.Done() for metric := range in {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 22:26:54 UTC 2024 - 131.9K bytes - Viewed (0)