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