[Controller] modify some OverwriteQueue name

deepflowio · Apr 29, 2024 · 83752cd · 83752cd
1 parent 43595ed
commit 83752cd
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/server/controller/genesis/genesis.go b/server/controller/genesis/genesis.go
@@ -84,9 +84,9 @@ func (g *Genesis) Start() {
 	genesisSyncDataChan := make(chan GenesisSyncData)
 	kubernetesDataChan := make(chan map[int]map[string]KubernetesInfo)
 	prometheusDataChan := make(chan map[int]map[string]PrometheusInfo)
-	sQueue := queue.NewOverwriteQueue("genesis sync data", g.cfg.QueueLengths)
-	kQueue := queue.NewOverwriteQueue("genesis k8s data", g.cfg.QueueLengths)
-	pQueue := queue.NewOverwriteQueue("genesis prometheus data", g.cfg.QueueLengths)
+	sQueue := queue.NewOverwriteQueue("genesis-sync-data", g.cfg.QueueLengths)
+	kQueue := queue.NewOverwriteQueue("genesis-k8s-data", g.cfg.QueueLengths)
+	pQueue := queue.NewOverwriteQueue("genesis-prometheus-data", g.cfg.QueueLengths)
 
 	// 由于可能需要从数据库恢复数据，这里先启动监听
 	go g.receiveGenesisSyncData(genesisSyncDataChan)