import type { RetryStrategyConfig } from '@omnitron-dev/titan/utils';
export interface MessagingTransport {
    readonly id: string;
    readonly type: string;
    publish(channel: string, message: NotificationMessage, options?: TransportPublishOptions): Promise<TransportPublishResult>;
    subscribe(pattern: string, handler: NotificationHandler, options?: TransportSubscribeOptions): Promise<NotificationSubscription>;
    use(middleware: TransportMiddleware): void;
    healthCheck(): Promise<TransportHealth>;
    shutdown(): Promise<void>;
    waitUntilReady?(): Promise<void>;
    destroy?(): Promise<void>;
    subscribeToDLQ?(handler: NotificationHandler): Promise<void>;
    requeueFromDLQ?(count?: number): Promise<number>;
    getDLQStats?(): Promise<DLQStats>;
    getDLQMessages?(options?: DLQQueryOptions): Promise<DLQMessageInfo[]>;
    cleanupDLQ?(): Promise<number>;
    clearDLQ?(): Promise<void>;
    updateDLQConfig?(config: Partial<DLQCleanupConfig>): void;
}
export interface TransportPublishOptions {
    delayMs?: number;
    deliverAt?: number | Date;
    exactlyOnce?: boolean;
    deduplicationTTL?: number;
    dedupKey?: string;
    priority?: 'low' | 'normal' | 'high' | 'urgent';
    maxRetries?: number;
    metadata?: Record<string, unknown>;
}
export interface TransportPublishResult {
    success: boolean;
    messageIds: string[];
    status: 'published' | 'scheduled' | 'duplicate' | 'no_subscribers' | 'failed';
    patternCount: number;
    error?: string;
    timestamp: number;
}
export interface TransportSubscribeOptions {
    groupName?: string;
    consumerName?: string;
    startFrom?: '$' | '0' | string;
    maxRetries?: number;
    retryDelay?: number | ((attempt: number) => number);
    retryStrategy?: RetryStrategyConfig;
    autoAck?: boolean;
    prefetchCount?: number;
}
export type NotificationHandler = (message: IncomingNotification) => Promise<void>;
export interface IncomingNotification {
    id: string;
    channel: string;
    payload: NotificationMessage;
    timestamp: number;
    attempt: number;
    metadata?: Record<string, unknown>;
    ack(): Promise<void>;
    nack?(requeue?: boolean): Promise<void>;
}
export interface NotificationSubscription {
    id: string;
    pattern: string;
    group: string;
    isPaused: boolean;
    unsubscribe(removePattern?: boolean): Promise<void>;
    pause(): void;
    resume(): void;
    stats(): SubscriptionStats;
}
export interface SubscriptionStats {
    messages: number;
    retries: number;
    failures?: number;
    lastMessageAt?: number;
    inflightCount?: number;
}
export interface TransportHealth {
    status: 'healthy' | 'degraded' | 'unhealthy';
    connected: boolean;
    latency?: number;
    error?: string;
    details?: Record<string, unknown>;
    timestamp: number;
}
export interface NotificationMessage {
    type: string;
    data: unknown;
    id?: string;
    metadata?: Record<string, unknown>;
}
export interface DLQStats {
    totalMessages: number;
    messagesByChannel: Record<string, number>;
    oldestMessage?: number;
    newestMessage?: number;
    messagesCleanedUp: number;
    messagesArchived: number;
}
export interface DLQQueryOptions {
    channel?: string;
    limit?: number;
    offset?: number;
    maxAge?: number;
}
export interface DLQMessageInfo {
    id: string;
    channel: string;
    payload: unknown;
    error?: string;
    timestamp: number;
    attempt: number;
    age: number;
}
export interface DLQCleanupConfig {
    enabled?: boolean;
    maxAge?: number;
    maxSize?: number;
    cleanupInterval?: number;
    batchSize?: number;
    archiveBeforeDelete?: boolean;
    archivePrefix?: string;
}
export interface TransportMiddleware {
    beforePublish?(channel: string, message: NotificationMessage, options?: TransportPublishOptions): void | Promise<void>;
    afterPublish?(channel: string, message: NotificationMessage, result: TransportPublishResult, options?: TransportPublishOptions): void | Promise<void>;
    beforeProcess?(notification: IncomingNotification): void | Promise<void>;
    afterProcess?(notification: IncomingNotification): void | Promise<void>;
    onError?(notification: IncomingNotification, error: Error): void | Promise<void>;
}
export declare function generateUuid(): string;
//# sourceMappingURL=transport.interface.d.ts.map