- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 931 for Pods (0.04 sec)
-
istioctl/pkg/dashboard/dashboard_test.go
ExpectedOutput: "Error: no pods found with selector app=kiali\n", WantException: true, }, { // case 9 Args: strings.Split("prometheus --browser=false", " "), ExpectedOutput: "Error: no pods found with selector app.kubernetes.io/name=prometheus\n", WantException: true, }, { // case 10 Args: strings.Split("zipkin --browser=false", " "), ExpectedOutput: "Error: no pods found with selector app=zipkin\n",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Nov 21 01:17:24 UTC 2023 - 4.3K bytes - Viewed (0) -
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/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/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/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/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) -
operator/pkg/helmreconciler/wait.go
if err != nil { return fmt.Sprintf("failed to get label selector: %v", err) } pods, err := getPods(client, namespace, sel) if err != nil { return fmt.Sprintf("failed to fetch pods: %v", err) } sort.Slice(pods, func(i, j int) bool { return pods[i].CreationTimestamp.After(pods[j].CreationTimestamp.Time) }) for _, pod := range pods { for _, cs := range pod.Status.ContainerStatuses { if cs.State.Waiting != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Dec 08 03:13:12 UTC 2023 - 13.1K bytes - Viewed (0) -
plugin/pkg/auth/authorizer/rbac/bootstrappolicy/policy.go
rbacv1helpers.NewRule(Read...).Groups(legacyGroup).Resources("pods/attach", "pods/proxy", "pods/exec", "pods/portforward", "secrets", "services/proxy").RuleOrDie(), rbacv1helpers.NewRule("impersonate").Groups(legacyGroup).Resources("serviceaccounts").RuleOrDie(), rbacv1helpers.NewRule(Write...).Groups(legacyGroup).Resources("pods", "pods/attach", "pods/proxy", "pods/exec", "pods/portforward").RuleOrDie(),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 08 19:25:10 UTC 2024 - 34.4K bytes - Viewed (0)