chore: update codegen

Author: elijah-rou

vendor/knative.dev/pkg/controller/controller.go

@@ -470,7 +470,7 @@ func (c *Impl) RunContext(ctx context.Context, threadiness int) error {
 	}
 
 	// Launch workers to process resources that get enqueued to our workqueue.
-	c.logger.Infow("Starting controller and workers", zap.Int("threadiness", threadiness))
+	c.logger.Info("Starting controller and workers")
 	for range threadiness {
 		sg.Add(1)
 		go func() {

vendor/knative.dev/pkg/controller/queue_metrics.go

@@ -88,15 +88,13 @@ func (m *queueMetrics) get(item any) {
 	m.mu.Lock()
 	defer m.mu.Unlock()
 
+	m.depth.Dec()
+	m.processingStartTimes[item] = m.clock.Now()
+
 	if startTime, exists := m.addTimes[item]; exists {
-		m.depth.Dec()
 		m.latency.Observe(m.sinceInSeconds(startTime))
 		delete(m.addTimes, item)
 	}
-
-	if _, exists := m.processingStartTimes[item]; !exists {
-		m.processingStartTimes[item] = m.clock.Now()
-	}
 }
 
 func (m *queueMetrics) done(item any) {

vendor/knative.dev/pkg/controller/two_lane_queue.go

@@ -223,9 +223,9 @@ func (q *twoLaneRateLimitingQueue) slowLane() workqueue.TypedInterface[any] {
 // It gets the item from fast lane if it has anything, alternatively
 // the slow lane.
 func (tlq *twoLaneQueue) Get() (any, bool) {
-	item, shutdown := tlq.consumerQueue.Get()
+	item, ok := tlq.consumerQueue.Get()
 	tlq.metrics.get(item)
-	return item, shutdown
+	return item, ok
 }
 
 // Len returns the sum of lengths.

vendor/knative.dev/pkg/hack/update-codegen.sh

@@ -73,6 +73,7 @@ go run k8s.io/code-generator/cmd/deepcopy-gen \
   knative.dev/pkg/apis/duck/v1 \
   knative.dev/pkg/tracker \
   knative.dev/pkg/logging \
+  knative.dev/pkg/metrics \
   knative.dev/pkg/testing \
   knative.dev/pkg/testing/duck \
   knative.dev/pkg/webhook/resourcesemantics/conversion/internal

vendor/knative.dev/pkg/hack/verify-codegen.sh

@@ -37,6 +37,7 @@ cp -aR \
   "${REPO_ROOT_DIR}/go.sum" \
   "${REPO_ROOT_DIR}/apis" \
   "${REPO_ROOT_DIR}/logging" \
+  "${REPO_ROOT_DIR}/metrics" \
   "${REPO_ROOT_DIR}/testing" \
   "${REPO_ROOT_DIR}/vendor" \
   "${TMP_DIFFROOT}"
@@ -54,6 +55,9 @@ diff -Naupr --no-dereference \
 diff -Naupr --no-dereference \
   "${REPO_ROOT_DIR}/logging" "${TMP_DIFFROOT}/logging" || ret=1
 
+diff -Naupr --no-dereference \
+  "${REPO_ROOT_DIR}/metrics" "${TMP_DIFFROOT}/metrics" || ret=1
+
 diff -Naupr --no-dereference \
   "${REPO_ROOT_DIR}/testing" "${TMP_DIFFROOT}/testing" || ret=1
 
@@ -65,6 +69,7 @@ rm -fr \
   "${REPO_ROOT_DIR}/go.sum" \
   "${REPO_ROOT_DIR}/apis" \
   "${REPO_ROOT_DIR}/logging" \
+  "${REPO_ROOT_DIR}/metrics" \
   "${REPO_ROOT_DIR}/testing" \
   "${REPO_ROOT_DIR}/vendor"
 

vendor/knative.dev/pkg/network/transports.go

@@ -96,8 +96,7 @@ func dialBackOffHelper(ctx context.Context, network, address string, bo wait.Bac
 		if tlsConf == nil {
 			c, err = dialer.DialContext(ctx, network, address)
 		} else {
-			d := tls.Dialer{NetDialer: dialer, Config: tlsConf}
-			c, err = d.DialContext(ctx, network, address)
+			c, err = tls.DialWithDialer(dialer, network, address, tlsConf)
 		}
 		if err != nil {
 			var errNet net.Error