/**
 * In-memory reference implementation of {@link AgentSubmissionStore}.
 *
 * Suitable for the inline runtime, dev, and tests. Single-threaded JS makes
 * every compare-and-set trivially atomic, but the observable gating
 * conditions — runnable-head FIFO per session, owner checks, first-terminal-
 * wins, idempotent admission with payload-conflict detection — match the
 * durable backends exactly so the contract suite passes unchanged.
 */
import type { AgentAttemptMarker, AgentDispatchAdmission, AgentSubmission, AgentSubmissionInput, AgentSubmissionStore, SubmissionAttemptRef, SubmissionClaimRef, AgentSubmissionDurability, SubmissionSettledRecord, SubmissionSettlementObligation } from './submission-store.js';
import type { DispatchInput } from './dispatch.js';
export declare class InMemorySubmissionStore implements AgentSubmissionStore {
    private nextSequence;
    private readonly submissions;
    private readonly dispatchReceipts;
    private readonly attemptMarkers;
    private readonly obligations;
    getSubmission(submissionId: string): Promise<AgentSubmission | null>;
    hasUnsettledSubmissions(): Promise<boolean>;
    listRunnableSubmissions(): Promise<AgentSubmission[]>;
    listUnreadySubmissions(): Promise<AgentSubmission[]>;
    listRunningSubmissions(): Promise<AgentSubmission[]>;
    listPendingSubmissionSettlements(): Promise<SubmissionSettlementObligation[]>;
    replaceSubmissionAttempt(attempt: SubmissionAttemptRef, nextAttemptId: string, lease?: {
        ownerId: string;
        leaseExpiresAt: number;
    }): Promise<AgentSubmission | null>;
    admitDispatch(input: DispatchInput): Promise<AgentDispatchAdmission>;
    admitDirect(input: AgentSubmissionInput): Promise<AgentSubmission>;
    markSubmissionCanonicalReady(submissionId: string): Promise<AgentSubmission | null>;
    claimSubmission(claim: SubmissionClaimRef): Promise<AgentSubmission | null>;
    markSubmissionInputApplied(attempt: SubmissionAttemptRef, durability?: AgentSubmissionDurability): Promise<boolean>;
    requestSubmissionRecovery(attempt: SubmissionAttemptRef): Promise<boolean>;
    requestSessionAbort(storeSessionId: string): Promise<string[]>;
    requeueSubmissionBeforeInputApplied(attempt: SubmissionAttemptRef): Promise<boolean>;
    reserveSubmissionSettlement(attempt: SubmissionAttemptRef, settlement: {
        recordId: string;
        record: SubmissionSettledRecord;
    }): Promise<SubmissionSettlementObligation | null>;
    finalizeSubmissionSettlement(attempt: SubmissionAttemptRef, recordId: string): Promise<boolean>;
    completeSubmission(attempt: SubmissionAttemptRef): Promise<boolean>;
    failSubmission(attempt: SubmissionAttemptRef, error: unknown): Promise<boolean>;
    claimJoinableSubmissions(host: SubmissionAttemptRef, agentName: string): Promise<AgentSubmission[]>;
    finalizeJoinedSubmission(host: SubmissionAttemptRef, submissionId: string): Promise<boolean>;
    revertJoiningSubmission(host: SubmissionAttemptRef, submissionId: string): Promise<boolean>;
    listJoinedSubmissions(hostSubmissionId: string): Promise<AgentSubmission[]>;
    settleJoinedSubmission(host: SubmissionAttemptRef, submissionId: string, outcome: 'completed' | 'failed' | 'aborted', error?: unknown): Promise<boolean>;
    insertAttemptMarker(attempt: SubmissionAttemptRef): Promise<void>;
    deleteAttemptMarker(attempt: SubmissionAttemptRef): Promise<void>;
    listAttemptMarkers(): Promise<AgentAttemptMarker[]>;
    deleteSessionSubmissions(storeSessionId: string): Promise<number>;
    renewLeases(ownerId: string, submissionIds: string[]): Promise<void>;
    listExpiredSubmissions(): Promise<AgentSubmission[]>;
    private admitSubmission;
    private ordered;
    private hasEarlierUnsettled;
    private ownedRunning;
    /** Serializable state used by durable adapters that wrap the reference semantics. */
    exportPersistenceSnapshot(): unknown;
    importPersistenceSnapshot(snapshot: unknown): void;
}
//# sourceMappingURL=in-memory-submission-store.d.ts.map