File tree Expand file tree Collapse file tree 5 files changed +15
-13
lines changed
knative.dev/pkg/controller Expand file tree Collapse file tree 5 files changed +15
-13
lines changed Original file line number Diff line number Diff line change @@ -13,8 +13,8 @@ require (
1313 k8s.io/apimachinery v0.33.4
1414 k8s.io/client-go v0.33.4
1515 knative.dev/hack v0.0.0-20250902154142-af735b2738d6
16- knative.dev/networking v0.0.0-20250902160145-7dad473f6351
17- knative.dev/pkg v0.0.0-20250902154944-9aa11443ba68
16+ knative.dev/networking v0.0.0-20250912164322-3fcdea3327b7
17+ knative.dev/pkg v0.0.0-20250909011231-077dcf0d00e8
1818 sigs.k8s.io/yaml v1.6.0
1919)
2020
Original file line number Diff line number Diff line change @@ -268,10 +268,10 @@ k8s.io/utils v0.0.0-20241210054802-24370beab758 h1:sdbE21q2nlQtFh65saZY+rRM6x6aJ
268268k8s.io/utils v0.0.0-20241210054802-24370beab758 /go.mod h1:OLgZIPagt7ERELqWJFomSt595RzquPNLL48iOWgYOg0 =
269269knative.dev/hack v0.0.0-20250902154142-af735b2738d6 h1:JYZgO9bni32T+BB5v6WpeRFm1hjj+EypBLZCk6HZBt0 =
270270knative.dev/hack v0.0.0-20250902154142-af735b2738d6 /go.mod h1:R0ritgYtjLDO9527h5vb5X6gfvt5LCrJ55BNbVDsWiY =
271- knative.dev/networking v0.0.0-20250902160145-7dad473f6351 h1:Gv/UqbN0AK+ORoT5e2Kg+3+uMW/y9CCdhpXKxYaVV6k =
272- knative.dev/networking v0.0.0-20250902160145-7dad473f6351 /go.mod h1:P/fAhhVDgmLt1ugFX8vBvdSDiUOw2P4SGcjbzoZ02Xw =
273- knative.dev/pkg v0.0.0-20250902154944-9aa11443ba68 h1:QlgJtxC1LtNf9k1OMSHdr3dq+HjtOOmB/SV/SklVt2k =
274- knative.dev/pkg v0.0.0-20250902154944-9aa11443ba68 /go.mod h1:a1amDzo4YIUNuGeDgEz/uDHs5MQVYI1DXnRnEpWCAts =
271+ knative.dev/networking v0.0.0-20250912164322-3fcdea3327b7 h1:znAKzAIZRONj/3/sj29h3LymPvXc58nsF6P/8yDqEwc =
272+ knative.dev/networking v0.0.0-20250912164322-3fcdea3327b7 /go.mod h1:+yUXx0sIKx5tzyW10GFcUSTfhuxNJhaGgvpXcv6PeHI =
273+ knative.dev/pkg v0.0.0-20250909011231-077dcf0d00e8 h1:n0BMHXIem9MyDkK4vfA4Vzdxaf1e+EeLJ6k+8exCjjI =
274+ knative.dev/pkg v0.0.0-20250909011231-077dcf0d00e8 /go.mod h1:a1amDzo4YIUNuGeDgEz/uDHs5MQVYI1DXnRnEpWCAts =
275275sigs.k8s.io/json v0.0.0-20241014173422-cfa47c3a1cc8 h1:gBQPwqORJ8d8/YNZWEjoZs7npUVDpVXUUOFfW6CgAqE =
276276sigs.k8s.io/json v0.0.0-20241014173422-cfa47c3a1cc8 /go.mod h1:mdzfpAEoE6DHQEN0uh9ZbOCuHbLK5wOm7dK4ctXE9Tg =
277277sigs.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 @@ -1100,7 +1100,7 @@ k8s.io/utils/trace
11001100# knative.dev/hack v0.0.0-20250902154142-af735b2738d6
11011101## explicit; go 1.21
11021102knative.dev/hack
1103- # knative.dev/networking v0.0.0-20250902160145-7dad473f6351
1103+ # knative.dev/networking v0.0.0-20250912164322-3fcdea3327b7
11041104## explicit; go 1.24.0
11051105knative.dev/networking/config
11061106knative.dev/networking/pkg
@@ -1150,7 +1150,7 @@ knative.dev/networking/test/test_images/runtime/handlers
11501150knative.dev/networking/test/test_images/timeout
11511151knative.dev/networking/test/test_images/wsserver
11521152knative.dev/networking/test/types
1153- # knative.dev/pkg v0.0.0-20250902154944-9aa11443ba68
1153+ # knative.dev/pkg v0.0.0-20250909011231-077dcf0d00e8
11541154## explicit; go 1.24.0
11551155knative.dev/pkg/apis
11561156knative.dev/pkg/apis/duck
You can’t perform that action at this time.
0 commit comments