Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 12 for GetNodeConfig (0.19 sec)

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

    }
    
    // GetNodeConfig mocks base method.
    func (m *MockProvider) GetNodeConfig() cm.NodeConfig {
    	m.ctrl.T.Helper()
    	ret := m.ctrl.Call(m, "GetNodeConfig")
    	ret0, _ := ret[0].(cm.NodeConfig)
    	return ret0
    }
    
    // GetNodeConfig indicates an expected call of GetNodeConfig.
    func (mr *MockProviderMockRecorder) GetNodeConfig() *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/handler.go

    	// namespace.
    	GetPodByName(namespace, name string) (*v1.Pod, bool)
    	// GetNode returns the spec of the local node.
    	GetNode() (*v1.Node, error)
    	// GetNodeConfig returns the configuration of the local node.
    	GetNodeConfig() cm.NodeConfig
    	// ListVolumesForPod returns the stats of the volume used by the pod with
    	// the podUID.
    	ListVolumesForPod(podUID types.UID) (map[string]volume.Volume, bool)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Dec 14 21:31:38 UTC 2023
    - 6.8K bytes
    - Viewed (0)
  3. pkg/kubelet/server/stats/summary.go

    	// the following errors occur.
    	node, err := sp.provider.GetNode()
    	if err != nil {
    		return nil, fmt.Errorf("failed to get node info: %v", err)
    	}
    	nodeConfig := sp.provider.GetNodeConfig()
    	rootStats, networkStats, err := sp.provider.GetCgroupStats("/", updateStats)
    	if err != nil {
    		return nil, fmt.Errorf("failed to get root cgroup stats: %v", err)
    	}
    	rootFsStats, err := sp.provider.RootFsStats()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Nov 01 18:46:33 UTC 2023
    - 5.1K bytes
    - Viewed (0)
  4. pkg/kubelet/cm/fake_container_manager.go

    	defer cm.Unlock()
    	cm.CalledFunctions = append(cm.CalledFunctions, "SystemCgroupsLimit")
    	return v1.ResourceList{}
    }
    
    func (cm *FakeContainerManager) GetNodeConfig() NodeConfig {
    	cm.Lock()
    	defer cm.Unlock()
    	cm.CalledFunctions = append(cm.CalledFunctions, "GetNodeConfig")
    	return NodeConfig{}
    }
    
    func (cm *FakeContainerManager) GetMountedSubsystems() *CgroupSubsystems {
    	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)
  5. pkg/kubelet/server/stats/summary_test.go

    	}
    
    	mockCtrl := gomock.NewController(t)
    	defer mockCtrl.Finish()
    	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()
    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

    	// These cgroups include the system and Kubernetes services.
    	SystemCgroupsLimit() v1.ResourceList
    
    	// GetNodeConfig returns a NodeConfig that is being used by the container manager.
    	GetNodeConfig() NodeConfig
    
    	// Status returns internal Status.
    	Status() Status
    
    	// NewPodContainerManager is a factory method which returns a podContainerManager object
    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

    	mockCtrl := gomock.NewController(t)
    	defer mockCtrl.Finish()
    
    	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()
    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

    	klog.V(2).InfoS("Starting stub container manager")
    	return nil
    }
    
    func (cm *containerManagerStub) SystemCgroupsLimit() v1.ResourceList {
    	return v1.ResourceList{}
    }
    
    func (cm *containerManagerStub) GetNodeConfig() NodeConfig {
    	return NodeConfig{}
    }
    
    func (cm *containerManagerStub) GetMountedSubsystems() *CgroupSubsystems {
    	return &CgroupSubsystems{}
    }
    
    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

    			return n, nil
    		}
    	}
    	return kl.initialNode(context.TODO())
    }
    
    // GetNodeConfig returns the container manager node config.
    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 {
    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 cm, nil
    }
    
    func (cm *containerManagerImpl) SystemCgroupsLimit() v1.ResourceList {
    	return v1.ResourceList{}
    }
    
    func (cm *containerManagerImpl) GetNodeConfig() NodeConfig {
    	return NodeConfig{}
    }
    
    func (cm *containerManagerImpl) GetMountedSubsystems() *CgroupSubsystems {
    	return &CgroupSubsystems{}
    }
    
    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