Add refresh path to proxy (#21933)

/kind improvement
Signed-off-by: NYuchen Gao <yuchen.gao@zilliz.com>

internal/proxy/impl.go

@@ -383,7 +383,8 @@ func (node *Proxy) LoadCollection(ctx context.Context, request *milvuspb.LoadCol
 	log := log.Ctx(ctx).With(
 		zap.String("role", typeutil.ProxyRole),
 		zap.String("db", request.DbName),
-		zap.String("collection", request.CollectionName))
+		zap.String("collection", request.CollectionName),
+		zap.Bool("refreshMode", request.Refresh))
 
 	log.Debug("LoadCollection received")
 
@@ -1129,7 +1130,8 @@ func (node *Proxy) LoadPartitions(ctx context.Context, request *milvuspb.LoadPar
 		zap.String("role", typeutil.ProxyRole),
 		zap.String("db", request.DbName),
 		zap.String("collection", request.CollectionName),
-		zap.Any("partitions", request.PartitionNames))
+		zap.Strings("partitions", request.PartitionNames),
+		zap.Bool("refreshMode", request.Refresh))
 
 	log.Debug(rpcReceived(method))
 

internal/proxy/task.go

@@ -1369,6 +1369,7 @@ func (lct *loadCollectionTask) Execute(ctx context.Context) (err error) {
 		Schema:        collSchema,
 		ReplicaNumber: lct.ReplicaNumber,
 		FieldIndexID:  fieldIndexIDs,
+		Refresh:       lct.Refresh,
 	}
 	log.Debug("send LoadCollectionRequest to query coordinator",
 		zap.Any("schema", request.Schema))
@@ -1595,6 +1596,7 @@ func (lpt *loadPartitionsTask) Execute(ctx context.Context) error {
 		Schema:        collSchema,
 		ReplicaNumber: lpt.ReplicaNumber,
 		FieldIndexID:  fieldIndexIDs,
+		Refresh:       lpt.Refresh,
 	}
 	lpt.result, err = lpt.queryCoord.LoadPartitions(ctx, request)
 	return err

internal/querycoordv2/services.go

@@ -213,6 +213,7 @@ func (s *Server) LoadCollection(ctx context.Context, req *querypb.LoadCollection
 		zap.Any("schema", req.Schema),
 		zap.Int32("replicaNumber", req.ReplicaNumber),
 		zap.Int64s("fieldIndexes", lo.Values(req.GetFieldIndexID())),
+		zap.Bool("refreshMode", req.GetRefresh()),
 	)
 	metrics.QueryCoordLoadCount.WithLabelValues(metrics.TotalLabel).Inc()
 
@@ -301,6 +302,7 @@ func (s *Server) LoadPartitions(ctx context.Context, req *querypb.LoadPartitions
 		zap.Int64("collectionID", req.GetCollectionID()),
 		zap.Int32("replicaNumber", req.GetReplicaNumber()),
 		zap.Strings("resourceGroups", req.GetResourceGroups()),
+		zap.Bool("refreshMode", req.GetRefresh()),
 	)
 
 	log.Info("received load partitions request",