RetryManager

Defined in: packages/core/src/data/retry-manager.ts:151

Retry manager with exponential backoff and jitter.

Remarks

Implements exponential backoff with the formula:

delay = min(initialDelay * (backoffFactor ^ (attempt - 1)), maxDelay)

With jitter applied as:

delay = delay + (random(-1, 1) * delay * jitterFactor)

Jitter helps prevent thundering herd problems when multiple clients retry simultaneously.

Example

const retry = new RetryManager({
  maxRetries: 5,
  initialDelay: 1000,
  backoffFactor: 2,
});

try {
  const result = await retry.execute(
    async () => {
      const response = await fetch('https://api.example.com/data');
      if (!response.ok) throw new Error('Request failed');
      return response.json();
    },
    {
      onRetry: (attempt, delay, error) => {
        console.log(`Retry ${attempt} in ${delay}ms: ${error.message}`);
      },
    }
  );
  console.log('Success:', result);
} catch (error) {
  console.error('All retries failed:', error);
}

Constructors

Constructor

new RetryManager(config?): RetryManager

Defined in: packages/core/src/data/retry-manager.ts:168

Create a new RetryManager instance

Parameters

Parameter	Type	Description
config?	Partial<RetryConfig>	Retry configuration options

Returns

RetryManager

Methods

calculateDelay()

calculateDelay(attempt): number

Defined in: packages/core/src/data/retry-manager.ts:253

Calculate delay for a given attempt using exponential backoff

Parameters

Parameter	Type	Description
attempt	number	Current attempt number (1-indexed)

Returns

number

Delay in milliseconds

Example

const retry = new RetryManager({ initialDelay: 1000, backoffFactor: 2 });
console.log(retry.calculateDelay(1)); // ~1000ms
console.log(retry.calculateDelay(2)); // ~2000ms
console.log(retry.calculateDelay(3)); // ~4000ms

---

execute()

execute<T>(fn, callbacks?): Promise<T>

Defined in: packages/core/src/data/retry-manager.ts:196

Execute a function with retry logic

Type Parameters

Type Parameter	Description
T	Return type of the function

Parameters

Parameter	Type	Description
fn	() => Promise<T>	Async function to execute with retries
callbacks?	RetryCallbacks	Optional lifecycle callbacks

Returns

Promise<T>

Promise that resolves with the function’s result

Throws

When all retry attempts fail

Example

const data = await retry.execute(
  () => fetchData(url),
  {
    isRetryable: (error) => {
      // Don't retry 4xx errors except 429 (rate limit)
      if (error.message.includes('429')) return true;
      if (error.message.match(/4\d\d/)) return false;
      return true;
    },
  }
);

---

reset()

reset(): void

Defined in: packages/core/src/data/retry-manager.ts:281

Reset internal state

Returns

void

Remarks

Currently this class is stateless, but this method is provided for API consistency and future extensibility.