import { type SharedWakeAgentJob } from './coordination';
export interface WakeAgentEnqueueResult {
    job: SharedWakeAgentJob;
    inserted: boolean;
}
export interface WakeAgentQueue {
    enqueue(job: SharedWakeAgentJob): Promise<WakeAgentEnqueueResult>;
    listQueued(thread: string, agent?: string): Promise<SharedWakeAgentJob[]>;
    close?(): Promise<void>;
}
export interface WakeAgentQueueOptions {
    redisUrl?: string;
    namespace?: string;
}
export declare function createWakeAgentQueue(options?: WakeAgentQueueOptions): WakeAgentQueue;
export declare function sharedWakeAgentJobId(input: Pick<SharedWakeAgentJob, 'thread' | 'triggerMessage' | 'agent'>): string;
export declare function wakeAgentQueueKey(job: Pick<SharedWakeAgentJob, 'thread' | 'agent'>): string;
export declare class InMemoryWakeAgentQueue implements WakeAgentQueue {
    private readonly jobsByDedupeKey;
    private readonly queueKeysByDedupeKey;
    enqueue(job: SharedWakeAgentJob): Promise<WakeAgentEnqueueResult>;
    listQueued(thread: string, agent?: string): Promise<SharedWakeAgentJob[]>;
}