- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for activePods (0.26 sec)
-
pkg/kubelet/cm/container_manager_windows.go
func (ra *noopWindowsResourceAllocator) Admit(attrs *lifecycle.PodAdmitAttributes) lifecycle.PodAdmitResult { return admission.GetPodAdmitResult(nil) } func (cm *containerManagerImpl) Start(node *v1.Node, activePods ActivePodsFunc, sourcesReady config.SourcesReady, podStatusProvider status.PodStatusProvider, runtimeService internalapi.RuntimeService, localStorageCapacityIsolation bool) error {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 12 11:25:36 UTC 2023 - 8.7K bytes - Viewed (0) -
pkg/scheduler/metrics/metric_recorder.go
type PendingPodsRecorder struct { recorder metrics.GaugeMetric } // NewActivePodsRecorder returns ActivePods in a Prometheus metric fashion func NewActivePodsRecorder() *PendingPodsRecorder { return &PendingPodsRecorder{ recorder: ActivePods(), } } // NewUnschedulablePodsRecorder returns UnschedulablePods in a Prometheus metric fashion
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Feb 16 07:27:08 UTC 2023 - 4.4K bytes - Viewed (0) -
pkg/kubelet/cm/dra/types.go
type Manager interface { // Start starts the reconcile loop of the manager. // This will ensure that all claims are unprepared even if pods get deleted unexpectedly. Start(activePods ActivePodsFunc, sourcesReady config.SourcesReady) error // PrepareResources prepares resources for a pod. // It communicates with the DRA resource plugin to prepare resources. PrepareResources(pod *v1.Pod) error
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 03 13:23:29 UTC 2024 - 2.1K bytes - Viewed (0) -
pkg/kubelet/cm/cpumanager/fake_cpu_manager.go
"k8s.io/kubernetes/pkg/kubelet/config" "k8s.io/kubernetes/pkg/kubelet/status" "k8s.io/utils/cpuset" ) type fakeManager struct { state state.State } func (m *fakeManager) Start(activePods ActivePodsFunc, sourcesReady config.SourcesReady, podStatusProvider status.PodStatusProvider, containerRuntime runtimeService, initialContainers containermap.ContainerMap) error { klog.InfoS("Start()") return nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 03 16:26:09 UTC 2023 - 2.9K bytes - Viewed (0) -
pkg/kubelet/cm/memorymanager/fake_memory_manager.go
"k8s.io/kubernetes/pkg/kubelet/config" "k8s.io/kubernetes/pkg/kubelet/status" ) type fakeManager struct { state state.State } func (m *fakeManager) Start(activePods ActivePodsFunc, sourcesReady config.SourcesReady, podStatusProvider status.PodStatusProvider, containerRuntime runtimeService, initialContainers containermap.ContainerMap) error { klog.InfoS("Start()") return nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 27 13:02:15 UTC 2023 - 3.1K bytes - Viewed (0) -
pkg/kubelet/cm/devicemanager/types.go
schedulerframework "k8s.io/kubernetes/pkg/scheduler/framework" ) // Manager manages all the Device Plugins running on a node. type Manager interface { // Start starts device plugin registration service. Start(activePods ActivePodsFunc, sourcesReady config.SourcesReady, initialContainers containermap.ContainerMap, initialContainerRunningSet sets.Set[string]) error // Allocate configures and assigns devices to a container in a pod. From
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 27 13:02:15 UTC 2023 - 5K bytes - Viewed (0)