- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 480 for Pods (0.06 sec)
-
staging/src/k8s.io/client-go/applyconfigurations/autoscaling/v2/metricstatus.go
return b } // WithPods sets the Pods field in the declarative configuration to the given value // and returns the receiver, so that objects can be built by chaining "With" function invocations. // If called multiple times, the Pods field is set to the value of the last call. func (b *MetricStatusApplyConfiguration) WithPods(value *PodsMetricStatusApplyConfiguration) *MetricStatusApplyConfiguration { b.Pods = value return b }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Nov 09 02:34:54 UTC 2021 - 4.2K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/populator/desired_state_of_world_populator.go
pods, err := dswp.podLister.List(labels.Everything()) if err != nil { logger.Error(err, "PodLister List failed") return } dswp.timeOfLastListPods = time.Now() for _, pod := range pods { if volutil.IsPodTerminated(pod, pod.Status) { // Do not add volumes for terminated pods continue } util.ProcessPodVolumes(logger, pod, true,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 00:37:30 UTC 2023 - 7.7K bytes - Viewed (0) -
pkg/config/analysis/analyzers/sidecar/selector.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun May 05 03:44:57 UTC 2024 - 5K bytes - Viewed (0) -
pkg/test/framework/components/istio/util.go
) ([]any, bool, error) { if !s.LoadBalancerSupported { pods, err := cluster.PodsForSelector(context.TODO(), ns, label) if err != nil { return nil, false, err } names := make([]string, 0, len(pods.Items)) for _, p := range pods.Items { names = append(names, p.Name) } scopes.Framework.Debugf("Querying remote service %s, pods:%v", svcName, names) if len(pods.Items) == 0 {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Feb 29 17:13:34 UTC 2024 - 4.7K bytes - Viewed (0) -
pkg/kubelet/apis/podresources/server_v1.go
} // NewV1PodResourcesServer returns a PodResourcesListerServer which lists pods provided by the PodsProvider // with device information provided by the DevicesProvider func NewV1PodResourcesServer(providers PodResourcesProviders) podresourcesv1.PodResourcesListerServer { return &v1PodResourcesServer{ podsProvider: providers.Pods, devicesProvider: providers.Devices, cpusProvider: providers.Cpus,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 21 13:00:09 UTC 2024 - 6.2K bytes - Viewed (0) -
pkg/scheduler/framework/listers.go
// List returns the list of NodeInfos. List() ([]*NodeInfo, error) // HavePodsWithAffinityList returns the list of NodeInfos of nodes with pods with affinity terms. HavePodsWithAffinityList() ([]*NodeInfo, error) // HavePodsWithRequiredAntiAffinityList returns the list of NodeInfos of nodes with pods with required anti-affinity terms. HavePodsWithRequiredAntiAffinityList() ([]*NodeInfo, error) // Get returns the NodeInfo of the given node name.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 04 01:00:41 UTC 2022 - 1.6K bytes - Viewed (0) -
pkg/controller/job/backoff_utils.go
backoff.lastFailureTime = &failedTime } backoff.failuresAfterLastSuccess += 1 } return *backoff } } func sortByFinishedTime(pods []*v1.Pod) { sort.Slice(pods, func(i, j int) bool { p1 := pods[i] p2 := pods[j] p1FinishTime := getFinishedTime(p1) p2FinishTime := getFinishedTime(p2) return p1FinishTime.Before(p2FinishTime) }) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 07:46:41 UTC 2024 - 8.3K bytes - Viewed (0) -
pkg/scheduler/metrics/resources/resources.go
pods, err := c.lister.List(labels.Everything()) if err != nil { return } reuseReqs, reuseLimits := make(v1.ResourceList, 4), make(v1.ResourceList, 4) for _, p := range pods { reqs, limits, terminal := podRequestsAndLimitsByLifecycle(p, reuseReqs, reuseLimits) if terminal { // terminal pods are excluded from resource usage calculations continue }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 09 23:15:53 UTC 2023 - 6.8K bytes - Viewed (0) -
operator/cmd/mesh/testdata/operator/output/operator-dump.json
], "resources": [ "configmaps", "endpoints", "events", "namespaces", "pods", "pods/proxy", "pods/portforward", "persistentvolumeclaims", "secrets", "services", "serviceaccounts", "resourcequotas"
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 10 01:35:08 UTC 2023 - 4.1K bytes - Viewed (0) -
staging/src/k8s.io/client-go/applyconfigurations/autoscaling/v2/metricspec.go
return b } // WithPods sets the Pods field in the declarative configuration to the given value // and returns the receiver, so that objects can be built by chaining "With" function invocations. // If called multiple times, the Pods field is set to the value of the last call. func (b *MetricSpecApplyConfiguration) WithPods(value *PodsMetricSourceApplyConfiguration) *MetricSpecApplyConfiguration { b.Pods = value return b }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Nov 09 02:34:54 UTC 2021 - 4.2K bytes - Viewed (0)