Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 122 for topology (0.14 sec)

  1. pkg/kubelet/cm/devicemanager/pod_devices.go

    		for numaid, devlist := range allocateInfo.deviceIds {
    			for _, devID := range devlist {
    				var topology *pluginapi.TopologyInfo
    				if numaid != nodeWithoutTopology {
    					NUMANodes := []*pluginapi.NUMANode{{ID: numaid}}
    					if pDev, ok := devicePluginMap[devID]; ok && pDev.Topology != nil {
    						if nodes := pDev.Topology.GetNodes(); nodes != nil {
    							NUMANodes = append(NUMANodes, nodes...)
    						}
    					}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jan 27 02:10:25 UTC 2024
    - 16.7K bytes
    - Viewed (0)
  2. staging/src/k8s.io/api/storage/v1/types.go

    	// When a driver is initialized on a cluster, it provides a set of topology
    	// keys that it understands (e.g. "company.com/zone", "company.com/region").
    	// When a driver is initialized on a node, it provides the same topology keys
    	// along with values. Kubelet will expose these topology keys as labels
    	// on its own node object.
    	// When Kubernetes does topology aware provisioning, it can use this list to
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 23 17:42:49 UTC 2024
    - 32K bytes
    - Viewed (0)
  3. pkg/kubelet/cm/cpumanager/topology/topology_test.go

    				},
    			},
    			wantErr: false,
    		},
    		{
    
    			// FAKE Topology from dual xeon gold 6230
    			// (see: dual xeon gold 6230).
    			// We flip NUMA cells and Sockets to exercise the code.
    			// TODO(fromanirh): replace with a real-world topology
    			// once we find a suitable one.
    			// Note: this is a fake topology. Thus, there is not a "correct"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 03 16:26:09 UTC 2023
    - 31.7K bytes
    - Viewed (0)
  4. staging/src/k8s.io/api/storage/v1alpha1/generated.proto

    // For a given StorageClass, this describes the available capacity in a
    // particular topology segment.  This can be used when considering where to
    // instantiate new PersistentVolumes.
    //
    // For example this can express things like:
    // - StorageClass "standard" has "1234 GiB" available in "topology.kubernetes.io/zone=us-east1"
    // - StorageClass "localssd" has "10 GiB" available in "kubernetes.io/hostname=knode-abc123"
    //
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 28 15:34:11 UTC 2024
    - 11.3K bytes
    - Viewed (0)
  5. staging/src/k8s.io/api/storage/v1alpha1/types.go

    // For a given StorageClass, this describes the available capacity in a
    // particular topology segment.  This can be used when considering where to
    // instantiate new PersistentVolumes.
    //
    // For example this can express things like:
    // - StorageClass "standard" has "1234 GiB" available in "topology.kubernetes.io/zone=us-east1"
    // - StorageClass "localssd" has "10 GiB" available in "kubernetes.io/hostname=knode-abc123"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Nov 27 20:06:32 UTC 2023
    - 13.4K bytes
    - Viewed (0)
  6. common/scripts/kind_provisioner.sh

      done
    }
    
    # setup_kind_clusters sets up a given number of kind clusters with given topology
    # as specified in cluster topology configuration file.
    # 1. IMAGE = docker image used as node by KinD
    # 2. IP_FAMILY = either ipv4 or ipv6
    #
    # NOTE: Please call load_cluster_topology before calling this method as it expects
    # cluster topology information to be loaded in advance
    function setup_kind_clusters() {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Apr 08 19:12:55 UTC 2024
    - 17.3K bytes
    - Viewed (0)
  7. pkg/scheduler/framework/plugins/interpodaffinity/filtering.go

    type preFilterState struct {
    	// A map of topology pairs to the number of existing pods that has anti-affinity terms that match the "pod".
    	existingAntiAffinityCounts topologyToMatchedTermCount
    	// A map of topology pairs to the number of existing pods that match the affinity terms of the "pod".
    	affinityCounts topologyToMatchedTermCount
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jun 01 10:24:54 UTC 2023
    - 14.6K bytes
    - Viewed (0)
  8. pkg/kubelet/cm/devicemanager/manager.go

    		for dev := range allocDevices {
    			if m.allDevices[resource][dev].Topology == nil || len(m.allDevices[resource][dev].Topology.Nodes) == 0 {
    				allocDevicesWithNUMA[nodeWithoutTopology] = append(allocDevicesWithNUMA[nodeWithoutTopology], dev)
    				continue
    			}
    			for idx := range m.allDevices[resource][dev].Topology.Nodes {
    				node := m.allDevices[resource][dev].Topology.Nodes[idx]
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 15 12:01:56 UTC 2024
    - 43K bytes
    - Viewed (0)
  9. pkg/test/framework/components/echo/echotest/filters_test.go

    	// 2 clusters on 2 networks
    	allClusters = make(cluster.Map)
    	cls1        = &kube.Cluster{Topology: cluster.Topology{
    		ClusterName:        "cls1",
    		Network:            "n1",
    		PrimaryClusterName: "cls1",
    		ConfigClusterName:  "cls1",
    		Index:              0,
    		AllClusters:        allClusters,
    	}}
    	cls2 = &kube.Cluster{Topology: cluster.Topology{
    		ClusterName:        "cls2",
    		Network:            "n2",
    		PrimaryClusterName: "cls2",
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 22:12:34 UTC 2024
    - 13.1K bytes
    - Viewed (0)
  10. pkg/scheduler/framework/plugins/interpodaffinity/scoring.go

    	for _, term := range terms {
    		m.processTerm(&term.AffinityTerm, term.Weight, pod, nsLabels, node, multiplier)
    	}
    }
    
    func (m scoreMap) append(other scoreMap) {
    	for topology, oScores := range other {
    		scores := m[topology]
    		if scores == nil {
    			m[topology] = oScores
    			continue
    		}
    		for k, v := range oScores {
    			scores[k] += v
    		}
    	}
    }
    
    func (pl *InterPodAffinity) processExistingPod(
    	state *preScoreState,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 15 03:30:06 UTC 2023
    - 10.5K bytes
    - Viewed (0)
Back to top