indexer_scheduler limiter usage change

indexer/crawler.go

@@ -145,10 +145,15 @@ func (c *CrawlDispatcher) mainLoop() {
 			pdsID := crawlJob.act.PDS
 			limiter := c.repoFetcher.GetOrCreateLimiterLazy(pdsID)
 			now := time.Now()
-			res := limiter.ReserveN(now, 1)
-			wouldDelay := res.DelayFrom(now)
-			res.Cancel()
-			crawlJob.eligibleTime = now.Add(wouldDelay)
+			avail := limiter.TokensAt(now)
+			if avail > 1 {
+				crawlJob.eligibleTime = now
+			} else {
+				rate := float64(limiter.Limit())
+				need := 1 - avail
+				wouldDelay := time.Duration(float64(time.Second) * need / rate)
+				crawlJob.eligibleTime = now.Add(wouldDelay)
+			}
 			// put crawl job on heap sorted by eligible time
 			c.enheapJob(crawlJob)
 			c.dequeueJob(crawlJob)