import type { BuiltEpisodicMemoryStore, BuiltMemory, EpisodicMemoryMethods, MemoryDescriptor, Thread } from '../../types';
import type { AgentDbMessage } from '../../types/sdk/message';
import type { ObservationCursor } from '../../types/sdk/observation';
import type { BuiltObservationLogStore, BuiltObservationLogTaskLockStore, NewObservationLogEntry, ObservationLogEntry, ObservationLogReadOptions, ObservationLogReflection, ObservationLogReflectionResult, ObservationLogScope, ObservationLogTaskKind, ObservationLogTaskLockHandle } from '../../types/sdk/observation-log';
export declare class InMemoryMemory implements BuiltMemory, BuiltObservationLogStore, BuiltObservationLogTaskLockStore, BuiltEpisodicMemoryStore {
    private threads;
    private messagesByThread;
    private observationLogByScope;
    private cursorsByScope;
    private locksByScope;
    private episodicMemory;
    private episodicMemorySources;
    private episodicMemoryCursorsByScope;
    private episodicMemoryLocksByResource;
    readonly episodic: EpisodicMemoryMethods;
    getThread(threadId: string): Promise<Thread | null>;
    saveThread(thread: Omit<Thread, 'createdAt' | 'updatedAt'>): Promise<Thread>;
    deleteThread(threadId: string): Promise<void>;
    getMessages(threadId: string, opts?: {
        limit?: number;
        before?: Date;
        resourceId?: string;
    }): Promise<AgentDbMessage[]>;
    saveMessages(args: {
        threadId: string;
        resourceId?: string;
        messages: AgentDbMessage[];
    }): Promise<void>;
    deleteMessages(messageIds: string[]): Promise<void>;
    describe(): MemoryDescriptor;
    appendObservationLogEntries(rows: NewObservationLogEntry[]): Promise<ObservationLogEntry[]>;
    getActiveObservationLog(scope: ObservationLogScope & {
        limit?: number;
        order?: 'asc' | 'desc';
    }): Promise<ObservationLogEntry[]>;
    getObservationLog(opts: ObservationLogReadOptions): Promise<ObservationLogEntry[]>;
    dropObservationLogEntries(ids: string[]): Promise<void>;
    supersedeObservationLogEntries(ids: string[], supersededBy: string): Promise<void>;
    applyObservationLogReflection(scope: ObservationLogScope, reflection: ObservationLogReflection): Promise<ObservationLogReflectionResult>;
    getMessagesForObservationScope(observationScopeId: string, opts?: {
        since?: {
            sinceCreatedAt: Date;
            sinceMessageId: string;
        };
    }): Promise<AgentDbMessage[]>;
    getCursor(observationScopeId: string): Promise<ObservationCursor | null>;
    setCursor(cursor: ObservationCursor): Promise<void>;
    acquireObservationLogTaskLock(observationScopeId: string, taskKind: ObservationLogTaskKind, opts: {
        ttlMs: number;
        holderId: string;
    }): Promise<ObservationLogTaskLockHandle | null>;
    private acquireScopeLock;
    releaseObservationLogTaskLock(handle: ObservationLogTaskLockHandle): Promise<void>;
    private releaseScopeLock;
    private saveEpisodicMemoryEntries;
    private saveEpisodicMemoryEntrySources;
    private saveEpisodicMemoryEntryWithSources;
    private searchEpisodicMemoryEntries;
    private supersedeEpisodicMemoryEntries;
    private getEpisodicMemoryEntrySources;
    private applyEpisodicMemoryReflection;
    private getEpisodicMemoryCursor;
    private setEpisodicMemoryCursor;
    private acquireEpisodicMemoryTaskLock;
    private releaseEpisodicMemoryTaskLock;
}
export declare function saveMessagesToThread(memory: BuiltMemory, threadId: string, resourceId: string, messages: AgentDbMessage[]): Promise<void>;