Connectum API Reference / @connectum/interceptors / retry / createRetryInterceptor

Function: createRetryInterceptor()

createRetryInterceptor(options?): Interceptor

Defined in: retry.ts:44

Create retry interceptor

Automatically retries failed unary RPC calls with exponential backoff. Only retries on configurable error codes (Unavailable and ResourceExhausted by default).

Parameters

options?

RetryOptions = {}

Retry options

Returns

Interceptor

ConnectRPC interceptor

Example

import { createServer } from '@connectum/core';
import { createRetryInterceptor } from '@connectum/interceptors';

const server = createServer({
  services: [myRoutes],
  interceptors: [
    createRetryInterceptor({
      maxRetries: 3,
      initialDelay: 200,
      maxDelay: 5000,
      retryableCodes: [Code.Unavailable, Code.ResourceExhausted],
    }),
  ],
});

await server.start();