Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for GetNodeInfo (0.23 sec)

  1. pkg/kubelet/winstats/winstats.go

    type StatsClient struct {
    	client winNodeStatsClient
    }
    
    type winNodeStatsClient interface {
    	startMonitoring() error
    	getNodeMetrics() (nodeMetrics, error)
    	getNodeInfo() nodeInfo
    	getMachineInfo() (*cadvisorapi.MachineInfo, error)
    	getVersionInfo() (*cadvisorapi.VersionInfo, error)
    }
    
    type nodeMetrics struct {
    	cpuUsageCoreNanoSeconds   uint64
    	cpuUsageNanoCores         uint64
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Aug 24 19:47:49 UTC 2021
    - 5.2K bytes
    - Viewed (0)
  2. pkg/kubelet/winstats/winstats_test.go

    		cpuUsageNanoCores:         23,
    		memoryPrivWorkingSetBytes: 1234,
    		memoryCommittedBytes:      12345,
    		timeStamp:                 timeStamp,
    	}, nil
    }
    
    func (f fakeWinNodeStatsClient) getNodeInfo() nodeInfo {
    	return nodeInfo{
    		kernelVersion:               "v42",
    		memoryPhysicalCapacityBytes: 1.6e+10,
    	}
    }
    func (f fakeWinNodeStatsClient) getMachineInfo() (*cadvisorapi.MachineInfo, error) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Mar 13 12:08:15 UTC 2023
    - 4.2K bytes
    - Viewed (0)
  3. tools/bug-report/pkg/content/content.go

    func GetClusterContext(runner *kubectlcmd.Runner, kubeConfig string) (string, error) {
    	return runner.RunCmd("config current-context", "", kubeConfig, "", false)
    }
    
    // GetNodeInfo returns node information.
    func GetNodeInfo(p *Params) (map[string]string, error) {
    	out, err := p.Runner.RunCmd("get nodes -o yaml", "", p.KubeConfig, p.KubeContext, p.DryRun)
    	return map[string]string{
    		"nodes": out,
    	}, err
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Dec 05 18:47:53 UTC 2023
    - 9.7K bytes
    - Viewed (0)
  4. pkg/kubelet/winstats/perfcounter_nodestats_test.go

    	counterClient, err := NewPerfCounterClient()
    	assert.NoError(t, err)
    
    	// assert that startMonitoring has been called. nodeInfo should be set.
    	assert.NotNil(t, counterClient.(*StatsClient).client.getNodeInfo())
    
    	// Wait until we get a non-zero node metrics.
    	if pollErr := wait.Poll(100*time.Millisecond, 5*perfCounterUpdatePeriod, func() (bool, error) {
    		metrics, _ := counterClient.(*StatsClient).client.getNodeMetrics()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jan 26 18:37:21 UTC 2024
    - 5.7K bytes
    - Viewed (0)
  5. pkg/kubelet/winstats/perfcounter_nodestats.go

    	}, nil
    }
    
    func (p *perfCounterNodeStatsClient) getNodeMetrics() (nodeMetrics, error) {
    	p.mu.RLock()
    	defer p.mu.RUnlock()
    	return p.nodeMetrics, nil
    }
    
    func (p *perfCounterNodeStatsClient) getNodeInfo() nodeInfo {
    	return p.nodeInfo
    }
    
    func (p *perfCounterNodeStatsClient) collectMetricsData(cpuCounter, memWorkingSetCounter, memCommittedBytesCounter perfCounter, networkAdapterCounter *networkCounter) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jan 26 18:37:21 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  6. pkg/scheduler/internal/cache/cache_test.go

    		return errors.New("still assumed")
    	}
    	if _, err := c.GetPod(p); err == nil {
    		return errors.New("still in cache")
    	}
    	return nil
    }
    
    // getNodeInfo returns cached data for the node name.
    func (cache *cacheImpl) getNodeInfo(nodeName string) (*v1.Node, error) {
    	cache.mu.RLock()
    	defer cache.mu.RUnlock()
    
    	n, ok := cache.nodes[nodeName]
    	if !ok {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 17 01:38:03 UTC 2023
    - 63.8K bytes
    - Viewed (0)
  7. tools/bug-report/pkg/bugreport/bugreport.go

    	getFromCluster(content.GetEvents, params, clusterDir, &mandatoryWg)
    	getFromCluster(content.GetClusterInfo, params, clusterDir, &mandatoryWg)
    	getFromCluster(content.GetNodeInfo, params, clusterDir, &mandatoryWg)
    	getFromCluster(content.GetSecrets, params.SetVerbose(config.FullSecrets), clusterDir, &mandatoryWg)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Apr 05 20:57:29 UTC 2024
    - 20.7K bytes
    - Viewed (0)
Back to top