- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 591 for Pods (0.32 sec)
-
pkg/kubelet/eviction/eviction_manager.go
case <-timeout.C(): klog.InfoS("Eviction manager: timed out waiting for pods to be cleaned up", "pods", klog.KObjSlice(pods)) return case <-ticker.C(): for i, pod := range pods { if !podCleanedUpFunc(pod) { break } if i == len(pods)-1 { klog.InfoS("Eviction manager: pods successfully cleaned up", "pods", klog.KObjSlice(pods)) return } } } } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 27 18:55:56 UTC 2024 - 24.6K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/cache/desired_state_of_world.go
func getPodsFromMap(podMap map[types.UniquePodName]pod) []*v1.Pod { pods := make([]*v1.Pod, 0, len(podMap)) for _, pod := range podMap { pods = append(pods, pod.podObj) } return pods } func (dsw *desiredStateOfWorld) GetPodToAdd() map[types.UniquePodName]PodToAdd { dsw.RLock() defer dsw.RUnlock() pods := make(map[types.UniquePodName]PodToAdd) for nodeName, nodeObj := range dsw.nodesManaged {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 10:42:15 UTC 2024 - 13.5K bytes - Viewed (0) -
pkg/kubelet/pleg/generic.go
}() // Get all the pods. podList, err := g.runtime.GetPods(ctx, true) if err != nil { klog.ErrorS(err, "GenericPLEG: Unable to retrieve pods") return } g.updateRelistTime(timestamp) pods := kubecontainer.Pods(podList) // update running pod and container count updateRunningPodAndContainerMetrics(pods) g.podRecords.setCurrent(pods)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 19.3K bytes - Viewed (0) -
staging/src/k8s.io/api/autoscaling/v1/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 - 22K bytes - Viewed (0) -
common-protos/k8s.io/api/autoscaling/v1/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: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Mar 11 18:43:24 UTC 2024 - 22K bytes - Viewed (0) -
tools/bug-report/pkg/cluster/cluster_test.go
ObjectMeta: metav1.ObjectMeta{ Name: "in-pod1", }, }, &config2.BugReportConfig{ Include: []*config2.SelectionSpec{ { Pods: []string{"in-"}, }, }, Exclude: []*config2.SelectionSpec{ { Pods: []string{"ex-"}, }, }, }, false, }, { "tested pod name skip", &v1.Pod{ ObjectMeta: metav1.ObjectMeta{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jul 06 17:23:32 UTC 2023 - 11K bytes - Viewed (0) -
staging/src/k8s.io/api/autoscaling/v2/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: Thu May 23 17:42:49 UTC 2024 - 28.5K bytes - Viewed (0) -
staging/src/k8s.io/api/autoscaling/v1/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: Thu May 23 17:42:49 UTC 2024 - 27.8K bytes - Viewed (0) -
istioctl/pkg/injector/injector-list.go
"istio.io/istio/pkg/kube" "istio.io/istio/pkg/kube/inject" "istio.io/istio/pkg/slices" "istio.io/istio/pkg/util/sets" ) type revisionCount struct { // pods in a revision pods int // pods that are disabled from injection disabled int // pods that are enabled for injection, but whose revision doesn't match their namespace's revision needsRestart int } func Cmd(cliContext cli.Context) *cobra.Command {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jan 04 03:08:06 UTC 2024 - 10.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)