/**
 * @license
 * Copyright 2025 Steven Roussey <sroussey@gmail.com>
 * SPDX-License-Identifier: Apache-2.0
 */
import type { DataPortSchemaObject, FromSchema, TypedArraySchemaOptions } from "@workglow/util/schema";
import type { ITabularMigrationApplier } from "../migrations";
import type { AutoGeneratedKeys, CoveringIndexQueryOptions, DeleteSearchCriteria, InsertEntity, ITabularStorage, Page, PageRequest, QueryOptions, SearchCriteria, SimplifyPrimaryKey, TabularChangePayload, TabularEventListener, TabularEventName, TabularEventParameters, TabularSubscribeOptions } from "./ITabularStorage";
/**
 * Telemetry wrapper for any ITabularStorage implementation.
 * Creates spans for all storage operations.
 */
export declare class TelemetryTabularStorage<Schema extends DataPortSchemaObject, PrimaryKeyNames extends ReadonlyArray<keyof Schema["properties"]>, Entity = FromSchema<Schema, TypedArraySchemaOptions>, PrimaryKey = SimplifyPrimaryKey<Entity, PrimaryKeyNames>, InsertType = InsertEntity<Entity, AutoGeneratedKeys<Schema>>> implements ITabularStorage<Schema, PrimaryKeyNames, Entity, PrimaryKey, InsertType> {
    protected readonly storageName: string;
    protected readonly inner: ITabularStorage<Schema, PrimaryKeyNames, Entity, PrimaryKey, InsertType>;
    constructor(storageName: string, inner: ITabularStorage<Schema, PrimaryKeyNames, Entity, PrimaryKey, InsertType>);
    put(value: InsertType): Promise<Entity>;
    putBulk(values: InsertType[]): Promise<Entity[]>;
    get(key: PrimaryKey): Promise<Entity | undefined>;
    delete(key: PrimaryKey | Entity): Promise<void>;
    getAll(options?: QueryOptions<Entity>): Promise<Entity[] | undefined>;
    deleteAll(): Promise<void>;
    size(): Promise<number>;
    count(criteria?: SearchCriteria<Entity>): Promise<number>;
    deleteSearch(criteria: DeleteSearchCriteria<Entity>): Promise<void>;
    getOffsetPage(offset: number, limit: number): Promise<Entity[] | undefined>;
    getBulk(keys: readonly PrimaryKey[]): Promise<Entity[]>;
    getPage(request?: PageRequest<Entity>): Promise<Page<Entity>>;
    queryPage(criteria: SearchCriteria<Entity>, request?: PageRequest<Entity>): Promise<Page<Entity>>;
    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>[]>;
    records(pageSize?: number): AsyncGenerator<Entity, void, undefined>;
    pages(pageSize?: number): AsyncGenerator<Entity[], void, undefined>;
    subscribeToChanges(callback: (change: TabularChangePayload<Entity>) => void, options?: TabularSubscribeOptions): () => void;
    withTransaction<T>(fn: (tx: this) => Promise<T>): Promise<T>;
    setupDatabase(): Promise<void>;
    /**
     * Forwards to the inner storage's applier so callers that wrap a
     * migration-aware storage in TelemetryTabularStorage still observe
     * declared migrations.
     */
    getMigrationApplier(): ITabularMigrationApplier | null;
    destroy(): void;
    [Symbol.dispose](): void;
    [Symbol.asyncDispose](): Promise<void>;
    on<Event extends TabularEventName>(name: Event, fn: TabularEventListener<Event, PrimaryKey, Entity>): void;
    off<Event extends TabularEventName>(name: Event, fn: TabularEventListener<Event, PrimaryKey, Entity>): void;
    emit<Event extends TabularEventName>(name: Event, ...args: TabularEventParameters<Event, PrimaryKey, Entity>): void;
    once<Event extends TabularEventName>(name: Event, fn: TabularEventListener<Event, PrimaryKey, Entity>): void;
    waitOn<Event extends TabularEventName>(name: Event): Promise<TabularEventParameters<Event, PrimaryKey, Entity>>;
}
//# sourceMappingURL=TelemetryTabularStorage.d.ts.map