kvclient: move all mux rangefeed client log lines from Dev to KvExec

Epic: none

Release note: None

Author: arulajmani

pkg/kv/kvclient/kvcoord/dist_sender_mux_rangefeed.go

@@ -66,10 +66,10 @@ func muxRangeFeed(
 	eventCh chan<- RangeFeedMessage,
 ) (retErr error) {
 	if log.V(1) {
-		log.Dev.Infof(ctx, "Establishing MuxRangeFeed (%s...; %d spans)", spans[0], len(spans))
+		log.KvExec.Infof(ctx, "Establishing MuxRangeFeed (%s...; %d spans)", spans[0], len(spans))
 		start := timeutil.Now()
 		defer func() {
-			log.Dev.Infof(ctx, "MuxRangeFeed terminating after %s with err=%v", timeutil.Since(start), retErr)
+			log.KvExec.Infof(ctx, "MuxRangeFeed terminating after %s with err=%v", timeutil.Since(start), retErr)
 		}()
 	}
 
@@ -381,10 +381,10 @@ func (m *rangefeedMuxer) startNodeMuxRangeFeed(
 	defer restore()
 
 	if log.V(1) {
-		log.Dev.Infof(ctx, "Establishing MuxRangeFeed to node %d", nodeID)
+		log.KvExec.Infof(ctx, "Establishing MuxRangeFeed to node %d", nodeID)
 		start := timeutil.Now()
 		defer func() {
-			log.Dev.Infof(ctx, "MuxRangeFeed to node %d terminating after %s with err=%v",
+			log.KvExec.Infof(ctx, "MuxRangeFeed to node %d terminating after %s with err=%v",
 				nodeID, timeutil.Since(start), retErr)
 		}()
 	}
@@ -403,7 +403,7 @@ func (m *rangefeedMuxer) startNodeMuxRangeFeed(
 	maybeCloseClient := func() {
 		if closer, ok := mux.(io.Closer); ok {
 			if err := closer.Close(); err != nil {
-				log.Dev.Warningf(ctx, "error closing mux rangefeed client: %v", err)
+				log.KvExec.Warningf(ctx, "error closing mux rangefeed client: %v", err)
 			}
 		}
 	}
@@ -442,7 +442,7 @@ func (m *rangefeedMuxer) startNodeMuxRangeFeed(
 		}
 
 		if log.V(1) {
-			log.Dev.Infof(ctx, "mux to node %d restarted %d streams", ms.nodeID, len(toRestart))
+			log.KvExec.Infof(ctx, "mux to node %d restarted %d streams", ms.nodeID, len(toRestart))
 		}
 		return m.restartActiveRangeFeeds(ctx, recvErr, toRestart)
 	}
@@ -471,7 +471,7 @@ func (m *rangefeedMuxer) receiveEventsFromNode(
 		// additional event(s) arriving for a stream that is no longer active.
 		if active == nil {
 			if log.V(1) {
-				log.Dev.Infof(ctx, "received stray event stream %d: %v", event.StreamID, event)
+				log.KvExec.Infof(ctx, "received stray event stream %d: %v", event.StreamID, event)
 			}
 			continue
 		}
@@ -566,7 +566,7 @@ func (m *rangefeedMuxer) restartActiveRangeFeed(
 	}
 
 	if log.V(1) {
-		log.Dev.Infof(ctx, "RangeFeed %s@%s (r%d, replica %s) disconnected with last checkpoint %s ago: %v (errInfo %v)",
+		log.KvExec.Infof(ctx, "RangeFeed %s@%s (r%d, replica %s) disconnected with last checkpoint %s ago: %v (errInfo %v)",
 			active.Span, active.StartAfter, active.RangeID, active.ReplicaDescriptor,
 			timeutil.Since(active.Resolved.GoTime()), reason, errInfo)
 	}