Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for activePods (0.16 sec)

  1. 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)
  2. 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)
  3. 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)
  4. pkg/kubelet/cm/qos_container_manager_linux_test.go

    		subsystems:    subsystems,
    		cgroupManager: NewCgroupManager(subsystems, "cgroupfs"),
    		cgroupRoot:    cgroupRoot,
    		qosReserved:   nil,
    	}
    
    	qosContainerManager.activePods = activeTestPods
    
    	return qosContainerManager, nil
    }
    
    func TestQoSContainerCgroup(t *testing.T) {
    	m, err := createTestQOSContainerManager()
    	assert.Nil(t, err)
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Aug 24 19:47:49 UTC 2021
    - 4K bytes
    - Viewed (0)
  5. 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)
  6. 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)
  7. 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)
Back to top