fix:es代理等待数监听功能修改

internal/service/manager.go

@@ -133,15 +133,15 @@ var (
 )
 
 func InformationNumber(ctx context.Context) map[string]interface{} {
-	rejected_count, _ := g.Redis().Get(ctx, "es_rejected_count")
-	timeout_count, _ := g.Redis().Get(ctx, "es_timeout_count")
+	rejectedCount, _ := g.Redis().Get(ctx, "es_rejected_count")
+	timeoutCount, _ := g.Redis().Get(ctx, "es_timeout_count")
 	return map[string]interface{}{
 		"simple":        g.Cfg().MustGet(ctx, "elasticSearch.pool.simple", 10).Int() - len(EsProxyManager.simpleQueryPool),   //简单执行数
 		"aggs":          g.Cfg().MustGet(ctx, "elasticSearch.pool.aggs", 10).Int() - len(EsProxyManager.aggsQueryPool),       //聚合执行数
 		"complex":       g.Cfg().MustGet(ctx, "elasticSearch.pool.complex", 10).Int() - len(EsProxyManager.complexQueryPool), //复杂执行数
 		"queueCount":    QueueCounter,                                                                                        //等待数
-		"rejectedCount": rejected_count.Val(),                                                                                //拒绝数
-		"timeOutCount":  timeout_count.Val(),                                                                                 //超时数
+		"rejectedCount": rejectedCount.Val(),                                                                                 //拒绝数
+		"timeOutCount":  timeoutCount.Val(),                                                                                  //超时数
 	}
 }
 
@@ -156,8 +156,7 @@ func RejectedIncrement(ctx context.Context) {
 func OvertimeIncrement(ctx context.Context) {
 	sn.Lock()
 	defer sn.Unlock()
-	fmt.Println("超时")
-	_, _ = g.Redis().Incr(ctx, "es_overtime_increment")
+	_, _ = g.Redis().Incr(ctx, "es_timeout_count")
 }
 
 // Increment 程序等待数