import type { Config } from '../../config/schema.js';
import type { AgentIPCMessage } from './types.js';
/** SQLite queue with acknowledgement after processing and renewable claims. */
export declare class AgentInbox {
    private readonly queue;
    private timer?;
    private processing;
    private stopped;
    constructor(agentId: string);
    static forAgent(_config: Config, agentId: string): AgentInbox;
    enqueue(message: AgentIPCMessage): Promise<void>;
    peek(limit?: number): Promise<AgentIPCMessage[]>;
    count(): Promise<number>;
    clearProcessed(olderThanMs?: number): Promise<number>;
    watch(handler: (msg: AgentIPCMessage) => Promise<void>): Promise<() => void>;
    stopWatching(): void;
    private processPending;
}