import type { MutableWorkerAdvertisementProvider } from '../client.js';
import { NativeBridgeProtocolError } from './protocol.js';
export declare const NATIVE_BRIDGE_HELLO_TIMEOUT_MS = 5000;
export interface NativeBridgeRunResult {
    checkpoint?: Record<string, unknown>;
    action_output?: Record<string, unknown>;
    auth_update?: Record<string, unknown>;
    credentials?: Record<string, unknown>;
    metadata?: Record<string, unknown>;
}
export interface NativeBridgeRunOptions {
    requestId?: string;
    operation: 'sync' | 'action' | 'auth' | 'read';
    job: Record<string, unknown>;
    onStream?: (payload: Record<string, unknown>, sequence: number) => Promise<void>;
}
export declare class NativeBridgeClient {
    private readonly input;
    private readonly provider;
    private readonly expectedWorkerId;
    private readonly daemonBuild;
    private readonly handshakeTimeoutMs;
    private readonly decoder;
    private readonly writer;
    private readonly pending;
    private readonly terminalRuns;
    private readonly ignoredRuns;
    private reading;
    private handshakeComplete;
    private handshakePromise?;
    private handshakeReject?;
    private failure?;
    private readonly transportFailureHandlers;
    constructor(input: NodeJS.ReadableStream, output: NodeJS.WritableStream, provider: MutableWorkerAdvertisementProvider, expectedWorkerId: string, daemonBuild: string, handshakeTimeoutMs?: number);
    handshake(): Promise<void>;
    run(options: NativeBridgeRunOptions): Promise<NativeBridgeRunResult>;
    cancel(requestId: string, runId: number): Promise<void>;
    cancelAndAbandon(requestId: string, runId: number, error: Error): Promise<void>;
    cancelActiveRuns(): Promise<void>;
    shutdown(): Promise<void>;
    close(error?: NativeBridgeProtocolError): void;
    onTransportFailure(handler: (error: Error) => void): () => void;
    get activeRunCount(): number;
    private readLoop;
    private receive;
    private send;
    private rejectPending;
    private failAll;
    private failBridge;
}
//# sourceMappingURL=client.d.ts.map