/**
 * @license
 * Copyright 2025 Steven Roussey <sroussey@gmail.com>
 * SPDX-License-Identifier: Apache-2.0
 */
import { DataPortSchemaObject, FromSchema, TypedArraySchemaOptions } from "@workglow/util/schema";
import { type ITabularMigration, type ITabularMigrationApplier } from "../migrations";
import { BaseTabularStorage, ClientProvidedKeysOption, KeyGenerationStrategy } from "./BaseTabularStorage";
import { AnyTabularStorage, AutoGeneratedKeys, CoveringIndexQueryOptions, DeleteSearchCriteria, InsertEntity, QueryOptions, SearchCriteria, SimplifyPrimaryKey, TabularChangePayload, TabularSubscribeOptions } from "./ITabularStorage";
export declare const MEMORY_TABULAR_REPOSITORY: import("@workglow/util").ServiceToken<AnyTabularStorage>;
/** Non-persistent tabular storage backed by a `Map` keyed by row fingerprint. */
export declare class InMemoryTabularStorage<Schema extends DataPortSchemaObject, PrimaryKeyNames extends ReadonlyArray<keyof Schema["properties"]>, Entity = FromSchema<Schema, TypedArraySchemaOptions>, PrimaryKey = SimplifyPrimaryKey<Entity, PrimaryKeyNames>, Value = Omit<Entity, PrimaryKeyNames[number] & keyof Entity>, InsertType extends InsertEntity<Entity, AutoGeneratedKeys<Schema>> = InsertEntity<Entity, AutoGeneratedKeys<Schema>>> extends BaseTabularStorage<Schema, PrimaryKeyNames, Entity, PrimaryKey, Value, InsertType> {
    values: Map<string, Entity>;
    private autoIncrementCounter;
    /** Tracks whether the last put was an insert vs update — read by subscribeToChanges. */
    private _lastPutWasInsert;
    constructor(schema: Schema, primaryKeyNames: PrimaryKeyNames, indexes?: readonly (keyof NoInfer<Entity> | readonly (keyof NoInfer<Entity>)[])[], clientProvidedKeys?: ClientProvidedKeysOption, tabularMigrations?: ReadonlyArray<ITabularMigration>, migrationName?: string, uniqueIndexes?: readonly (readonly (keyof NoInfer<Entity>)[])[]);
    setupDatabase(): Promise<void>;
    /** In-memory rows do not survive a process restart. */
    isDurable(): boolean;
    getMigrationApplier(): ITabularMigrationApplier | null;
    protected generateKeyValue(columnName: string, strategy: KeyGenerationStrategy): string | number;
    put(value: InsertType): Promise<Entity>;
    putBulk(values: InsertType[]): Promise<Entity[]>;
    /**
     * Scan the row Map and reject `entityToStore` if any *other* row (different
     * fingerprint id) already shares the same value tuple for any declared
     * unique-index tuple. Matches the DB-level `CREATE UNIQUE INDEX` semantics
     * the SQLite/Postgres backends emit so contract tests can exercise the
     * constraint without standing up a real DB.
     */
    private assertUniqueIndexes;
    /**
     * Capture the mutable state required to roll back a batch op: the row
     * entries (a clone of the live `Map`) and the autoincrement counter. The
     * result is opaque to callers; pair with {@link restoreMutableState}.
     */
    protected snapshotMutableState(): {
        readonly entries: ReadonlyArray<readonly [string, Entity]>;
        readonly counter: number;
    };
    /**
     * Restore the row Map and autoincrement counter from a prior
     * {@link snapshotMutableState} result. Used by atomic batch overrides
     * (vector `putBulk`) to undo partial writes when a mid-batch error fires.
     */
    protected restoreMutableState(snapshot: {
        readonly entries: ReadonlyArray<readonly [string, Entity]>;
        readonly counter: number;
    }): void;
    get(key: PrimaryKey): Promise<Entity | undefined>;
    delete(value: PrimaryKey | Entity): Promise<void>;
    deleteAll(): Promise<void>;
    getAll(options?: QueryOptions<Entity>): Promise<Entity[] | undefined>;
    size(): Promise<number>;
    getOffsetPage(offset: number, limit: number): Promise<Entity[] | undefined>;
    deleteSearch(criteria: DeleteSearchCriteria<Entity>): Promise<void>;
    query(criteria: SearchCriteria<Entity>, options?: QueryOptions<Entity>): Promise<Entity[] | undefined>;
    queryIndex<K extends keyof Entity & string>(criteria: SearchCriteria<Entity>, options: CoveringIndexQueryOptions<Entity, K>): Promise<Pick<Entity, K>[]>;
    /** InMemory is both client and server, so changes flow through local events. */
    subscribeToChanges(callback: (change: TabularChangePayload<Entity>) => void, options?: TabularSubscribeOptions): () => void;
    destroy(): void;
}
//# sourceMappingURL=InMemoryTabularStorage.d.ts.map