Record load latency for loaded collection (#20538) (#20590)

Signed-off-by: Nyah01 <yang.cen@zilliz.com>
Signed-off-by: Nyah01 <yang.cen@zilliz.com>
Signed-off-by: Nyah01 <yang.cen@zilliz.com>

internal/metrics/querycoord_metrics.go

@@ -64,8 +64,8 @@ var (
 			Namespace: milvusNamespace,
 			Subsystem: typeutil.QueryCoordRole,
 			Name:      "load_latency",
-			Help:      "latency of load request",
-			Buckets:   buckets,
+			Help:      "latency of load the entire collection",
+			Buckets:   []float64{0, 500, 1000, 2000, 5000, 10000, 20000, 50000, 60000, 300000, 600000, 1800000},
 		}, []string{})
 
 	QueryCoordReleaseLatency = prometheus.NewHistogramVec(

internal/querycoordv2/job/job.go

@@ -165,6 +165,7 @@ func (job *LoadCollectionJob) PreExecute() error {
 			log.Warn(msg)
 			return utils.WrapError(msg, ErrLoadParameterMismatched)
 		}
+
 		return ErrCollectionLoaded
 	}
 

internal/querycoordv2/observers/collection_observer.go

@@ -232,9 +232,9 @@ func (ob *CollectionObserver) observeCollectionLoadStatus(collection *meta.Colle
 	channelTargets := ob.targetMgr.GetDmChannelsByCollection(collection.GetCollectionID())
 	targetNum := len(segmentTargets) + len(channelTargets)
 	log.Info("collection targets",
-		zap.Int("segment-target-num", len(segmentTargets)),
-		zap.Int("channel-target-num", len(channelTargets)),
-		zap.Int("total-target-num", targetNum))
+		zap.Int("segmentTargetNum", len(segmentTargets)),
+		zap.Int("channelTargetNum", len(channelTargets)),
+		zap.Int("totalTargetNum", targetNum))
 	if targetNum == 0 {
 		log.Info("collection released, skip it")
 		return
@@ -296,9 +296,9 @@ func (ob *CollectionObserver) observePartitionLoadStatus(partition *meta.Partiti
 	channelTargets := ob.targetMgr.GetDmChannelsByCollection(partition.GetCollectionID())
 	targetNum := len(segmentTargets) + len(channelTargets)
 	log.Info("partition targets",
-		zap.Int("segment-target-num", len(segmentTargets)),
-		zap.Int("channel-target-num", len(channelTargets)),
-		zap.Int("total-target-num", targetNum))
+		zap.Int("segmentTargetNum", len(segmentTargets)),
+		zap.Int("channelTargetNum", len(channelTargets)),
+		zap.Int("totalTargetNum", targetNum))
 	if targetNum == 0 {
 		log.Info("partition released, skip it")
 		return