import type { RuntimeAssignmentContext } from "./ipc-server.js";
export interface BufferedMessage {
    id: string;
    arrived_at: string;
    envelope: {
        from: string;
        content: string;
        contentType: string;
        metadata?: Record<string, unknown>;
        sourceMessageId?: string;
        runtimeAssignment?: RuntimeAssignmentContext;
    };
}
export interface ReconnectingBuffer {
    append(msg: BufferedMessage): void;
    read(): BufferedMessage[];
    drain(): BufferedMessage[];
    delete(): void;
    size(): number;
}
export interface ReconnectingBufferManager {
    forEndpoint(endpoint_id: string): ReconnectingBuffer;
    cleanup(endpoint_id: string): void;
}
export declare function createReconnectingBufferManager(buffersDir: string): ReconnectingBufferManager;
//# sourceMappingURL=reconnecting-buffer.d.ts.map