- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 635 for pfds (0.05 sec)
-
pkg/scheduler/internal/cache/debugger/comparer.go
} // ComparePods compares actual pods with cached pods. func (c *CacheComparer) ComparePods(pods, waitingPods []*v1.Pod, nodeinfos map[string]*framework.NodeInfo) (missed, redundant []string) { actual := []string{} for _, pod := range pods { actual = append(actual, string(pod.UID)) } cached := []string{} for _, nodeinfo := range nodeinfos { for _, p := range nodeinfo.Pods { cached = append(cached, string(p.Pod.UID))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 29 05:26:32 UTC 2023 - 3.5K bytes - Viewed (0) -
pkg/kubelet/apis/podresources/server_v1alpha1.go
} // List returns information about the resources assigned to pods on the node func (p *v1alpha1PodResourcesServer) List(ctx context.Context, req *v1alpha1.ListPodResourcesRequest) (*v1alpha1.ListPodResourcesResponse, error) { metrics.PodResourcesEndpointRequestsTotalCount.WithLabelValues("v1alpha1").Inc() pods := p.podsProvider.GetPods() podResources := make([]*v1alpha1.PodResources, len(pods)) p.devicesProvider.UpdateAllocatedDevices()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 17:33:01 UTC 2023 - 2.6K bytes - Viewed (0) -
pkg/kubelet/apis/podresources/types.go
// DevicesProvider knows how to provide the devices used by the given container type DevicesProvider interface { // UpdateAllocatedDevices frees any Devices that are bound to terminated pods. UpdateAllocatedDevices() // GetDevices returns information about the devices assigned to pods and containers GetDevices(podUID, containerName string) []*podresourcesapi.ContainerDevices // GetAllocatableDevices returns information about all the devices known to the manager
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 17:33:04 UTC 2023 - 2.6K bytes - Viewed (0) -
pkg/kubelet/config/http.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 01 07:19:44 UTC 2021 - 4.1K bytes - Viewed (0) -
pkg/kubelet/util/pod_startup_latency_tracker.go
delete(p.pods, pod.UID) return } state := p.pods[pod.UID] if state == nil { // create a new record for pod, only if it was not yet acknowledged by the Kubelet // this is required, as we want to log metric only for those pods, that where scheduled // after Kubelet started if pod.Status.StartTime.IsZero() { p.pods[pod.UID] = &perPodState{} } return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 15 06:09:49 UTC 2023 - 5.5K bytes - Viewed (0) -
pkg/kubelet/config/apiserver.go
func newSourceApiserverFromLW(lw cache.ListerWatcher, updates chan<- interface{}) { send := func(objs []interface{}) { var pods []*v1.Pod for _, o := range objs { pods = append(pods, o.(*v1.Pod)) } updates <- kubetypes.PodUpdate{Pods: pods, Op: kubetypes.SET, Source: kubetypes.ApiserverSource} } r := cache.NewReflector(lw, &v1.Pod{}, cache.NewUndeltaStore(send, cache.MetaNamespaceKeyFunc), 0)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 21 19:46:27 UTC 2021 - 2.4K bytes - Viewed (0) -
pkg/config/analysis/analyzers/k8sgateway/workloadselector.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Dec 15 01:19:33 UTC 2023 - 2.8K bytes - Viewed (0) -
staging/src/k8s.io/api/policy/v1beta1/types_swagger_doc_generated.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Aug 07 20:44:13 UTC 2023 - 7.7K bytes - Viewed (0) -
pkg/kubelet/config/common.go
obj, err := runtime.Decode(legacyscheme.Codecs.UniversalDecoder(), data) if err != nil { return false, pods, err } newPods, ok := obj.(*api.PodList) // Check whether the object could be converted to list of pods. if !ok { err = fmt.Errorf("invalid pods list: %#v", obj) return false, pods, err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 03 18:40:48 UTC 2023 - 5.8K bytes - Viewed (0) -
manifests/charts/istio-cni/templates/clusterrole.yaml
verbs: ["create", "patch"] - apiGroups: [""] resources: ["pods"] verbs: ["watch", "get", "list"] {{- if .Values.cni.repair.repairPods }} {{- /* No privileges needed*/}} {{- else if .Values.cni.repair.deletePods }} - apiGroups: [""] resources: ["pods"] verbs: ["delete"] {{- else if .Values.cni.repair.labelPods }} - apiGroups: [""]
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 17 21:52:29 UTC 2024 - 2.3K bytes - Viewed (0)