import type { SippClientOptions } from '../engine/browser-client.js';
import { type EngineEvent, type EngineState, type ObservabilityEvent, type ObservabilitySnapshot, type ModelInfo, type ModelAddOptions, type ModelAddSource, type ModelLifecycleService, type ModelLoadOptions, type EmbedOptions, type EmbeddingResult, type GenerationResult, type ChatInput, type InternalTextRequestOptions, type QueryInput } from '../models/types.js';
export declare function getOptimizedDefaultWorkerUrl(importerUrl?: string): string | null;
export declare class WorkerModelServiceClient implements ModelLifecycleService {
    private readonly config;
    private worker;
    private nextCallId;
    private closed;
    private currentSnapshot;
    private readonly observability;
    private readonly engineEventListeners;
    private readonly pendingCalls;
    private readonly workerConfig;
    private tokenRingReader;
    private tokenRingDrainScheduled;
    private activeTokenCallCount;
    private readonly callIdByNativeRequestId;
    private readonly pendingTokenRecordsByNativeRequestId;
    private readonly streamStatsByCallId;
    constructor(config?: SippClientOptions);
    add(source: ModelAddSource, options?: ModelAddOptions): Promise<ModelInfo>;
    load(modelId: string, options?: ModelLoadOptions): Promise<ModelInfo>;
    current(): ModelInfo | null;
    list(): Promise<ModelInfo[]>;
    remove(id: string): Promise<void>;
    unload(): Promise<void>;
    runQuery(input: QueryInput, options: InternalTextRequestOptions): Promise<GenerationResult>;
    runChat(input: ChatInput, options: InternalTextRequestOptions): Promise<GenerationResult>;
    runEmbedding(input: string, options: EmbedOptions): Promise<EmbeddingResult>;
    currentObservability(): ObservabilitySnapshot;
    subscribeObservability(listener: (event: ObservabilityEvent) => void): () => void;
    state(): EngineState;
    subscribeEvents(listener: (event: EngineEvent) => void): () => void;
    close(): void;
    private assertOpen;
    private scheduleTokenRingDrain;
    private drainTokenRing;
    private bufferPendingTokenRecord;
    private flushPendingTokenRecords;
    private deliverTokenRecord;
    private deliverTokenBatch;
    private forgetStreamingCall;
    private ensureWorker;
    private failWorker;
    private postWorkerMessage;
    private callWorker;
    private handleWorkerMessage;
    private deserializeError;
    private emitEngineEvent;
    private snapshotState;
}