- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 178 for zoneinfo (0.1 sec)
-
pkg/scheduler/internal/cache/debugger/comparer_test.go
for _, nodeName := range actual { node := &v1.Node{} node.Name = nodeName nodes = append(nodes, node) } nodeInfo := make(map[string]*framework.NodeInfo) for _, nodeName := range cached { nodeInfo[nodeName] = &framework.NodeInfo{} } m, r := compare.CompareNodes(nodes, nodeInfo) if diff := cmp.Diff(missing, m); diff != "" { t.Errorf("Unexpected missing (-want, +got):\n%s", diff) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 05 08:00:25 UTC 2023 - 4.8K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/defaultpreemption/default_preemption.go
ctx context.Context, state *framework.CycleState, pod *v1.Pod, nodeInfo *framework.NodeInfo, pdbs []*policy.PodDisruptionBudget) ([]*v1.Pod, int, *framework.Status) { logger := klog.FromContext(ctx) var potentialVictims []*framework.PodInfo removePod := func(rpi *framework.PodInfo) error { if err := nodeInfo.RemovePod(logger, rpi.Pod); err != nil { return err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Nov 25 19:36:04 UTC 2023 - 12.7K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/podtopologyspread/filtering.go
s, err := getPreFilterState(cycleState) if err != nil { return framework.AsStatus(err) } pl.updateWithPod(s, podInfoToAdd.Pod, podToSchedule, nodeInfo.Node(), 1) return nil } // RemovePod from pre-computed data in cycleState.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 28 10:42:29 UTC 2024 - 12.4K bytes - Viewed (1) -
pkg/scheduler/framework/runtime/instrumented_plugins.go
} var _ framework.FilterPlugin = &instrumentedFilterPlugin{} func (p *instrumentedFilterPlugin) Filter(ctx context.Context, state *framework.CycleState, pod *v1.Pod, nodeInfo *framework.NodeInfo) *framework.Status { p.metric.Inc() return p.FilterPlugin.Filter(ctx, state, pod, nodeInfo) } type instrumentedPreFilterPlugin struct { framework.PreFilterPlugin metric compbasemetrics.CounterMetric }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Dec 15 03:30:06 UTC 2023 - 2.4K bytes - Viewed (0) -
pkg/kubelet/winstats/perfcounter_nodestats.go
return &cadvisorapi.VersionInfo{ KernelVersion: p.nodeInfo.kernelVersion, ContainerOsVersion: p.nodeInfo.osImageVersion, }, 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 }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 26 18:37:21 UTC 2024 - 9.2K bytes - Viewed (0) -
pkg/kubelet/winstats/winstats.go
Interfaces: nodeMetrics.interfaceStats, }, }) nodeInfo := c.client.getNodeInfo() rootInfo := cadvisorapiv2.ContainerInfo{ Spec: cadvisorapiv2.ContainerSpec{ CreationTime: nodeInfo.startTime, HasCpu: true, HasMemory: true, HasNetwork: true, Memory: cadvisorapiv2.MemorySpec{ Limit: nodeInfo.memoryPhysicalCapacityBytes, }, }, Stats: stats, }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Aug 24 19:47:49 UTC 2021 - 5.2K bytes - Viewed (0) -
pkg/structured/structured.go
// Err is the original error string. Err error } // Log appends relevant labels to the log scope. func (e *Error) Log(s *log.Scope) *log.Scope { lbls := make([]any, 0, 10) if e.MoreInfo != "" { lbls = append(lbls, "moreInfo", e.MoreInfo) } if e.Impact != "" { lbls = append(lbls, "impact", e.Impact) } if e.Action != "" { lbls = append(lbls, "action", e.Action) } if e.LikelyCause != "" {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Jul 15 23:58:50 UTC 2023 - 2.5K bytes - Viewed (0) -
operator/pkg/controller/istiocontrolplane/errdict.go
operatorImpactNoUpdates = "In this error state, changes to the IstioOperator CR will not result in the Istio " + "control plane being updated." ) var ( operatorFailedToGetObjectFromAPIServer = &structured.Error{ MoreInfo: "Failed to get an object from the Kubernetes API server, because of a transient " + "API server error or the object no longer exists.", Impact: operatorImpactFailedToGetObjectFromAPIServer,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 13:56:46 UTC 2024 - 4.7K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/imagelocality/image_locality.go
// the final score. func sumImageScores(nodeInfo *framework.NodeInfo, pod *v1.Pod, totalNumNodes int) int64 { var sum int64 for _, container := range pod.Spec.InitContainers { if state, ok := nodeInfo.ImageStates[normalizedImageName(container.Image)]; ok { sum += scaledImageScore(state, totalNumNodes) } } for _, container := range pod.Spec.Containers {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 19 06:17:57 UTC 2024 - 5K bytes - Viewed (0) -
pkg/scheduler/internal/cache/debugger/dumper.go
d.dumpNodes(logger) d.dumpSchedulingQueue(logger) } // dumpNodes writes NodeInfo to the scheduler logs. func (d *CacheDumper) dumpNodes(logger klog.Logger) { dump := d.cache.Dump() nodeInfos := make([]string, 0, len(dump.Nodes)) for name, nodeInfo := range dump.Nodes { nodeInfos = append(nodeInfos, d.printNodeInfo(name, nodeInfo)) } // Extra blank line added between node entries for readability.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 29 05:26:32 UTC 2023 - 3.1K bytes - Viewed (0)