import { Checkpoint, CheckpointId, CheckpointMetadata, CheckpointPutOptions, CheckpointStoreExt, CheckpointTuple, ListOptions, PendingWrite, PruneThreadsOptions } from "@graphorin/core";

//#region src/checkpoint-store-memory.d.ts

/**
 * Pure in-memory `CheckpointStore` implementation. Thread-safe
 * within a single Node.js event loop because every mutation is
 * synchronous; concurrent runs that share the same instance will see
 * a consistent view.
 *
 * @stable
 */
declare class InMemoryCheckpointStore implements CheckpointStoreExt {
  #private;
  put(threadId: string, namespace: string, checkpoint: Checkpoint, metadata: CheckpointMetadata, opts?: CheckpointPutOptions): Promise<CheckpointId>;
  putWrites(threadId: string, namespace: string, checkpointId: CheckpointId, writes: ReadonlyArray<PendingWrite>, taskId: string): Promise<void>;
  getTuple(threadId: string, namespace: string, checkpointId?: CheckpointId): Promise<CheckpointTuple | null>;
  list(threadId: string, namespace: string, opts?: ListOptions): AsyncIterable<CheckpointTuple>;
  deleteThread(threadId: string): Promise<void>;
  /**
   * Enumerate threads whose LATEST checkpoint in `namespace` is
   * suspended with a due `wakeAt` - parity with the SQLite adapter.
   */
  listSuspended(namespace: string, opts?: {
    readonly dueBefore?: number;
    readonly limit?: number;
  }): Promise<ReadonlyArray<{
    readonly threadId: string;
    readonly wakeAt: number;
  }>>;
  /**
   * Retention sweep - parity with the SQLite implementation:
   * namespace-SCOPED (entries key as `threadId::namespace`), latest
   * checkpoint decides age + status, suspended pairs survive unless
   * `onlyTerminal: false`.
   */
  pruneThreads(opts: PruneThreadsOptions): Promise<number>;
  /** Compaction - keep the `keepLast` newest checkpoints of one pair. */
  compactThread(threadId: string, namespace: string, keepLast: number): Promise<number>;
  /**
   * Test-only helper that exposes the raw count of stored checkpoints
   * - handy for assertions like "the runtime wrote exactly N
   * checkpoints across the run".
   */
  size(): number;
}
//#endregion
export { InMemoryCheckpointStore };
//# sourceMappingURL=checkpoint-store-memory.d.ts.map