Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 579 for scorer (0.16 sec)

  1. pkg/scheduler/framework/plugins/volumebinding/scorer.go

    	"k8s.io/kubernetes/pkg/scheduler/framework/plugins/helper"
    )
    
    // classResourceMap holds a map of storage class to resource.
    type classResourceMap map[string]*StorageResource
    
    // volumeCapacityScorer calculates the score based on class storage resource information.
    type volumeCapacityScorer func(classResourceMap) int64
    
    // buildScorerFunction builds volumeCapacityScorer from the scoring function shape.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Aug 13 11:08:45 UTC 2021
    - 1.8K bytes
    - Viewed (0)
  2. pkg/scheduler/framework/plugins/noderesources/resource_allocation.go

    	// cpu and memory.
    	useRequested bool
    	scorer       func(requested, allocable []int64) int64
    	resources    []config.ResourceSpec
    }
    
    // score will use `scorer` function to calculate the score.
    func (r *resourceAllocationScorer) score(
    	ctx context.Context,
    	pod *v1.Pod,
    	nodeInfo *framework.NodeInfo,
    	podRequests []int64) (int64, *framework.Status) {
    	logger := klog.FromContext(ctx)
    	node := nodeInfo.Node()
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 20 14:53:43 UTC 2023
    - 5.3K bytes
    - Viewed (0)
  3. pkg/scheduler/framework/plugins/noderesources/resource_allocation_test.go

    				v1.ResourceMemory: 3 + util.DefaultMemoryRequest,
    			},
    		},
    	}
    
    	for _, tc := range tests {
    		t.Run(tc.name, func(t *testing.T) {
    			var scorer resourceAllocationScorer
    			for n, exp := range tc.expected {
    				got := scorer.calculatePodResourceRequest(&tc.pod, n)
    				if got != exp {
    					t.Errorf("expected %s = %d, got %d", n, exp, got)
    				}
    			}
    		})
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 09 23:15:53 UTC 2023
    - 5.9K bytes
    - Viewed (0)
  4. pkg/scheduler/framework/plugins/noderesources/balanced_allocation.go

    	}
    	return s, nil
    }
    
    // Name returns name of the plugin. It is used in logs, etc.
    func (ba *BalancedAllocation) Name() string {
    	return BalancedAllocationName
    }
    
    // Score invoked at the score extension point.
    func (ba *BalancedAllocation) Score(ctx context.Context, state *framework.CycleState, pod *v1.Pod, nodeName string) (int64, *framework.Status) {
    	nodeInfo, err := ba.handle.SnapshotSharedLister().NodeInfos().Get(nodeName)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 15 03:30:06 UTC 2023
    - 6.5K bytes
    - Viewed (0)
  5. pkg/scheduler/framework/plugins/imagelocality/image_locality.go

    }
    
    // sumImageScores returns the sum of image scores of all the containers that are already on the node.
    // Each image receives a raw score of its size, scaled by scaledImageScore. The raw scores are later used to calculate
    // the final score.
    func sumImageScores(nodeInfo *framework.NodeInfo, pod *v1.Pod, totalNumNodes int) int64 {
    	var sum int64
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 19 06:17:57 UTC 2024
    - 5K bytes
    - Viewed (0)
  6. pkg/scheduler/framework/plugins/helper/normalize_score_test.go

    		},
    		{
    			scores:         []int64{0, 0, 0, 0},
    			expectedScores: []int64{0, 0, 0, 0},
    		},
    		{
    			reverse:        true,
    			scores:         []int64{0, 0, 0, 0},
    			expectedScores: []int64{100, 100, 100, 100},
    		},
    	}
    
    	for i, test := range tests {
    		t.Run(fmt.Sprintf("case_%d", i), func(t *testing.T) {
    			scores := framework.NodeScoreList{}
    			for _, score := range test.scores {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jul 14 16:15:18 UTC 2022
    - 2.4K bytes
    - Viewed (0)
  7. pkg/scheduler/framework/plugins/helper/normalize_score.go

    		if scores[i].Score > maxCount {
    			maxCount = scores[i].Score
    		}
    	}
    
    	if maxCount == 0 {
    		if reverse {
    			for i := range scores {
    				scores[i].Score = maxPriority
    			}
    		}
    		return nil
    	}
    
    	for i := range scores {
    		score := scores[i].Score
    
    		score = maxPriority * score / maxCount
    		if reverse {
    			score = maxPriority - score
    		}
    
    		scores[i].Score = score
    	}
    	return nil
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jul 14 16:15:18 UTC 2022
    - 1.4K bytes
    - Viewed (0)
  8. pkg/kubelet/qos/policy.go

    	KubeProxyOOMScoreAdj  int = -999
    	guaranteedOOMScoreAdj int = -997
    	besteffortOOMScoreAdj int = 1000
    )
    
    // GetContainerOOMScoreAdjust returns the amount by which the OOM score of all processes in the
    // container should be adjusted.
    // The OOM score of a process is the percentage of memory it consumes
    // multiplied by 10 (barring exceptional cases) + a configurable quantity which is between -1000
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 10 14:49:26 UTC 2023
    - 3.3K bytes
    - Viewed (0)
  9. pkg/scheduler/framework/plugins/tainttoleration/taint_toleration.go

    	if err != nil {
    		return 0, framework.AsStatus(err)
    	}
    
    	score := int64(countIntolerableTaintsPreferNoSchedule(node.Spec.Taints, s.tolerationsPreferNoSchedule))
    	return score, nil
    }
    
    // NormalizeScore invoked after scoring all nodes.
    func (pl *TaintToleration) NormalizeScore(ctx context.Context, _ *framework.CycleState, pod *v1.Pod, scores framework.NodeScoreList) *framework.Status {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/score/ScoreUpdater.java

                    resultBuf.append(b.getClass().getSimpleName()).append(" : ").append(count).append('\n');
                } catch (final Exception e) {
                    logger.warn("Failed to update scores.", e);
                    resultBuf.append(e.getMessage()).append('\n');
                }
            });
            return resultBuf.toString();
        }
    
        protected void addScoreBooster(final ScoreBooster scoreBooster) {
    Registered: Wed Jun 12 13:08:18 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 1.7K bytes
    - Viewed (0)
Back to top