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 @@ -50,8 +50,8 @@ require (
5050 k8s.io/utils v0.0.0-20241210054802-24370beab758
5151 knative.dev/hack v0.0.0-20250902154142-af735b2738d6
5252 knative.dev/hack/schema v0.0.0-20250902154142-af735b2738d6
53- knative.dev/pkg v0.0.0-20250821143151-4ffdcf6b3fa5
54- knative.dev/reconciler-test v0.0.0-20250821144151-207031116b7d
53+ knative.dev/pkg v0.0.0-20250909011231-077dcf0d00e8
54+ knative.dev/reconciler-test v0.0.0-20250902155644-548dffd12a48
5555 sigs.k8s.io/randfill v1.0.0
5656 sigs.k8s.io/yaml v1.6.0
5757)
Original file line number Diff line number Diff line change @@ -1133,10 +1133,10 @@ knative.dev/hack v0.0.0-20250902154142-af735b2738d6 h1:JYZgO9bni32T+BB5v6WpeRFm1
11331133knative.dev/hack v0.0.0-20250902154142-af735b2738d6 /go.mod h1:R0ritgYtjLDO9527h5vb5X6gfvt5LCrJ55BNbVDsWiY =
11341134knative.dev/hack/schema v0.0.0-20250902154142-af735b2738d6 h1:RIPnscHomWR2WxXJ84/JOU72SSatNZX+nsA2mN9B39g =
11351135knative.dev/hack/schema v0.0.0-20250902154142-af735b2738d6 /go.mod h1:KkibP1IazICP5ClxwN5D26LDSygsqbYnVGuGFTsHNOQ =
1136- knative.dev/pkg v0.0.0-20250821143151-4ffdcf6b3fa5 h1:2U4nNoTuF/3enFcPp1BVQXCjUC4XfieIHkZeuU7j8uA =
1137- knative.dev/pkg v0.0.0-20250821143151-4ffdcf6b3fa5 /go.mod h1:ewap/fhCZCh6Gm+F6udBION8T2+UcJFK4L1Ss/5K8Dw =
1138- knative.dev/reconciler-test v0.0.0-20250821144151-207031116b7d h1:vAi2NeLP5qMXRYvFfrsPud//paEe13Z7Lm3XehcvKzs =
1139- knative.dev/reconciler-test v0.0.0-20250821144151-207031116b7d /go.mod h1:vjCHWzZlZUm7zBS+HBxrgmljJxeg0l2aerVgzNBfMkw =
1136+ knative.dev/pkg v0.0.0-20250909011231-077dcf0d00e8 h1:n0BMHXIem9MyDkK4vfA4Vzdxaf1e+EeLJ6k+8exCjjI =
1137+ knative.dev/pkg v0.0.0-20250909011231-077dcf0d00e8 /go.mod h1:a1amDzo4YIUNuGeDgEz/uDHs5MQVYI1DXnRnEpWCAts =
1138+ knative.dev/reconciler-test v0.0.0-20250902155644-548dffd12a48 h1:1a+z3OadrvoRDxYNoHuHtztngc6K6mrbzWJPnsKSnyI =
1139+ knative.dev/reconciler-test v0.0.0-20250902155644-548dffd12a48 /go.mod h1:diO3IEHuXS3CEveFUZ2sMwVX8AqdRVEmOcOf+t/7kA0 =
11401140rsc.io/binaryregexp v0.2.0 /go.mod h1:qTv7/COck+e2FymRvadv62gMdZztPaShugOCi3I+8D8 =
11411141rsc.io/quote/v3 v3.1.0 /go.mod h1:yEA65RcK8LyAZtP9Kv3t0HmxON59tX3rD+tICJqUlj0 =
11421142rsc.io/sampler v1.3.0 /go.mod h1:T1hPZKmBbMNahiBKFy5HrXp6adAjACjK9JXDnKaTXpA =
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 @@ -1239,7 +1239,7 @@ knative.dev/hack/schema/commands
12391239knative.dev/hack/schema/docs
12401240knative.dev/hack/schema/registry
12411241knative.dev/hack/schema/schema
1242- # knative.dev/pkg v0.0.0-20250821143151-4ffdcf6b3fa5
1242+ # knative.dev/pkg v0.0.0-20250909011231-077dcf0d00e8
12431243## explicit; go 1.24.0
12441244knative.dev/pkg/apiextensions/storageversion
12451245knative.dev/pkg/apiextensions/storageversion/cmd/migrate
@@ -1399,7 +1399,7 @@ knative.dev/pkg/webhook/resourcesemantics
13991399knative.dev/pkg/webhook/resourcesemantics/conversion
14001400knative.dev/pkg/webhook/resourcesemantics/defaulting
14011401knative.dev/pkg/webhook/resourcesemantics/validation
1402- # knative.dev/reconciler-test v0.0.0-20250821144151-207031116b7d
1402+ # knative.dev/reconciler-test v0.0.0-20250902155644-548dffd12a48
14031403## explicit; go 1.24.0
14041404knative.dev/reconciler-test/cmd/eventshub
14051405knative.dev/reconciler-test/pkg/environment
You can’t perform that action at this time.
0 commit comments