- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 881 for spreading (0.26 sec)
-
pkg/scheduler/framework/plugins/podtopologyspread/scoring.go
TopologyPairToPodCounts: make(map[topologyPair]*int64), } // Only require that nodes have all the topology labels if using // non-system-default spreading rules. This allows nodes that don't have a // zone label to still have hostname spreading. requireAllTopologies := len(pod.Spec.TopologySpreadConstraints) > 0 || !pl.systemDefaulted err = pl.initPreScoreState(state, pod, filteredNodes, requireAllTopologies)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Dec 15 03:30:06 UTC 2023 - 10.1K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/podtopologyspread/filtering.go
return } requiredSchedulingTerm := nodeaffinity.GetRequiredNodeAffinity(preemptorPod) if !pl.enableNodeInclusionPolicyInPodTopologySpread { // spreading is applied to nodes that pass those filters. // Ignore parsing errors for backwards compatibility. if match, _ := requiredSchedulingTerm.Match(node); !match { return } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 28 10:42:29 UTC 2024 - 12.4K bytes - Viewed (0) -
build/dependencies.yaml
- path: test/integration/scheduler_perf/config/templates/pod-with-preferred-topology-spreading.yaml match: registry.k8s.io\/pause:\d+\.\d+ - path: test/integration/scheduler_perf/config/templates/pod-with-secret-volume.yaml match: registry.k8s.io\/pause:\d+\.\d+ - path: test/integration/scheduler_perf/config/templates/pod-with-topology-spreading.yaml match: registry.k8s.io\/pause:\d+\.\d+
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 16:13:15 UTC 2024 - 12.3K bytes - Viewed (0) -
CONTRIBUTING.md
* Keep commits discrete. Avoid including multiple unrelated changes in a single commit. * Keep commits self-contained. Avoid spreading a single change across multiple commits. A single commit should make sense in isolation. ### Testing changes After making changes, you can test your code in 2 ways: 1. Run tests.
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri May 31 01:39:23 UTC 2024 - 15.7K bytes - Viewed (0) -
pkg/scheduler/schedule_one.go
// ensure a minimum level of spreading. minFeasibleNodesToFind = 100 // minFeasibleNodesPercentageToFind is the minimum percentage of nodes that // would be scored in each scheduling cycle. This is a semi-arbitrary value // to ensure that a certain minimum of nodes are checked for feasibility. // This in turn helps ensure a minimum level of spreading. minFeasibleNodesPercentageToFind = 5
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 13:28:08 UTC 2024 - 43.4K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set_utils.go
func getPersistentVolumeClaimName(set *apps.StatefulSet, claim *v1.PersistentVolumeClaim, ordinal int) string { // NOTE: This name format is used by the heuristics for zone spreading in ChooseZoneForVolume return fmt.Sprintf("%s-%s-%d", claim.Name, set.Name, ordinal) } // isMemberOf tests if pod is a member of set. func isMemberOf(set *apps.StatefulSet, pod *v1.Pod) bool {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 26.7K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/runtime/serializer/streaming/streaming.go
See the License for the specific language governing permissions and limitations under the License. */ // Package streaming implements encoder and decoder for streams // of runtime.Objects over io.Writer/Readers. package streaming import ( "bytes" "fmt" "io" "k8s.io/apimachinery/pkg/runtime" "k8s.io/apimachinery/pkg/runtime/schema" )
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Aug 25 14:51:36 UTC 2023 - 3.7K bytes - Viewed (0) -
pkg/scheduler/schedule_one_test.go
func TestZeroRequest(t *testing.T) { // A pod with no resources. We expect spreading to count it as having the default resources. noResources := v1.PodSpec{ Containers: []v1.Container{ {}, }, } noResources1 := noResources noResources1.NodeName = "node1" // A pod with the same resources as a 0-request pod gets by default as its resources (for spreading). small := v1.PodSpec{ Containers: []v1.Container{ {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:20:55 UTC 2024 - 128.1K bytes - Viewed (0) -
cmd/bitrot-streaming.go
} // newStreamingBitrotWriterBuffer returns streaming bitrot writer implementation. // The output is written to the supplied writer w. func newStreamingBitrotWriterBuffer(w io.Writer, algo BitrotAlgorithm, shardSize int64) io.Writer { return &streamingBitrotWriter{iow: ioutil.NopCloser(w), h: algo.New(), shardSize: shardSize, canClose: nil, closeWithErr: func(err error) {}} } // Returns streaming bitrot writer implementation.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 15 00:11:04 UTC 2024 - 6.1K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/podtopologyspread/scoring_test.go
failedNodes: []*v1.Node{}, objs: []runtime.Object{ &v1.Service{Spec: v1.ServiceSpec{Selector: map[string]string{"foo": ""}}}, }, want: []framework.NodeScore{ // Same scores as if we were using one spreading constraint. {Name: "node-a", Score: 44}, {Name: "node-b", Score: 66}, {Name: "node-c", Score: 77}, {Name: "node-d", Score: 100}, }, }, {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Dec 15 03:30:06 UTC 2023 - 60K bytes - Viewed (0)