- Sort Score
- Result 10 results
- Languages All
Results 131 - 140 of 1,369 for Pods (0.39 sec)
-
pkg/kubelet/types/pod_update.go
SET PodOperation = iota // ADD signifies pods that are new to this source. ADD // DELETE signifies pods that are gracefully deleted from this source. DELETE // REMOVE signifies pods that have been removed from this source. REMOVE // UPDATE signifies pods have been updated in this source. UPDATE // RECONCILE signifies pods that have unexpected status in this source,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 07 22:26:12 UTC 2023 - 6.4K bytes - Viewed (0) -
pkg/kubelet/util/pod_startup_latency_tracker_test.go
wants := "" metrics.Register() tracker := &basicPodStartupLatencyTracker{ pods: map[types.UID]*perPodState{}, } if err := testutil.GatherAndCompare(metrics.GetGather(), strings.NewReader(wants), metricsName); err != nil { t.Fatal(err) } assert.Empty(t, tracker.pods) metrics.PodStartSLIDuration.Reset() }) } func TestPodsRunningBeforeKubeletStarted(t *testing.T) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 15 06:09:49 UTC 2023 - 13.7K bytes - Viewed (0) -
pkg/controller/disruption/disruption_test.go
pods := []*v1.Pod{} for i := int32(0); i < 4; i++ { ps.VerifyPdbStatus(t, pdbName, 0, i, 3, i, map[string]metav1.Time{}) pod, _ := newPod(t, fmt.Sprintf("yo-yo-yo %d", i)) pods = append(pods, pod) add(t, dc.podStore, pod) dc.sync(ctx, pdbName) } ps.VerifyPdbStatus(t, pdbName, 1, 4, 3, 4, map[string]metav1.Time{}) // Now set one pod as unavailable pods[0].Status.Conditions = []v1.PodCondition{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 50K bytes - Viewed (0) -
cmd/kubeadm/app/util/apiclient/wait.go
pods, err := w.client.CoreV1().Pods(metav1.NamespaceSystem).List(context.TODO(), listOpts) if err != nil { fmt.Fprintf(w.writer, "[apiclient] Error getting Pods with label selector %q [%v]\n", kvLabel, err) return false, nil } if lastKnownPodNumber != len(pods.Items) { fmt.Fprintf(w.writer, "[apiclient] Found %d Pods for label selector %s\n", len(pods.Items), kvLabel)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 01 07:10:31 UTC 2024 - 13.3K bytes - Viewed (0) -
plugin/pkg/auth/authorizer/rbac/bootstrappolicy/testdata/controller-roles.yaml
- "" resources: - nodes verbs: - list - watch - apiGroups: - "" resources: - pods verbs: - create - delete - list - patch - watch - apiGroups: - "" resources: - pods/binding verbs: - create - apiGroups: - apps resources: - controllerrevisions verbs:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 26.6K bytes - Viewed (0) -
plugin/pkg/admission/priority/admission_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 03 18:43:48 UTC 2022 - 21.2K bytes - Viewed (0) -
pkg/scheduler/framework/preemption/preemption.go
nodeInfoCopy := potentialNodes[(int(offset)+i)%len(potentialNodes)].Snapshot() stateCopy := ev.State.Clone() pods, numPDBViolations, status := ev.SelectVictimsOnNode(ctx, stateCopy, pod, nodeInfoCopy, pdbs) if status.IsSuccess() && len(pods) != 0 { victims := extenderv1.Victims{ Pods: pods, NumPDBViolations: int64(numPDBViolations), } c := &candidate{ victims: &victims,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 15:52:16 UTC 2024 - 25.1K bytes - Viewed (0) -
staging/src/k8s.io/api/autoscaling/v2beta2/types.go
// pods refers to a metric describing each pod in the current scale target // (for example, transactions-processed-per-second). The values will be // averaged together before being compared to the target value. // +optional Pods *PodsMetricSource `json:"pods,omitempty" protobuf:"bytes,3,opt,name=pods"` // resource refers to a resource metric (such as those specified in
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Nov 27 20:06:27 UTC 2023 - 28.4K bytes - Viewed (0) -
pkg/scheduler/metrics/resources/resources_test.go
) type fakePodLister struct { pods []*v1.Pod } func (l *fakePodLister) List(selector labels.Selector) (ret []*v1.Pod, err error) { return l.pods, nil } func (l *fakePodLister) Pods(namespace string) corelisters.PodNamespaceLister { panic("not implemented") } func Test_podResourceCollector_Handler(t *testing.T) { h := Handler(&fakePodLister{pods: []*v1.Pod{ {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 13 07:42:19 UTC 2023 - 21.6K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/volumerestrictions/volume_restrictions.go
// - GCE PD allows multiple mounts as long as they're all read-only // - AWS EBS forbids any two pods mounting the same volume ID // - Ceph RBD forbids if any two pods share at least same monitor, and match pool and image, and the image is read-only // - ISCSI forbids if any two pods share at least same IQN and ISCSI volume is read-only // If the pod uses PVCs with the ReadWriteOncePod access mode, it evaluates if
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 20 17:40:39 UTC 2023 - 12.5K bytes - Viewed (0)