mogami-stream - v0.2.0
    Preparing search index...

    Interface RetryOptions

    Retry configuration for individual mapper failures. Upstream read errors and cleanup errors are not retried.

    interface RetryOptions {
        delayMs?: number | ((error: unknown, context: MapContext) => number);
        retries: number;
        shouldRetry?: (
            error: unknown,
            context: MapContext,
        ) => boolean | PromiseLike<boolean>;
    }
    Index
    delayMs?: number | ((error: unknown, context: MapContext) => number)

    Delay in milliseconds before the next retry, or a synchronous function that computes the delay from the failed attempt. Must be finite and non-negative. Defaults to 0.

    retries: number

    Maximum number of retry attempts after the initial failure. Must be a non-negative safe integer (0 disables retries).

    shouldRetry?: (
        error: unknown,
        context: MapContext,
    ) => boolean | PromiseLike<boolean>

    Predicate called after a failed attempt to decide whether to retry. Receives the error and the failed attempt's context. Defaults to retrying all mapper errors.