提交 12d40247 编写于 作者: 7 710leo

fix: clude api get redundant tags

上级 9cb07f12
...@@ -94,7 +94,7 @@ func Rebuild(persistenceDir string, concurrency int) { ...@@ -94,7 +94,7 @@ func Rebuild(persistenceDir string, concurrency int) {
} }
if err := RebuildFromDisk(dbDir, concurrency); err != nil { if err := RebuildFromDisk(dbDir, concurrency); err != nil {
logger.Errorf("rebuild index from local disk error:%+v", err) logger.Warningf("rebuild index from local disk error:%+v", err)
} }
} }
......
...@@ -265,10 +265,11 @@ func GetIndexByClude(c *gin.Context) { ...@@ -265,10 +265,11 @@ func GetIndexByClude(c *gin.Context) {
excludeList := r.Exclude excludeList := r.Exclude
step := 0 step := 0
dsType := "" dsType := ""
for _, endpoint := range r.Endpoints {
tagList := make([]string, 0) tagList := make([]string, 0)
tagFilter := make(map[string]struct{}) tagFilter := make(map[string]struct{})
for _, endpoint := range r.Endpoints {
if endpoint == "" { if endpoint == "" {
logger.Debugf("invalid request: lack of endpoint param:%v\n", r) logger.Debugf("invalid request: lack of endpoint param:%v\n", r)
stats.Counter.Set("xclude.miss", 1) stats.Counter.Set("xclude.miss", 1)
......
...@@ -20,7 +20,7 @@ func NodataJudge(concurrency int) { ...@@ -20,7 +20,7 @@ func NodataJudge(concurrency int) {
} }
nodataJob = semaphore.NewSemaphore(concurrency) nodataJob = semaphore.NewSemaphore(concurrency)
t1 := time.NewTicker(time.Duration(9000) * time.Millisecond) t1 := time.NewTicker(time.Duration(10) * time.Second)
nodataJudge() nodataJudge()
for { for {
<-t1.C <-t1.C
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册