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