import { EventBase } from "./event-base";
import { BackoffOptions } from "./types";
import { ConsumerMetrics, ConsumerOptions, GracefulShutdownOptions, SeekTarget } from "./consumer";
export interface EventBus<MessageType, HeadersType, EventIdType = string> {
    connect(...args: unknown[]): Promise<void>;
    disconnect(): Promise<void>;
    checkHealth(): Promise<boolean>;
    publish(event: EventIdType, eventData: EventBase<MessageType, HeadersType>, ...args: unknown[]): Promise<void>;
    subscribe(event: EventIdType, handler: (data: EventBase<MessageType, HeadersType>) => void): Promise<void>;
    unsubscribe(subscriptionId: string): Promise<void>;
    acknowledge?(messageId: string): Promise<void>;
    reject?(messageId: string, requeue?: boolean): Promise<void>;
    setRetryPolicy?(retries: number, delay: number, backoff?: BackoffOptions): void;
    subscribeToPattern?(pattern: string, handler: (eventId: EventIdType, event: EventBase<MessageType, HeadersType>) => void): Promise<string>;
    subscribeBatch?(event: EventIdType, handler: (events: EventBase<MessageType, HeadersType>[]) => void): Promise<string>;
    consume?(event: EventIdType, options: ConsumerOptions<MessageType, HeadersType>): Promise<string>;
    seek?(target: SeekTarget, event?: EventIdType): Promise<void>;
    pause?(events?: EventIdType[]): void;
    resume?(events?: EventIdType[]): void;
    getMetrics?(): Promise<ConsumerMetrics>;
    gracefulShutdown?(options?: GracefulShutdownOptions): Promise<void>;
}