Remove calc_distance (milvus-io#25663)

Signed-off-by: Yudong Cai <yudong.cai@zilliz.com>

Author: cydrain

internal/proxy/impl.go

@@ -3150,88 +3150,12 @@ func (node *Proxy) AlterAlias(ctx context.Context, request *milvuspb.AlterAliasR
 
 // CalcDistance calculates the distances between vectors.
 func (node *Proxy) CalcDistance(ctx context.Context, request *milvuspb.CalcDistanceRequest) (*milvuspb.CalcDistanceResults, error) {
-	if !node.checkHealthy() {
-		return &milvuspb.CalcDistanceResults{
-			Status: unhealthyStatus(),
-		}, nil
-	}
-
-	ctx, sp := otel.Tracer(typeutil.ProxyRole).Start(ctx, "Proxy-CalcDistance")
-	defer sp.End()
-
-	query := func(ids *milvuspb.VectorIDs) (*milvuspb.QueryResults, error) {
-		outputFields := []string{ids.FieldName}
-
-		queryRequest := &milvuspb.QueryRequest{
-			DbName:         "",
-			CollectionName: ids.CollectionName,
-			PartitionNames: ids.PartitionNames,
-			OutputFields:   outputFields,
-		}
-
-		qt := &queryTask{
-			ctx:       ctx,
-			Condition: NewTaskCondition(ctx),
-			RetrieveRequest: &internalpb.RetrieveRequest{
-				Base: commonpbutil.NewMsgBase(
-					commonpbutil.WithMsgType(commonpb.MsgType_Retrieve),
-					commonpbutil.WithSourceID(paramtable.GetNodeID()),
-				),
-				ReqID: paramtable.GetNodeID(),
-			},
-			request: queryRequest,
-			qc:      node.queryCoord,
-			ids:     ids.IdArray,
-		}
-
-		log := log.Ctx(ctx).With(
-			zap.String("collection", queryRequest.CollectionName),
-			zap.Any("partitions", queryRequest.PartitionNames),
-			zap.Any("OutputFields", queryRequest.OutputFields))
-
-		err := node.sched.dqQueue.Enqueue(qt)
-		if err != nil {
-			log.Error("CalcDistance queryTask failed to enqueue",
-				zap.Error(err))
-
-			return &milvuspb.QueryResults{
-				Status: &commonpb.Status{
-					ErrorCode: commonpb.ErrorCode_UnexpectedError,
-					Reason:    err.Error(),
-				},
-			}, err
-		}
-
-		log.Debug("CalcDistance queryTask enqueued")
-
-		err = qt.WaitToFinish()
-		if err != nil {
-			log.Error("CalcDistance queryTask failed to WaitToFinish",
-				zap.Error(err))
-
-			return &milvuspb.QueryResults{
-				Status: &commonpb.Status{
-					ErrorCode: commonpb.ErrorCode_UnexpectedError,
-					Reason:    err.Error(),
-				},
-			}, err
-		}
-
-		log.Debug("CalcDistance queryTask Done")
-
-		return &milvuspb.QueryResults{
-			Status:     qt.result.Status,
-			FieldsData: qt.result.FieldsData,
-		}, nil
-	}
-
-	// calcDistanceTask is not a standard task, no need to enqueue
-	task := &calcDistanceTask{
-		traceID:   sp.SpanContext().TraceID().String(),
-		queryFunc: query,
-	}
-
-	return task.Execute(ctx, request)
+	return &milvuspb.CalcDistanceResults{
+		Status: &commonpb.Status{
+			ErrorCode: commonpb.ErrorCode_UnexpectedError,
+			Reason:    "interface obsolete",
+		},
+	}, nil
 }
 
 // FlushAll notifies Proxy to flush all collection's DML messages.

internal/proxy/proxy_test.go

@@ -63,9 +63,9 @@ import (
 	"github.com/milvus-io/milvus/pkg/tracer"
 	"github.com/milvus-io/milvus/pkg/util"
 	"github.com/milvus-io/milvus/pkg/util/crypto"
-	"github.com/milvus-io/milvus/pkg/util/distance"
 	"github.com/milvus-io/milvus/pkg/util/etcd"
 	"github.com/milvus-io/milvus/pkg/util/funcutil"
+	"github.com/milvus-io/milvus/pkg/util/metric"
 	"github.com/milvus-io/milvus/pkg/util/metricsinfo"
 	"github.com/milvus-io/milvus/pkg/util/paramtable"
 	"github.com/milvus-io/milvus/pkg/util/typeutil"
@@ -639,7 +639,7 @@ func TestProxy(t *testing.T) {
 				},
 				{
 					Key:   common.MetricTypeKey,
-					Value: distance.L2,
+					Value: metric.L2,
 				},
 				{
 					Key:   common.IndexTypeKey,
@@ -1543,7 +1543,7 @@ func TestProxy(t *testing.T) {
 			Params: []*commonpb.KeyValuePair{
 				{
 					Key:   common.MetricTypeKey,
-					Value: distance.L2,
+					Value: metric.L2,
 				},
 			},
 		})