- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for SliceMapReduce (0.15 sec)
-
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) -
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)