Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for SliceMapReduce (0.15 sec)

  1. staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/queueset/types.go

    	return func(set map[Elt]sets.Empty) Accumulator {
    		var ans Accumulator
    		for elt := range set {
    			ans = reduceFn(ans, mapFn(elt))
    		}
    		return ans
    	}
    }
    
    // SliceMapReduce is map-reduce starting from a slice.
    func SliceMapReduce[Elt, Result, Accumulator any](mapFn func(Elt) Result, reduceFn func(Accumulator, Result) Accumulator) func([]Elt) Accumulator {
    	return func(slice []Elt) Accumulator {
    		var ans Accumulator
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jul 18 17:38:43 UTC 2023
    - 6.9K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/queueset/queueset_test.go

    	}
    	goodSliceOfRequests := SliceMapReduce(goodRequest, or)
    	if goodSliceOfRequests(qsd.QueuelessExecutingRequests) {
    		t.Logf("Found user %s among queueless requests", username)
    		return
    	}
    	goodQueueDump := func(qd debug.QueueDump) bool {
    		return goodSliceOfRequests(qd.Requests) || goodSliceOfRequests(qd.RequestsExecuting)
    	}
    	if SliceMapReduce(goodQueueDump, or)(qsd.Queues) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Sep 26 12:55:23 UTC 2023
    - 58.4K bytes
    - Viewed (0)
Back to top