joao-fontenele/stable-cache

import { Policy, TimeoutStrategy } from 'cockatiel';
import { MyPolicy, PolicyLike } from './policy';

/**
 * @typedef {Object} TimeoutOptions
 * @property {?number} [timeout=null] - max amount of time in milliseconds a
 * producer call can be waited
 * @property {?string} [name=''] - name of the service for the configured retry
 * policy.
 */

export interface TimeoutOptions {
  timeout?: number,
  name?: string,
}

/**
 * Creates and holds a retry policy with exponential backoff
 */
export class TimeoutPolicy extends MyPolicy {
  options: TimeoutOptions;

  policy: PolicyLike;

  /**
   * @constructor
   * @param {TimeoutOptions} options
   */
  constructor(options: TimeoutOptions) {
    super();
    this.options = options;
    const { timeout } = this.options;
    this.policy = Policy.noop;

    if (timeout) {
      this.policy = Policy.timeout(timeout, TimeoutStrategy.Aggressive);
    }
  }
}