Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 13 for GetPodCgroupRoot (0.22 sec)

  1. pkg/kubelet/server/stats/testing/mock_stats_provider.go

    }
    
    // GetPodCgroupRoot mocks base method.
    func (m *MockProvider) GetPodCgroupRoot() string {
    	m.ctrl.T.Helper()
    	ret := m.ctrl.Call(m, "GetPodCgroupRoot")
    	ret0, _ := ret[0].(string)
    	return ret0
    }
    
    // GetPodCgroupRoot indicates an expected call of GetPodCgroupRoot.
    func (mr *MockProviderMockRecorder) GetPodCgroupRoot() *gomock.Call {
    	mr.mock.ctrl.T.Helper()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 08:12:16 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  2. pkg/kubelet/server/stats/summary_sys_containers.go

    		statsapi.SystemContainerMisc:    {name: nodeConfig.SystemCgroupsName, forceStatsUpdate: false},
    		statsapi.SystemContainerPods:    {name: sp.provider.GetPodCgroupRoot(), forceStatsUpdate: updateStats},
    	}
    	for sys, cont := range systemContainers {
    		// skip if cgroup name is undefined (not all system containers are required)
    		if cont.name == "" {
    			continue
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Aug 24 19:47:49 UTC 2021
    - 3.5K bytes
    - Viewed (0)
  3. pkg/kubelet/cm/fake_container_manager.go

    }
    
    func (cm *FakeContainerManager) GetPodCgroupRoot() string {
    	cm.Lock()
    	defer cm.Unlock()
    	cm.CalledFunctions = append(cm.CalledFunctions, "GetPodCgroupRoot")
    	return ""
    }
    
    func (cm *FakeContainerManager) GetDevices(_, _ string) []*podresourcesapi.ContainerDevices {
    	cm.Lock()
    	defer cm.Unlock()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 14 17:33:04 UTC 2023
    - 7.4K bytes
    - Viewed (0)
  4. pkg/kubelet/server/stats/handler.go

    	GetPods() []*v1.Pod
    
    	// RlimitStats returns the rlimit stats of system.
    	RlimitStats() (*statsapi.RlimitStats, error)
    
    	// GetPodCgroupRoot returns the literal cgroupfs value for the cgroup containing all pods
    	GetPodCgroupRoot() string
    
    	// GetPodByCgroupfs provides the pod that maps to the specified cgroup literal, as well
    	// as whether the pod was found.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Dec 14 21:31:38 UTC 2023
    - 6.8K bytes
    - Viewed (0)
  5. pkg/kubelet/server/stats/summary_test.go

    	mockStatsProvider := statstest.NewMockProvider(mockCtrl)
    
    	mockStatsProvider.EXPECT().GetNode().Return(node, nil)
    	mockStatsProvider.EXPECT().GetNodeConfig().Return(nodeConfig)
    	mockStatsProvider.EXPECT().GetPodCgroupRoot().Return(cgroupRoot)
    	mockStatsProvider.EXPECT().ListPodStats(ctx).Return(podStats, nil).AnyTimes()
    	mockStatsProvider.EXPECT().ListPodStatsAndUpdateCPUNanoCoreUsage(ctx).Return(podStats, nil)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 08:12:16 UTC 2024
    - 15.1K bytes
    - Viewed (0)
  6. pkg/kubelet/cm/container_manager.go

    	UpdatePluginResources(*schedulerframework.NodeInfo, *lifecycle.PodAdmitAttributes) error
    
    	InternalContainerLifecycle() InternalContainerLifecycle
    
    	// GetPodCgroupRoot returns the cgroup which contains all pods.
    	GetPodCgroupRoot() string
    
    	// GetPluginRegistrationHandler returns a plugin registration handler
    	// The pluginwatcher's Handlers allow to have a single module for handling
    	// registration.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 21:22:13 UTC 2024
    - 9K bytes
    - Viewed (0)
  7. pkg/kubelet/server/stats/summary_windows_test.go

    	mockStatsProvider := statstest.NewMockProvider(mockCtrl)
    	mockStatsProvider.EXPECT().GetNode().Return(node, nil).AnyTimes()
    	mockStatsProvider.EXPECT().GetNodeConfig().Return(nodeConfig).AnyTimes()
    	mockStatsProvider.EXPECT().GetPodCgroupRoot().Return(cgroupRoot).AnyTimes()
    	mockStatsProvider.EXPECT().ListPodStats(ctx).Return(podStats, nil).AnyTimes()
    	mockStatsProvider.EXPECT().ListPodStatsAndUpdateCPUNanoCoreUsage(ctx).Return(podStats, nil).AnyTimes()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 08:12:16 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  8. pkg/kubelet/cm/container_manager_stub.go

    	return &internalContainerLifecycleImpl{cpumanager.NewFakeManager(), memorymanager.NewFakeManager(), topologymanager.NewFakeManager()}
    }
    
    func (cm *containerManagerStub) GetPodCgroupRoot() string {
    	return ""
    }
    
    func (cm *containerManagerStub) GetDevices(_, _ string) []*podresourcesapi.ContainerDevices {
    	return nil
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 15 02:26:59 UTC 2023
    - 5.9K bytes
    - Viewed (0)
  9. pkg/kubelet/kubelet_getters.go

    func (kl *Kubelet) GetNodeConfig() cm.NodeConfig {
    	return kl.containerManager.GetNodeConfig()
    }
    
    // GetPodCgroupRoot returns the listeral cgroupfs value for the cgroup containing all pods
    func (kl *Kubelet) GetPodCgroupRoot() string {
    	return kl.containerManager.GetPodCgroupRoot()
    }
    
    // GetHostIPs returns host IPs or nil in case of error.
    func (kl *Kubelet) GetHostIPs() ([]net.IP, error) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Mar 09 00:48:07 UTC 2024
    - 17.9K bytes
    - Viewed (0)
  10. pkg/kubelet/cm/container_manager_windows.go

    	return &internalContainerLifecycleImpl{cpumanager.NewFakeManager(), memorymanager.NewFakeManager(), topologymanager.NewFakeManager()}
    }
    
    func (cm *containerManagerImpl) GetPodCgroupRoot() string {
    	return ""
    }
    
    func (cm *containerManagerImpl) GetDevices(podUID, containerName string) []*podresourcesapi.ContainerDevices {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jul 12 11:25:36 UTC 2023
    - 8.7K bytes
    - Viewed (0)
Back to top