- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for SeatSeconds (0.12 sec)
-
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/request/seat_seconds_test.go
"testing" "time" ) // TestSeatSecondsString exercises the SeatSeconds constructor and de-constructors (String, ToFloat). func TestSeatSecondsString(t *testing.T) { testCases := []struct { ss SeatSeconds expectFloat float64 expectStr string }{ {ss: SeatSeconds(1), expectFloat: 1.0 / ssScale, expectStr: "0.00000001ss"}, {ss: SeatSeconds(ssScale - 1), expectFloat: (ssScale - 1) / ssScale, expectStr: "0.99999999ss"},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 29 20:20:16 UTC 2021 - 2.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/request/seat_seconds.go
// MinSeatSeconds is the lowest representable value of SeatSeconds const MinSeatSeconds = SeatSeconds(0) // SeatsTimeDuration produces the SeatSeconds value for the given factors. // This is intended only to produce small values, increments in work // rather than amount of work done since process start. func SeatsTimesDuration(seats float64, duration time.Duration) SeatSeconds {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 20 09:16:46 UTC 2023 - 2.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/queueset/types.go
arrivalR fcrequest.SeatSeconds // startTime is the real time when the request began executing startTime time.Time // Indicates whether client has called Request::Wait() waitStarted bool } type completedWorkEstimate struct { fcrequest.WorkEstimate totalWork fcrequest.SeatSeconds // initial plus final work finalWork fcrequest.SeatSeconds // only final work }
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/fifo_list_test.go
update := func(we *queueSum, req *request, multiplier int) { we.InitialSeatsSum += multiplier * req.InitialSeats() we.MaxSeatsSum += multiplier * req.MaxSeats() we.TotalWorkSum += fcrequest.SeatSeconds(multiplier) * req.totalWork() } assert := func(t *testing.T, want, got *queueSum) { if !reflect.DeepEqual(want, got) { t.Errorf("Expected queue work estimate to match, diff: %s", cmp.Diff(want, got)) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jul 28 08:48:40 UTC 2022 - 7.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/queueset/queueset.go
queues []*queue // currentR is the amount of seat-seconds allocated per queue since process startup. // This is our generalization of the progress meter named R in the original fair queuing work. currentR fqrequest.SeatSeconds // lastRealTime is what `clock.Now()` yielded when `virtualTime` was last updated lastRealTime time.Time // robinIndex is the index of the last queue dispatched robinIndex int
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jan 04 16:59:21 UTC 2024 - 42.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/queueset/queueset_test.go
counter: counter, seatDemandIntegratorSubject: seatDemandIntegratorSubject, }.exercise(t) } // TestSeatSecondsRollover checks that there is not a problem with SeatSeconds overflow. func TestSeatSecondsRollover(t *testing.T) { metrics.Register() now := time.Now() const Quarter = 91 * 24 * time.Hour clk, counter := testeventclock.NewFake(now, 0, nil)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Sep 26 12:55:23 UTC 2023 - 58.4K bytes - Viewed (0)