Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 11 for nodesMap (0.2 sec)

  1. cmd/endpoint.go

    			}
    			if !slices.Contains(node.Pools, ep.PoolIdx) {
    				node.Pools = append(node.Pools, ep.PoolIdx)
    			}
    			nodesMap[ep.Host] = node
    		}
    	}
    	nodes = make([]Node, 0, len(nodesMap))
    	for _, v := range nodesMap {
    		nodes = append(nodes, v)
    	}
    	sort.Slice(nodes, func(i, j int) bool {
    		return nodes[i].Host < nodes[j].Host
    	})
    	return
    }
    
    // GetPoolIdx return pool index
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 34.1K bytes
    - Viewed (0)
  2. src/internal/profile/graph.go

    	default:
    		// Do not leave it empty if there is no information at all.
    		name = append(name, "<unknown>")
    	}
    	return name
    }
    
    // NodeMap maps from a node info struct to a node. It is used to merge
    // report entries with the same info.
    type NodeMap map[NodeInfo]*Node
    
    // NodeSet is a collection of node info structs.
    type NodeSet map[NodeInfo]bool
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Feb 05 20:59:15 UTC 2024
    - 13.1K bytes
    - Viewed (0)
  3. pkg/kubelet/apis/config/validation/validation_test.go

    			conf.FeatureGates = map[string]bool{"NodeSwap": true}
    			conf.MemorySwap.SwapBehavior = "invalid-behavior"
    			return conf
    		},
    		errMsg: "invalid configuration: memorySwap.swapBehavior \"invalid-behavior\" must be one of: \"\", \"LimitedSwap\" or \"NoSwap\"",
    	}, {
    		name: "specify MemorySwap.SwapBehavior without enabling NodeSwap",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 05 21:10:42 UTC 2024
    - 28.7K bytes
    - Viewed (0)
  4. src/cmd/vendor/github.com/google/pprof/internal/graph/graph.go

    				lines = []profile.Line{{}} // Create empty line to include location info.
    			}
    			for lidx := len(lines) - 1; lidx >= 0; lidx-- {
    				nodeMap := parentNodeMap[parent]
    				if nodeMap == nil {
    					nodeMap = make(NodeMap)
    					parentNodeMap[parent] = nodeMap
    				}
    				n := nodeMap.findOrInsertLine(l, lines[lidx], o)
    				if n == nil {
    					continue
    				}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 31 19:48:28 UTC 2024
    - 31K bytes
    - Viewed (0)
  5. pkg/kubelet/apis/config/validation/validation.go

    		}
    	}
    	if !localFeatureGate.Enabled(features.NodeSwap) && kc.MemorySwap != (kubeletconfig.MemorySwapConfiguration{}) {
    		allErrors = append(allErrors, fmt.Errorf("invalid configuration: memorySwap.swapBehavior cannot be set when NodeSwap feature flag is disabled"))
    	}
    
    	for _, val := range kc.EnforceNodeAllocatable {
    		switch val {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 10 17:13:59 UTC 2024
    - 18.2K bytes
    - Viewed (0)
  6. pkg/kubelet/kuberuntime/kuberuntime_container_linux.go

    		}
    	}
    
    	return lcr
    }
    
    // configureContainerSwapResources configures the swap resources for a specified (linux) container.
    // Swap is only configured if a swap cgroup controller is available and the NodeSwap feature gate is enabled.
    func (m *kubeGenericRuntimeManager) configureContainerSwapResources(lcr *runtimeapi.LinuxContainerResources, pod *v1.Pod, container *v1.Container) {
    	if !swapControllerAvailable() {
    		return
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 22:40:29 UTC 2024
    - 17.2K bytes
    - Viewed (0)
  7. pkg/kubelet/kuberuntime/kuberuntime_container_linux_test.go

    			nodeSwapFeatureGateEnabled: true,
    			swapBehavior:               types.LimitedSwap,
    		},
    
    		// With feature gate turned off
    		{
    			name:                       "NodeSwap feature gate turned off, cgroups v2, LimitedSwap",
    			cgroupVersion:              cgroupV2,
    			qosClass:                   v1.PodQOSBurstable,
    			nodeSwapFeatureGateEnabled: false,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 22:40:29 UTC 2024
    - 41K bytes
    - Viewed (0)
  8. cmd/metrics.go

    }
    
    func nodeHealthMetricsPrometheus(ch chan<- prometheus.Metric) {
    	nodesUp, nodesDown := globalNotificationSys.GetPeerOnlineCount()
    	ch <- prometheus.MustNewConstMetric(
    		prometheus.NewDesc(
    			prometheus.BuildFQName(minioNamespace, "nodes", "online"),
    			"Total number of MinIO nodes online",
    			nil, nil),
    		prometheus.GaugeValue,
    		float64(nodesUp),
    	)
    	ch <- prometheus.MustNewConstMetric(
    		prometheus.NewDesc(
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  9. pkg/features/kube_features.go

    	// kep: https://kep.k8s.io/2400
    	// alpha: v1.22
    	// beta1: v1.28 (default=false)
    	// beta2: v.1.30 (default=true)
    
    	// Permits kubelet to run with swap enabled.
    	NodeSwap featuregate.Feature = "NodeSwap"
    
    	// owner: @mortent, @atiratree, @ravig
    	// kep: http://kep.k8s.io/3018
    	// alpha: v1.26
    	// beta: v1.27
    	//
    	// Enables PDBUnhealthyPodEvictionPolicy for PodDisruptionBudgets
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 22:51:23 UTC 2024
    - 45.2K bytes
    - Viewed (0)
  10. src/cmd/compile/internal/test/pgo_inl_test.go

    	"bytes"
    	"fmt"
    	"internal/profile"
    	"internal/testenv"
    	"io"
    	"os"
    	"path/filepath"
    	"regexp"
    	"strings"
    	"testing"
    )
    
    const profFile = "inline_hot.pprof"
    const preProfFile = "inline_hot.pprof.node_map"
    
    func buildPGOInliningTest(t *testing.T, dir string, gcflag string) []byte {
    	const pkg = "example.com/pgo/inline"
    
    	// Add a go.mod so we have a consistent symbol names in this temp dir.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Mar 26 19:58:28 UTC 2024
    - 11.1K bytes
    - Viewed (0)
Back to top