import { StreamData, StreamDataResponse, RetryPolicy } from '../../../types/stream';
export declare class ErrorHandler {
    shouldRetry(input: StreamData, output: StreamDataResponse, retry?: RetryPolicy): [boolean, number];
    structureUnhandledError(input: StreamData, err: Error): StreamDataResponse;
    structureUnacknowledgedError(input: StreamData): StreamDataResponse;
    structureError(input: StreamData, output: StreamDataResponse): StreamDataResponse;
    handleRetry(input: StreamData, output: StreamDataResponse, publishMessage: (topic: string, streamData: StreamData | StreamDataResponse) => Promise<string>, retry?: RetryPolicy, onRetryScheduled?: (topic: string, delayMs: number) => void): Promise<string>;
}