- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 338 for podB (0.04 sec)
-
pkg/controller/podautoscaler/replica_calculator.go
ignoredPods.Insert(pod.Name) continue } // Pending pods are ignored. if pod.Status.Phase == v1.PodPending { unreadyPods.Insert(pod.Name) continue } // Pods missing metrics. metric, found := metrics[pod.Name] if !found { missingPods.Insert(pod.Name) continue } // Unready pods are ignored. if resource == v1.ResourceCPU { var unready bool
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Aug 19 03:31:34 UTC 2023 - 20.1K bytes - Viewed (0) -
cmd/kubeadm/app/util/marshal_test.go
} pod2, ok := obj2.(*corev1.Pod) if !ok { t.Fatal("did not get a Pod") } if pod2.Name != pod.Name { t.Errorf("expected %q, got %q", pod.Name, pod2.Name) } if pod2.Namespace != pod.Namespace { t.Errorf("expected %q, got %q", pod.Namespace, pod2.Namespace) } if !reflect.DeepEqual(pod2.Labels, pod.Labels) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Feb 29 05:14:21 UTC 2024 - 11.6K bytes - Viewed (0) -
pkg/scheduler/internal/cache/cache.go
key, err := framework.GetPodKey(pod) if err != nil { return err } cache.mu.Lock() defer cache.mu.Unlock() currState, ok := cache.podStates[key] if ok && currState.pod.Spec.NodeName != pod.Spec.NodeName { return fmt.Errorf("pod %v(%v) was assumed on %v but assigned to %v", key, klog.KObj(pod), pod.Spec.NodeName, currState.pod.Spec.NodeName) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 24 09:56:48 UTC 2023 - 24.9K bytes - Viewed (0) -
pkg/controller/tainteviction/taint_eviction.go
getPodsAssignedToNode: func(nodeName string) ([]*v1.Pod, error) { objs, err := podIndexer.ByIndex("spec.nodeName", nodeName) if err != nil { return nil, err } pods := make([]*v1.Pod, 0, len(objs)) for _, obj := range objs { pod, ok := obj.(*v1.Pod) if !ok { continue } pods = append(pods, pod) } return pods, nil }, taintedNodes: make(map[string][]v1.Taint),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 19.9K bytes - Viewed (0) -
cni/pkg/repair/repair_test.go
c := &Controller{cfg: tt.config} assert.Equal(t, c.matchesFilter(tt.pod), tt.want) }) } } func fakeClient(pods ...*corev1.Pod) kube.Client { var csPods []runtime.Object for _, pod := range pods { csPods = append(csPods, pod.DeepCopy()) } return kube.NewFakeClient(csPods...) } func makePodLabelMap(pods []*corev1.Pod) (podmap map[string]string) { podmap = map[string]string{}
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Oct 24 03:31:28 UTC 2023 - 10.6K bytes - Viewed (0) -
staging/src/k8s.io/api/autoscaling/v2beta1/generated.proto
// resource metric across all relevant pods, represented as a percentage of // the requested value of the resource for the pods. // +optional optional int32 targetAverageUtilization = 2; // targetAverageValue is the target value of the average of the // resource metric across all relevant pods, as a raw value (instead of as // a percentage of the request), similar to the "pods" metric source type. // +optional
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 28 15:34:11 UTC 2024 - 21.3K bytes - Viewed (0) -
pkg/scheduler/framework/interface.go
// to a map of currently waiting pods and return status with "Wait" code. // Pod will remain waiting pod for the minimum duration returned by the Permit plugins. RunPermitPlugins(ctx context.Context, state *CycleState, pod *v1.Pod, nodeName string) *Status // WaitOnPermit will block, if the pod is a waiting pod, until the waiting pod is rejected or allowed.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 15:52:16 UTC 2024 - 35.4K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/noderesources/requested_to_capacity_ratio_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Dec 15 03:30:06 UTC 2023 - 21.2K bytes - Viewed (0) -
pkg/kubelet/metrics/metrics.go
) // ActivePodCount tracks the count of pods the Kubelet considers as active when deciding to admit a new pod ActivePodCount = metrics.NewGaugeVec( &metrics.GaugeOpts{ Subsystem: KubeletSubsystem, Name: ActivePodCountKey, Help: "The number of pods the kubelet considers active and which are being considered when admitting new pods. static is true if the pod is not from the apiserver.",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Feb 22 15:13:25 UTC 2024 - 45.6K 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)