Method constructor

src/limiter.ts:33–76

(
    protected config: Config,
    protected metrics: Metrics,
    protected monitor: Monitoring,
    protected webhooks: WebHooks,
    protected hooks: Hooks,
  )

  protected logger = new Logger('limiter');

  constructor(
    protected config: Config,
    protected metrics: Metrics,
    protected monitor: Monitoring,
    protected webhooks: WebHooks,
    protected hooks: Hooks,
  ) {
    super({
      autostart: true,
      concurrency: config.getConcurrent(),
      timeout: config.getTimeout(),
    });
    this.queued = config.getQueued();

    this.logger.debug(
      `Concurrency: ${this.concurrency} queue: ${this.queued} timeout: ${this.timeout}ms`,
    );

    config.on('concurrent', (concurrency: number) => {
      this.logger.debug(`Concurrency updated to ${concurrency}`);
      this.concurrency = concurrency;
    });

    config.on('queued', (queued: number) => {
      this.logger.debug(`Queue updated to ${queued}`);
      this.queued = queued;
    });

    config.on('timeout', (timeout: number) => {
      this.logger.debug(`Timeout updated to ${timeout}ms`);
      this.timeout = timeout <= 0 ? 0 : timeout;
    });

    // eslint-disable-next-line @typescript-eslint/no-explicit-any
    this.addEventListener('timeout', this.handleJobTimeout.bind(this) as any);

    // eslint-disable-next-line @typescript-eslint/no-explicit-any
    this.addEventListener('success', this.handleSuccess.bind(this) as any);

    // eslint-disable-next-line @typescript-eslint/no-explicit-any
    this.addEventListener('error', this.handleFail.bind(this) as any);

    this.addEventListener('end', this.handleEnd.bind(this));
  }

  protected _errorHandler({
    detail: { error },