import { TokenBucketLimiter, RollingWindowLimiter } from '@dutu/rate-limiter'
const rateLimiter = new TokenBucketLimiter({ bucketSize: 10, tokensPerInterval: 1, interval: 'sec'})
const throttledQueue = new ThrottledQueue({ rateLimiter, maxConcurrent: 1, minDelay: 0, timeout: 0 })

throttledQueue.add({ id : 'someId', priority: 5, timeout: 0 }, async () => {
  // async function/promise
  await delay(5000)
})

throttledQueue.pause(500)
throttledQueue.pause(null)

throttledQueue.start()

throttledQueue.clear()

throttledQueue.getSize()
throttledQueue.getSize({ priority: 5 })

throttledQueue.on("enqueue", function (info) {
  // This event is triggered when a job is added to the queue
});

throttledQueue.on("dequeue", function (info) {
  // This event is triggered when a job is removed from the queue (for execution)
});

throttledQueue.on("execute", function (error, jobId) {
  // This will be called when a job starts executing
});

throttledQueue.on("done", function (error, jobId) {
  // This will be called when a job execution completes successfully
});

throttledQueue.on("failed", function (error, jobId) {
  // This will be called when a job fails
});