feat: milvus support to use username+password as auth (#751)

2025-08-14 18:49:03 +08:00
parent 174da78c78
commit a734d9d8af
2 changed files with 17 additions and 9 deletions
--- a/backend/application/knowledge/init.go
+++ b/backend/application/knowledge/init.go
@ -172,7 +172,13 @@ func getVectorStore(ctx context.Context) (searchstore.Manager, error) {
 		defer cancel()

 		milvusAddr := os.Getenv("MILVUS_ADDR")
-		mc, err := milvusclient.New(cctx, &milvusclient.ClientConfig{Address: milvusAddr})
+		user := os.Getenv("MILVUS_USER")
+		password := os.Getenv("MILVUS_PASSWORD")
+		mc, err := milvusclient.New(cctx, &milvusclient.ClientConfig{
+			Address:  milvusAddr,
+			Username: user,
+			Password: password,
+		})
 		if err != nil {
 			return nil, fmt.Errorf("init milvus client failed, err=%w", err)
 		}