import type { DeserializedJson } from "../../schemas/json.js";
import type { ApiClient } from "../apiClient/index.js";
import type { AsyncIterableStream } from "../streams/asyncIterableStream.js";
import type { IOPacket } from "../utils/ioSerialization.js";
import type { ApiRequestOptions } from "../zodfetch.js";
import type { RunMetadataManager, RunMetadataUpdater } from "./types.js";
export declare class StandardMetadataManager implements RunMetadataManager {
    #private;
    private apiClient;
    private flushTimeoutId;
    private isFlushing;
    private store;
    private queuedOperations;
    private queuedParentOperations;
    private queuedRootOperations;
    runId: string | undefined;
    runIdIsRoot: boolean;
    constructor(apiClient: ApiClient);
    reset(): void;
    get parent(): RunMetadataUpdater;
    get root(): RunMetadataUpdater;
    enterWithMetadata(metadata: Record<string, DeserializedJson>): void;
    current(): Record<string, DeserializedJson> | undefined;
    getKey(key: string): DeserializedJson | undefined;
    private enqueueOperation;
    set(key: string, value: DeserializedJson): this;
    del(key: string): this;
    append(key: string, value: DeserializedJson): this;
    remove(key: string, value: DeserializedJson): this;
    increment(key: string, increment?: number): this;
    decrement(key: string, decrement?: number): this;
    update(metadata: Record<string, DeserializedJson>): this;
    stream<T>(key: string, value: AsyncIterable<T> | ReadableStream<T>, signal?: AbortSignal): Promise<AsyncIterable<T>>;
    fetchStream<T>(key: string, signal?: AbortSignal): Promise<AsyncIterableStream<T>>;
    private doStream;
    refresh(requestOptions?: ApiRequestOptions): Promise<void>;
    flush(requestOptions?: ApiRequestOptions): Promise<void>;
    startPeriodicFlush(intervalMs?: number): void;
    stopPeriodicFlush(): void;
    stopAndReturnLastFlush(): Promise<IOPacket>;
}