enhance: remove the rpc level of coordinator (#37876)

issue: #33285 pr: #37722 - move most cgo opeartions related to search/query into segcore package for reusing for streamingnode. - add go unittest for segcore operations. Signed-off-by: chyezh <[email protected]>
milvus-io · Nov 21, 2024 · 1a6b98b · 1a6b98b
1 parent 99da46d
commit 1a6b98b
Show file tree

Hide file tree

Showing 16 changed files with 2,439 additions and 42 deletions.
diff --git a/cmd/milvus/util.go b/cmd/milvus/util.go
@@ -20,6 +20,7 @@ import (
 	"go.uber.org/zap"
 
 	"github.com/milvus-io/milvus/cmd/roles"
+	"github.com/milvus-io/milvus/internal/coordinator/coordclient"
 	"github.com/milvus-io/milvus/internal/util/sessionutil"
 	"github.com/milvus-io/milvus/pkg/log"
 	"github.com/milvus-io/milvus/pkg/util/etcd"
@@ -171,7 +172,12 @@ func GetMilvusRoles(args []string, flags *flag.FlagSet) *roles.MilvusRoles {
 		fmt.Fprintf(os.Stderr, "Unknown server type = %s\n%s", serverType, getHelp())
 		os.Exit(-1)
 	}
-
+	coordclient.EnableLocalClientRole(&coordclient.LocalClientRoleConfig{
+		ServerType:       serverType,
+		EnableQueryCoord: role.EnableQueryCoord,
+		EnableDataCoord:  role.EnableDataCoord,
+		EnableRootCoord:  role.EnableRootCoord,
+	})
 	return role
 }