Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 45 for nodeInfos (0.18 sec)

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

    			},
    		},
    	}
    	nodeInfo := &schedulerframework.NodeInfo{}
    	nodeInfo.SetNode(cachedNode)
    
    	testManager.UpdatePluginResources(nodeInfo, &lifecycle.PodAdmitAttributes{Pod: pod})
    
    	allocatableScalarResources := nodeInfo.Allocatable.ScalarResources
    	// allocatable in nodeInfo is less than needed, should update
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 65K bytes
    - Viewed (0)
  2. src/cmd/vendor/github.com/google/pprof/internal/report/report.go

    	objfiles := make(map[string]int)
    	files := make(map[string]int)
    	names := make(map[string]int)
    
    	// prevInfo points to the previous NodeInfo.
    	// It is used to group cost lines together as much as possible.
    	var prevInfo *graph.NodeInfo
    	for _, n := range g.Nodes {
    		if prevInfo == nil || n.Info.Objfile != prevInfo.Objfile || n.Info.File != prevInfo.File || n.Info.Name != prevInfo.Name {
    			fmt.Fprintln(w)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 31 19:48:28 UTC 2024
    - 37.5K bytes
    - Viewed (0)
  3. cmd/notification.go

    	}
    	return reply
    }
    
    func (sys *NotificationSys) addNodeErr(nodeInfo madmin.NodeInfo, peerClient *peerRESTClient, err error) {
    	addr := peerClient.host.String()
    	reqInfo := (&logger.ReqInfo{}).AppendTags("remotePeer", addr)
    	ctx := logger.SetReqInfo(GlobalContext, reqInfo)
    	peersLogOnceIf(ctx, err, "add-node-err-"+addr)
    	nodeInfo.SetAddr(addr)
    	nodeInfo.SetError(err.Error())
    }
    
    // GetSysErrors - Memory information
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 44.9K bytes
    - Viewed (0)
  4. pkg/kubelet/cm/container_manager_linux.go

    	// External containers being managed.
    	systemContainers []*systemContainer
    	// Tasks that are run periodically
    	periodicTasks []func()
    	// Holds all the mounted cgroup subsystems
    	subsystems *CgroupSubsystems
    	nodeInfo   *v1.Node
    	// Interface for cgroup management
    	cgroupManager CgroupManager
    	// Capacity of this node.
    	capacity v1.ResourceList
    	// Capacity of this node, including internal resources.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 21 10:18:16 UTC 2024
    - 35.1K bytes
    - Viewed (0)
  5. pkg/kubelet/cm/node_container_manager_linux.go

    		Name:               cm.cgroupRoot,
    		ResourceParameters: getCgroupConfig(nodeAllocatable),
    	}
    
    	// Using ObjectReference for events as the node maybe not cached; refer to #42701 for detail.
    	nodeRef := nodeRefFromNode(cm.nodeInfo.Name)
    
    	// If Node Allocatable is enforced on a node that has not been drained or is updated on an existing node to a lower value,
    	// existing memory usage across pods might be higher than current Node Allocatable Memory Limits.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 21 10:18:16 UTC 2024
    - 10.5K bytes
    - Viewed (0)
  6. pkg/scheduler/framework/plugins/dynamicresources/dynamicresources.go

    	if !pl.enabled {
    		return nil
    	}
    	state, err := getStateData(cs)
    	if err != nil {
    		return statusError(klog.FromContext(ctx), err)
    	}
    	if len(state.claims) == 0 {
    		return nil
    	}
    
    	logger := klog.FromContext(ctx)
    	node := nodeInfo.Node()
    
    	var unavailableClaims []int
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 30 15:22:37 UTC 2024
    - 75.9K bytes
    - Viewed (0)
  7. cmd/kube-proxy/app/server_linux.go

    		node, err := waitForPodCIDR(ctx, s.Client, s.Hostname)
    		if err != nil {
    			return err
    		}
    		s.podCIDRs = node.Spec.PodCIDRs
    		logger.Info("NodeInfo", "podCIDRs", node.Spec.PodCIDRs)
    	}
    
    	err := s.setupConntrack(ctx)
    	if err != nil {
    		return err
    	}
    
    	return nil
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jun 08 13:48:54 UTC 2024
    - 18.1K bytes
    - Viewed (0)
  8. pkg/printers/internalversion/printers.go

    	}
    
    	row.Cells = append(row.Cells, obj.Name, strings.Join(status, ","), roles, translateTimestampSince(obj.CreationTimestamp), obj.Status.NodeInfo.KubeletVersion)
    	if options.Wide {
    		osImage, kernelVersion, crVersion := obj.Status.NodeInfo.OSImage, obj.Status.NodeInfo.KernelVersion, obj.Status.NodeInfo.ContainerRuntimeVersion
    		if osImage == "" {
    			osImage = "<unknown>"
    		}
    		if kernelVersion == "" {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 14:04:15 UTC 2024
    - 128.3K bytes
    - Viewed (0)
  9. pkg/printers/internalversion/printers_test.go

    	table := []struct {
    		node     api.Node
    		expected []metav1.TableRow
    	}{
    		{
    			node: api.Node{
    				ObjectMeta: metav1.ObjectMeta{Name: "foo1"},
    				Status: api.NodeStatus{
    					NodeInfo:  api.NodeSystemInfo{OSImage: "fake-os-image"},
    					Addresses: []api.NodeAddress{{Type: api.NodeExternalIP, Address: "1.1.1.1"}},
    				},
    			},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 14:04:15 UTC 2024
    - 218.6K bytes
    - Viewed (0)
  10. src/cmd/vendor/github.com/google/pprof/internal/report/source.go

    	for lineno := start; lineno <= end; lineno++ {
    		line, ok := reader.line(file, lineno)
    		if !ok {
    			break
    		}
    		flat, cum := lineNodes[lineno].Sum()
    		src = append(src, &graph.Node{
    			Info: graph.NodeInfo{
    				Name:   strings.TrimRight(line, "\n"),
    				Lineno: lineno,
    			},
    			Flat: flat,
    			Cum:  cum,
    		})
    	}
    	if err := reader.fileError(file); err != nil {
    		return nil, file, err
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 31 19:48:28 UTC 2024
    - 31.3K bytes
    - Viewed (0)
Back to top