- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 1,369 for Pods (0.14 sec)
-
tests/integration/pilot/cni_race_test.go
retry.UntilSuccessOrFail(t, func() error { pods, err := cluster.Kube().CoreV1().Pods(ns.Name()).List(context.TODO(), metav1.ListOptions{}) if err != nil { return err } if len(pods.Items) == 0 { return fmt.Errorf("still waiting the pod in namespace %v to start", ns.Name()) } // Verify that at least one pod is in broken state due to the race condition. for _, p := range pods.Items {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 09 16:52:52 UTC 2024 - 6.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/selection_predicate_test.go
Path: "/api/v1/namespaces/default/pods", Verb: "list", APIPrefix: "api", APIGroup: "", APIVersion: "v1", Namespace: "default", Resource: "pods", }), expected: []MatchValue{{IndexName: FieldIndex("metadata.namespace"), Value: "kube-system"}}, }, "Match field for listing all pods without metadata.namespace field selector": {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Nov 30 10:39:09 UTC 2023 - 8.6K bytes - Viewed (0) -
cni/pkg/repair/repaircontroller.go
patchBytes := fmt.Sprintf(`{"metadata":{"labels":{%q:%q}}}`, c.cfg.LabelKey, c.cfg.LabelValue) // Both "pods" and "pods/status" can mutate the metadata. However, pods/status is lower privilege, so we use that instead. _, err := c.client.Kube().CoreV1().Pods(pod.Namespace).Patch(context.Background(), pod.Name, types.MergePatchType, []byte(patchBytes), metav1.PatchOptions{}, "status") if err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Feb 10 00:31:55 UTC 2024 - 10.4K bytes - Viewed (0) -
pkg/kubelet/volumemanager/populator/desired_state_of_world_populator.go
podName volumetypes.UniquePodName) bool { dswp.pods.RLock() defer dswp.pods.RUnlock() return dswp.pods.processedPods[podName] } // markPodProcessingFailed marks the specified pod from processedPods as false to indicate that it failed processing func (dswp *desiredStateOfWorldPopulator) markPodProcessingFailed( podName volumetypes.UniquePodName) { dswp.pods.Lock() dswp.pods.processedPods[podName] = false dswp.pods.Unlock()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 11 09:02:45 UTC 2024 - 23.8K bytes - Viewed (0) -
pkg/controller/job/metrics/metrics.go
// are satisfied and the number of active Pods matches expectations (i.e. no // pod creation/deletions issued in this sync). This is expected to be the // action in most of the syncs. JobSyncActionTracking = "tracking" // JobSyncActionPodsCreated when the controller creates Pods. This can happen // when the number of active Pods is less than the wanted Job parallelism. JobSyncActionPodsCreated = "pods_created"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 05 17:25:15 UTC 2024 - 8.3K bytes - Viewed (0) -
pkg/kubelet/runonce.go
klog.InfoS("Processing manifest with pods", "numPods", len(u.Pods)) result, err := kl.runOnce(ctx, u.Pods, runOnceRetryDelay) klog.InfoS("Finished processing pods", "numPods", len(u.Pods)) return result, err case <-time.After(runOnceManifestDelay): return nil, fmt.Errorf("no pod manifest update after %v", runOnceManifestDelay) } } // runOnce runs a given set of pods and returns their status.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Aug 04 06:56:50 UTC 2023 - 5.9K bytes - Viewed (0) -
pkg/kube/controllers/example_test.go
// * if we have multiple resources watched, they are not handled in parallel // * errors can be retried c.queue = controllers.NewQueue("pods", controllers.WithReconciler(c.Reconcile), controllers.WithMaxAttempts(5)) // Register a handler for pods. For each pod event, we will add it to the queue. c.pods.AddEventHandler(controllers.ObjectHandler(c.queue.AddObject)) return c }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 7K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/noderesources/balanced_allocation_test.go
expectedList: []framework.NodeScore{{Name: "node2", Score: framework.MaxNodeScore}, {Name: "node2", Score: framework.MaxNodeScore}}, name: "no resources requested, pods without container scheduled", pods: []*v1.Pod{ st.MakePod().Node("node1").Labels(labels2).Obj(), st.MakePod().Node("node1").Labels(labels1).Obj(), st.MakePod().Node("node2").Labels(labels1).Obj(),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Dec 15 03:30:06 UTC 2023 - 15.9K bytes - Viewed (0) -
pkg/apis/autoscaling/types.go
// used by the autoscaler to control how often the number of pods is changed. // +optional LastScaleTime *metav1.Time // CurrentReplicas is current number of replicas of pods managed by this autoscaler, // as last seen by the autoscaler. CurrentReplicas int32 // DesiredReplicas is the desired number of replicas of pods managed by this autoscaler,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 27 23:13:24 UTC 2023 - 23.8K bytes - Viewed (0) -
pkg/client/tests/listwatch_test.go
location: buildLocation( "/api/v1/pods", buildQueryValues(url.Values{fieldSelectorQueryParamName: []string{"spec.host="}})), resource: "pods", namespace: metav1.NamespaceAll, fieldSelector: fields.Set{"spec.host": ""}.AsSelector(), }, { desc: "pod in namespace 'foo'", location: buildLocation( "/api/v1/namespaces/foo/pods",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 02 17:08:23 UTC 2022 - 5.6K bytes - Viewed (0)