File tree Expand file tree Collapse file tree
knative.dev/pkg/controller Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -11,9 +11,9 @@ require (
1111 k8s.io/apimachinery v0.33.4
1212 k8s.io/client-go v0.33.4
1313 k8s.io/code-generator v0.33.4
14- knative.dev/eventing v0.46.3
14+ knative.dev/eventing v0.46.4
1515 knative.dev/hack v0.0.0-20250902154142-af735b2738d6
16- knative.dev/pkg v0.0.0-20250902154944-9aa11443ba68
16+ knative.dev/pkg v0.0.0-20250909011231-077dcf0d00e8
1717)
1818
1919require (
Original file line number Diff line number Diff line change @@ -833,12 +833,12 @@ k8s.io/kube-openapi v0.0.0-20250318190949-c8a335a9a2ff h1:/usPimJzUKKu+m+TE36gUy
833833k8s.io/kube-openapi v0.0.0-20250318190949-c8a335a9a2ff /go.mod h1:5jIi+8yX4RIb8wk3XwBo5Pq2ccx4FP10ohkbSKCZoK8 =
834834k8s.io/utils v0.0.0-20241210054802-24370beab758 h1:sdbE21q2nlQtFh65saZY+rRM6x6aJJI8IUa1AmH/qa0 =
835835k8s.io/utils v0.0.0-20241210054802-24370beab758 /go.mod h1:OLgZIPagt7ERELqWJFomSt595RzquPNLL48iOWgYOg0 =
836- knative.dev/eventing v0.46.3 h1:zX8OgyfLPcMAuV1nT6EdUEelCQ9oKiBmOEgWpr/wdng =
837- knative.dev/eventing v0.46.3 /go.mod h1:36jvaFTMWklGd89iqE0ikchMkdID1iNbJDLa0aPLmys =
836+ knative.dev/eventing v0.46.4 h1:Kc3TiJzVJRvH/XE0zT14J1L+OgBykzYzobvCcit8jJE =
837+ knative.dev/eventing v0.46.4 /go.mod h1:KkMqluebpiT7TCXwqUfI0cG2EfZ8yjlapOlwOHYEnL4 =
838838knative.dev/hack v0.0.0-20250902154142-af735b2738d6 h1:JYZgO9bni32T+BB5v6WpeRFm1hjj+EypBLZCk6HZBt0 =
839839knative.dev/hack v0.0.0-20250902154142-af735b2738d6 /go.mod h1:R0ritgYtjLDO9527h5vb5X6gfvt5LCrJ55BNbVDsWiY =
840- knative.dev/pkg v0.0.0-20250902154944-9aa11443ba68 h1:QlgJtxC1LtNf9k1OMSHdr3dq+HjtOOmB/SV/SklVt2k =
841- knative.dev/pkg v0.0.0-20250902154944-9aa11443ba68 /go.mod h1:a1amDzo4YIUNuGeDgEz/uDHs5MQVYI1DXnRnEpWCAts =
840+ knative.dev/pkg v0.0.0-20250909011231-077dcf0d00e8 h1:n0BMHXIem9MyDkK4vfA4Vzdxaf1e+EeLJ6k+8exCjjI =
841+ knative.dev/pkg v0.0.0-20250909011231-077dcf0d00e8 /go.mod h1:a1amDzo4YIUNuGeDgEz/uDHs5MQVYI1DXnRnEpWCAts =
842842rsc.io/binaryregexp v0.2.0 /go.mod h1:qTv7/COck+e2FymRvadv62gMdZztPaShugOCi3I+8D8 =
843843rsc.io/quote/v3 v3.1.0 /go.mod h1:yEA65RcK8LyAZtP9Kv3t0HmxON59tX3rD+tICJqUlj0 =
844844rsc.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 @@ -1114,7 +1114,7 @@ k8s.io/utils/net
11141114k8s.io/utils/pointer
11151115k8s.io/utils/ptr
11161116k8s.io/utils/trace
1117- # knative.dev/eventing v0.46.3
1117+ # knative.dev/eventing v0.46.4
11181118## explicit; go 1.24.0
11191119knative.dev/eventing/cmd/heartbeats
11201120knative.dev/eventing/pkg/adapter/v2
@@ -1227,7 +1227,7 @@ knative.dev/eventing/test/test_images/recordevents
12271227# knative.dev/hack v0.0.0-20250902154142-af735b2738d6
12281228## explicit; go 1.21
12291229knative.dev/hack
1230- # knative.dev/pkg v0.0.0-20250902154944-9aa11443ba68
1230+ # knative.dev/pkg v0.0.0-20250909011231-077dcf0d00e8
12311231## explicit; go 1.24.0
12321232knative.dev/pkg/apis
12331233knative.dev/pkg/apis/duck
You can’t perform that action at this time.
0 commit comments