Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 15 of 15 for ContainerMap (0.14 sec)

  1. pkg/kubelet/cm/topologymanager/scope_container.go

    limitations under the License.
    */
    
    package topologymanager
    
    import (
    	"k8s.io/api/core/v1"
    	"k8s.io/klog/v2"
    	"k8s.io/kubernetes/pkg/kubelet/cm/admission"
    	"k8s.io/kubernetes/pkg/kubelet/cm/containermap"
    	"k8s.io/kubernetes/pkg/kubelet/lifecycle"
    	"k8s.io/kubernetes/pkg/kubelet/metrics"
    )
    
    type containerScope struct {
    	scope
    }
    
    // Ensure containerScope implements Scope interface
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 14 14:44:24 UTC 2023
    - 2.9K bytes
    - Viewed (0)
  2. pkg/kubelet/cm/cpumanager/state/state_checkpoint.go

    	"k8s.io/kubernetes/pkg/kubelet/cm/containermap"
    	"k8s.io/utils/cpuset"
    )
    
    var _ State = &stateCheckpoint{}
    
    type stateCheckpoint struct {
    	mux               sync.RWMutex
    	policyName        string
    	cache             State
    	checkpointManager checkpointmanager.CheckpointManager
    	checkpointName    string
    	initialContainers containermap.ContainerMap
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jul 13 00:59:30 UTC 2023
    - 7.9K bytes
    - Viewed (0)
  3. pkg/kubelet/stats/cri_stats_provider_linux.go

    	ps *statsapi.PodStats, fsIDtoInfo map[runtimeapi.FilesystemIdentifier]*cadvisorapiv2.FsInfo,
    	containerMap map[string]*runtimeapi.Container,
    	podSandbox *runtimeapi.PodSandbox,
    	rootFsInfo *cadvisorapiv2.FsInfo, updateCPUNanoCoreUsage bool) error {
    	for _, criContainerStat := range criSandboxStat.Linux.Containers {
    		container, found := containerMap[criContainerStat.Attributes.Id]
    		if !found {
    			continue
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 16 11:09:04 UTC 2023
    - 4K bytes
    - Viewed (0)
  4. pkg/kubelet/cm/container_manager_windows.go

    			cm.capacity[rName] = rCap
    		}
    	}
    
    	ctx := context.Background()
    	containerMap, containerRunningSet := buildContainerMapAndRunningSetFromRuntime(ctx, runtimeService)
    
    	// Starts device manager.
    	if err := cm.deviceManager.Start(devicemanager.ActivePodsFunc(activePods), sourcesReady, containerMap, containerRunningSet); err != nil {
    		return err
    	}
    
    	return nil
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jul 12 11:25:36 UTC 2023
    - 8.7K bytes
    - Viewed (0)
  5. pkg/kubelet/stats/cri_stats_provider_others.go

    	return nil, nil
    }
    
    func (p *criStatsProvider) addCRIPodContainerStats(criSandboxStat *runtimeapi.PodSandboxStats,
    	ps *statsapi.PodStats, fsIDtoInfo map[runtimeapi.FilesystemIdentifier]*cadvisorapiv2.FsInfo,
    	containerMap map[string]*runtimeapi.Container,
    	podSandbox *runtimeapi.PodSandbox,
    	rootFsInfo *cadvisorapiv2.FsInfo, updateCPUNanoCoreUsage bool) error {
    	return nil
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 16 11:09:04 UTC 2023
    - 1.8K bytes
    - Viewed (0)
Back to top