import { type NodeDefinition, type Edge, type ChannelSchema, type ONIConfig, type ONIStreamEvent, type StreamMode, type InterruptConfig, type ONICheckpointer, type ONICheckpoint } from "../types.js";
import { DeadLetterQueue, type DeadLetter } from "../dlq.js";
import type { BaseStore } from "../store/index.js";
import { HITLSessionStore } from "../hitl/index.js";
import { EventBus } from "../events/bus.js";
import type { GuardrailsConfig } from "../guardrails/types.js";
import type { EventListeners } from "../events/types.js";
import { AuditLog } from "../guardrails/audit.js";
import { BudgetTracker } from "../guardrails/budget.js";
import { ONITracer, type TracerLike } from "../telemetry.js";
import type { CustomStreamEvent, MessageStreamEvent } from "../types.js";
export declare class ONIPregelRunner<S extends Record<string, unknown>> {
    private readonly nodes;
    private readonly edges;
    private readonly channels;
    private readonly interruptConfig;
    private readonly checkpointer;
    private readonly store;
    private readonly defaults?;
    private readonly dlq;
    private hitlStore;
    private nodeCache;
    private circuitBreakers;
    /** Count of concurrent subgraph invocations active on this runner. >0 means running as subgraph. */
    _subgraphRef: {
        count: number;
    };
    /** Per-invocation parent updates from Command.PARENT, keyed by parent threadId. */
    readonly _perInvocationParentUpdates: Map<string, Partial<unknown>[]>;
    /** Per-invocation checkpointer override for subgraph isolation, keyed by threadId. */
    readonly _perInvocationCheckpointer: Map<string, unknown>;
    /** Monotonic counter for unique per-invocation subgraph keys (BUG-0082: per-instance, not module-level). */
    private _nextInvocationId;
    readonly eventBus: EventBus;
    readonly auditLog: AuditLog | null;
    readonly budgetTracker: BudgetTracker | null;
    private readonly contentFilters;
    private readonly toolPermissions;
    readonly tracer: ONITracer;
    /** Pre-indexed edges by source node — O(1) lookup instead of O(n) filter */
    private readonly _edgesBySource;
    /** Pre-computed ephemeral channel keys — avoids iterating all channels */
    private readonly _ephemeralKeys;
    constructor(nodes: Map<string, NodeDefinition<S>>, edges: Edge<S>[], channels: ChannelSchema<S>, interruptConfig?: InterruptConfig, checkpointer?: ONICheckpointer<S> | null, store?: BaseStore | null, guardrails?: GuardrailsConfig, listeners?: EventListeners, defaults?: {
        nodeTimeout?: number;
    } | undefined, dlq?: DeadLetterQueue | null, tracer?: TracerLike | null);
    private get _ctx();
    _stream(input: Partial<S>, config?: ONIConfig, streamMode?: StreamMode | StreamMode[]): AsyncGenerator<ONIStreamEvent<S> | CustomStreamEvent | MessageStreamEvent>;
    invoke(input: Partial<S>, config?: ONIConfig): Promise<S>;
    stream(input: Partial<S>, config?: ONIConfig & {
        streamMode?: StreamMode | StreamMode[];
    }): AsyncGenerator<ONIStreamEvent<S> | CustomStreamEvent | MessageStreamEvent>;
    batch(inputs: Partial<S>[], config?: ONIConfig): Promise<S[]>;
    getState(config: {
        threadId: string;
    }): Promise<S | null>;
    updateState(config: {
        threadId: string;
    }, update: Partial<S>): Promise<void>;
    getStateAt(config: {
        threadId: string;
        step: number;
    }): Promise<S | null>;
    getHistory(config: {
        threadId: string;
    }): Promise<ONICheckpoint<S>[]>;
    forkFrom(config: {
        threadId: string;
        step: number;
        newThreadId: string;
    }): Promise<void>;
    getPendingInterrupts(threadId: string): import("../hitl/resume.js").HITLSession<S>[];
    hitlSessionStore(): HITLSessionStore<S>;
    getDeadLetters(threadId: string): DeadLetter[];
}
//# sourceMappingURL=index.d.ts.map