File tree Expand file tree Collapse file tree 5 files changed +11
-9
lines changed
knative.dev/pkg/controller Expand file tree Collapse file tree 5 files changed +11
-9
lines changed Original file line number Diff line number Diff line change @@ -11,7 +11,7 @@ require (
1111 k8s.io/code-generator v0.33.4
1212 k8s.io/kube-openapi v0.0.0-20250318190949-c8a335a9a2ff
1313 knative.dev/hack v0.0.0-20250902154142-af735b2738d6
14- knative.dev/pkg v0.0.0-20250821143151-4ffdcf6b3fa5
14+ knative.dev/pkg v0.0.0-20250909011231-077dcf0d00e8
1515)
1616
1717require (
Original file line number Diff line number Diff line change @@ -186,8 +186,8 @@ k8s.io/utils v0.0.0-20241210054802-24370beab758 h1:sdbE21q2nlQtFh65saZY+rRM6x6aJ
186186k8s.io/utils v0.0.0-20241210054802-24370beab758 /go.mod h1:OLgZIPagt7ERELqWJFomSt595RzquPNLL48iOWgYOg0 =
187187knative.dev/hack v0.0.0-20250902154142-af735b2738d6 h1:JYZgO9bni32T+BB5v6WpeRFm1hjj+EypBLZCk6HZBt0 =
188188knative.dev/hack v0.0.0-20250902154142-af735b2738d6 /go.mod h1:R0ritgYtjLDO9527h5vb5X6gfvt5LCrJ55BNbVDsWiY =
189- knative.dev/pkg v0.0.0-20250821143151-4ffdcf6b3fa5 h1:2U4nNoTuF/3enFcPp1BVQXCjUC4XfieIHkZeuU7j8uA =
190- knative.dev/pkg v0.0.0-20250821143151-4ffdcf6b3fa5 /go.mod h1:ewap/fhCZCh6Gm+F6udBION8T2+UcJFK4L1Ss/5K8Dw =
189+ knative.dev/pkg v0.0.0-20250909011231-077dcf0d00e8 h1:n0BMHXIem9MyDkK4vfA4Vzdxaf1e+EeLJ6k+8exCjjI =
190+ knative.dev/pkg v0.0.0-20250909011231-077dcf0d00e8 /go.mod h1:a1amDzo4YIUNuGeDgEz/uDHs5MQVYI1DXnRnEpWCAts =
191191sigs.k8s.io/json v0.0.0-20241014173422-cfa47c3a1cc8 h1:gBQPwqORJ8d8/YNZWEjoZs7npUVDpVXUUOFfW6CgAqE =
192192sigs.k8s.io/json v0.0.0-20241014173422-cfa47c3a1cc8 /go.mod h1:mdzfpAEoE6DHQEN0uh9ZbOCuHbLK5wOm7dK4ctXE9Tg =
193193sigs.k8s.io/randfill v0.0.0-20250304075658-069ef1bbf016 /go.mod h1:XeLlZ/jmk4i1HRopwe7/aU3H5n1zNUcX6TM94b3QxOY =
Original file line number Diff line number Diff line change @@ -88,13 +88,15 @@ func (m *queueMetrics) get(item any) {
8888 m .mu .Lock ()
8989 defer m .mu .Unlock ()
9090
91- m .depth .Dec ()
92- m .processingStartTimes [item ] = m .clock .Now ()
93-
9491 if startTime , exists := m .addTimes [item ]; exists {
92+ m .depth .Dec ()
9593 m .latency .Observe (m .sinceInSeconds (startTime ))
9694 delete (m .addTimes , item )
9795 }
96+
97+ if _ , exists := m .processingStartTimes [item ]; ! exists {
98+ m .processingStartTimes [item ] = m .clock .Now ()
99+ }
98100}
99101
100102func (m * queueMetrics ) done (item any ) {
Original file line number Diff line number Diff line change @@ -223,9 +223,9 @@ func (q *twoLaneRateLimitingQueue) slowLane() workqueue.TypedInterface[any] {
223223// It gets the item from fast lane if it has anything, alternatively
224224// the slow lane.
225225func (tlq * twoLaneQueue ) Get () (any , bool ) {
226- item , ok := tlq .consumerQueue .Get ()
226+ item , shutdown := tlq .consumerQueue .Get ()
227227 tlq .metrics .get (item )
228- return item , ok
228+ return item , shutdown
229229}
230230
231231// Len returns the sum of lengths.
Original file line number Diff line number Diff line change @@ -721,7 +721,7 @@ k8s.io/utils/trace
721721# knative.dev/hack v0.0.0-20250902154142-af735b2738d6
722722## explicit; go 1.21
723723knative.dev/hack
724- # knative.dev/pkg v0.0.0-20250821143151-4ffdcf6b3fa5
724+ # knative.dev/pkg v0.0.0-20250909011231-077dcf0d00e8
725725## explicit; go 1.24.0
726726knative.dev/pkg/apis
727727knative.dev/pkg/apis/duck
You can’t perform that action at this time.
0 commit comments