import { EventBase } from "./event-base";
export type BackoffOptions = {
    maxDelay?: number;
    multiplier?: number;
    jitter?: boolean;
    type: "fixed" | "exponential";
};
export interface EventProcessorOptions<MessageType, HeadersType = Record<string, unknown>> {
    retries?: number;
    retryDelay?: number;
    backoff?: BackoffOptions;
    dlq?: {
        enabled: boolean;
        topic: string;
    };
    maxParallelism?: number;
    processingStrategy?: EventProcessingStrategy<MessageType, HeadersType>;
    callbacks?: {
        onError?: (error: Error, event: EventBase<MessageType, HeadersType>) => void;
        onSuccess?: (event: EventBase<MessageType, HeadersType>) => void;
        onClose?: () => void;
        onRetry?: (error: Error, event: EventBase<MessageType, HeadersType>, attempt: number) => void;
    };
}
export interface EventProcessingStrategy<MessageType, HeadersType = Record<string, unknown>> {
    process(event: EventBase<MessageType, HeadersType>, handler: (event: EventBase<MessageType, HeadersType>) => Promise<void>): Promise<void>;
}