import { StreamData, StreamDataResponse, RetryPolicy } from '../../../types/stream';
export declare class ErrorHandler {
    shouldRetry(input: StreamData, output: StreamDataResponse, retryPolicy?: 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>, retryPolicy?: RetryPolicy): Promise<string>;
}