diff --git a/internal/distributed/proxy/service.go b/internal/distributed/proxy/service.go index 234b5e3d34..3f59360de1 100644 --- a/internal/distributed/proxy/service.go +++ b/internal/distributed/proxy/service.go @@ -1099,11 +1099,21 @@ func (s *Server) ListResourceGroups(ctx context.Context, req *milvuspb.ListResou } func (s *Server) ListIndexedSegment(ctx context.Context, req *federpb.ListIndexedSegmentRequest) (*federpb.ListIndexedSegmentResponse, error) { - panic("TODO: implement me") + return &federpb.ListIndexedSegmentResponse{ + Status: &commonpb.Status{ + ErrorCode: commonpb.ErrorCode_UnexpectedError, + Reason: "not implemented", + }, + }, nil } func (s *Server) DescribeSegmentIndexData(ctx context.Context, req *federpb.DescribeSegmentIndexDataRequest) (*federpb.DescribeSegmentIndexDataResponse, error) { - panic("TODO: implement me") + return &federpb.DescribeSegmentIndexDataResponse{ + Status: &commonpb.Status{ + ErrorCode: commonpb.ErrorCode_UnexpectedError, + Reason: "not implemented", + }, + }, nil } func (s *Server) Connect(ctx context.Context, req *milvuspb.ConnectRequest) (*milvuspb.ConnectResponse, error) { diff --git a/internal/distributed/proxy/service_test.go b/internal/distributed/proxy/service_test.go index 97455b96c1..38c0d1aa3b 100644 --- a/internal/distributed/proxy/service_test.go +++ b/internal/distributed/proxy/service_test.go @@ -42,6 +42,7 @@ import ( "google.golang.org/grpc/health/grpc_health_v1" "github.com/milvus-io/milvus-proto/go-api/v2/commonpb" + "github.com/milvus-io/milvus-proto/go-api/v2/federpb" "github.com/milvus-io/milvus-proto/go-api/v2/milvuspb" "github.com/milvus-io/milvus/internal/mocks" "github.com/milvus-io/milvus/internal/proto/datapb" @@ -1717,3 +1718,25 @@ func Test_NewServer_GetVersion(t *testing.T) { assert.NoError(t, err) }) } + +func TestNotImplementedAPIs(t *testing.T) { + server := getServer(t) + + t.Run("ListIndexedSegment", func(t *testing.T) { + assert.NotPanics(t, func() { + resp, err := server.ListIndexedSegment(context.TODO(), &federpb.ListIndexedSegmentRequest{}) + assert.NoError(t, err) + assert.NotNil(t, resp) + assert.Equal(t, commonpb.ErrorCode_UnexpectedError, resp.GetStatus().GetErrorCode()) + }) + }) + + t.Run("DescribeSegmentIndexData", func(t *testing.T) { + assert.NotPanics(t, func() { + resp, err := server.DescribeSegmentIndexData(context.TODO(), &federpb.DescribeSegmentIndexDataRequest{}) + assert.NoError(t, err) + assert.NotNil(t, resp) + assert.Equal(t, commonpb.ErrorCode_UnexpectedError, resp.GetStatus().GetErrorCode()) + }) + }) +}