fix params data race (#22402)

Signed-off-by: Wei Liu <wei.liu@zilliz.com>

internal/querycoordv2/balance/rowcount_based_balancer_test.go

@@ -42,7 +42,7 @@ type RowCountBasedBalancerTestSuite struct {
 }
 
 func (suite *RowCountBasedBalancerTestSuite) SetupSuite() {
-	Params.Init()
+	Params.InitOnce()
 }
 
 func (suite *RowCountBasedBalancerTestSuite) SetupTest() {

internal/querycoordv2/checkers/channel_checker_test.go

@@ -45,7 +45,7 @@ type ChannelCheckerTestSuite struct {
 }
 
 func (suite *ChannelCheckerTestSuite) SetupSuite() {
-	Params.Init()
+	Params.InitOnce()
 }
 
 func (suite *ChannelCheckerTestSuite) SetupTest() {

internal/querycoordv2/checkers/segment_checker_test.go

@@ -46,7 +46,7 @@ type SegmentCheckerTestSuite struct {
 }
 
 func (suite *SegmentCheckerTestSuite) SetupSuite() {
-	Params.Init()
+	Params.InitOnce()
 }
 
 func (suite *SegmentCheckerTestSuite) SetupTest() {

internal/querycoordv2/dist/dist_controller_test.go

@@ -47,7 +47,7 @@ type DistControllerTestSuite struct {
 }
 
 func (suite *DistControllerTestSuite) SetupTest() {
-	Params.Init()
+	Params.InitOnce()
 
 	var err error
 	config := GenerateEtcdConfig()

internal/querycoordv2/job/job_test.go

@@ -65,7 +65,7 @@ type JobSuite struct {
 }
 
 func (suite *JobSuite) SetupSuite() {
-	Params.Init()
+	Params.InitOnce()
 
 	suite.collections = []int64{1000, 1001}
 	suite.partitions = map[int64][]int64{

internal/querycoordv2/meta/collection_manager_test.go

@@ -48,7 +48,7 @@ type CollectionManagerSuite struct {
 }
 
 func (suite *CollectionManagerSuite) SetupSuite() {
-	Params.Init()
+	Params.InitOnce()
 
 	suite.collections = []int64{100, 101, 102}
 	suite.partitions = map[int64][]int64{

internal/querycoordv2/meta/replica_manager_test.go

@@ -41,7 +41,7 @@ type ReplicaManagerSuite struct {
 }
 
 func (suite *ReplicaManagerSuite) SetupSuite() {
-	Params.Init()
+	Params.InitOnce()
 
 	suite.nodes = []int64{1, 2, 3}
 	suite.collections = []int64{100, 101, 102}

internal/querycoordv2/meta/resource_manager_test.go

@@ -37,7 +37,7 @@ type ResourceManagerSuite struct {
 }
 
 func (suite *ResourceManagerSuite) SetupSuite() {
-	Params.Init()
+	Params.InitOnce()
 }
 
 func (suite *ResourceManagerSuite) SetupTest() {

internal/querycoordv2/meta/store_test.go

@@ -36,7 +36,7 @@ type StoreTestSuite struct {
 }
 
 func (suite *StoreTestSuite) SetupSuite() {
-	Params.Init()
+	Params.InitOnce()
 }
 
 func (suite *StoreTestSuite) SetupTest() {

internal/querycoordv2/meta/target_manager_test.go

@@ -52,7 +52,7 @@ type TargetManagerSuite struct {
 }
 
 func (suite *TargetManagerSuite) SetupSuite() {
-	Params.Init()
+	Params.InitOnce()
 	suite.collections = []int64{1000, 1001}
 	suite.partitions = map[int64][]int64{
 		1000: {100, 101},

internal/querycoordv2/observers/collection_observer_test.go

@@ -67,7 +67,7 @@ type CollectionObserverSuite struct {
 }
 
 func (suite *CollectionObserverSuite) SetupSuite() {
-	Params.Init()
+	Params.InitOnce()
 
 	suite.collections = []int64{100, 101, 102}
 	suite.partitions = map[int64][]int64{

internal/querycoordv2/observers/leader_observer_test.go

@@ -47,7 +47,7 @@ type LeaderObserverTestSuite struct {
 }
 
 func (suite *LeaderObserverTestSuite) SetupSuite() {
-	Params.Init()
+	Params.InitOnce()
 }
 
 func (suite *LeaderObserverTestSuite) SetupTest() {

internal/querycoordv2/observers/replica_observer_test.go

@@ -44,7 +44,7 @@ type ReplicaObserverSuite struct {
 }
 
 func (suite *ReplicaObserverSuite) SetupSuite() {
-	Params.Init()
+	Params.InitOnce()
 	Params.QueryCoordCfg.CheckNodeInReplicaInterval = 1 * time.Second
 }
 

internal/querycoordv2/observers/resource_observer_test.go

@@ -48,7 +48,7 @@ type ResourceObserverSuite struct {
 }
 
 func (suite *ResourceObserverSuite) SetupSuite() {
-	Params.Init()
+	Params.InitOnce()
 	Params.QueryCoordCfg.CheckResourceGroupInterval = 3 * time.Second
 }
 

internal/querycoordv2/observers/target_observer_test.go

@@ -53,7 +53,7 @@ type TargetObserverSuite struct {
 }
 
 func (suite *TargetObserverSuite) SetupSuite() {
-	Params.Init()
+	Params.InitOnce()
 	Params.QueryCoordCfg.UpdateNextTargetInterval = 3 * time.Second
 }
 

internal/querycoordv2/task/merger_test.go

@@ -39,7 +39,7 @@ type MergerSuite struct {
 }
 
 func (suite *MergerSuite) SetupSuite() {
-	Params.Init()
+	Params.InitOnce()
 	Params.QueryCoordCfg.TaskMergeCap = 3
 	suite.collectionID = 1000
 	suite.replicaID = 100

internal/querycoordv2/task/task_test.go

@@ -75,7 +75,7 @@ type TaskSuite struct {
 }
 
 func (suite *TaskSuite) SetupSuite() {
-	Params.Init()
+	Params.InitOnce()
 	suite.collection = 1000
 	suite.replica = 10
 	suite.subChannels = []string{

internal/querycoordv2/utils/meta_test.go

@@ -32,7 +32,7 @@ import (
 )
 
 func TestSpawnReplicasWithRG(t *testing.T) {
-	Params.Init()
+	Params.InitOnce()
 	config := GenerateEtcdConfig()
 	cli, err := etcd.GetEtcdClient(
 		config.UseEmbedEtcd,
@@ -116,7 +116,7 @@ func TestSpawnReplicasWithRG(t *testing.T) {
 }
 
 func TestAddNodesToCollectionsInRGFailed(t *testing.T) {
-	Params.Init()
+	Params.InitOnce()
 
 	store := meta.NewMockStore(t)
 	store.EXPECT().SaveCollection(mock.Anything).Return(nil)
@@ -178,7 +178,7 @@ func TestAddNodesToCollectionsInRGFailed(t *testing.T) {
 }
 
 func TestAddNodesToCollectionsInRG(t *testing.T) {
-	Params.Init()
+	Params.InitOnce()
 
 	store := meta.NewMockStore(t)
 	store.EXPECT().SaveCollection(mock.Anything).Return(nil)