import type { SDKConfig, RunOptions, StreamOptions } from './types/sdk';
import type { SchemaKey, SchemaMap, ModelResultMap, ModelAIR, UtilityMap, RunParams } from './types/task-map';
import type { TextStream } from './types/stream';
import { type ContentClient } from './content';
export type RunwareClient = {
    connect: () => Promise<void>;
    disconnect: () => Promise<void>;
    isConnected: () => boolean;
    /**
     * Run an inference task.
     *
     * With an official model — return type auto-inferred:
     *   client.run({ model: 'inworld:tts@2', ... })  → AudioInferenceResult[]
     *
     * With an architecture generic — typed params and results:
     *   client.run<'sdxl'>({ model: '...', positivePrompt: '...' })
     *
     * Without — loose params, untyped result:
     *   client.run({ model: '...', positivePrompt: '...' })
     */
    run: {
        <M extends ModelAIR>(params: {
            model: M;
        } & Record<string, unknown>, options?: RunOptions): Promise<ModelResultMap[M][]>;
        <S extends SchemaKey>(params: SchemaMap[S]['params'], options?: RunOptions): Promise<SchemaMap[S]['result'][]>;
        (params: RunParams, options?: RunOptions): Promise<Record<string, unknown>[]>;
    };
    /**
     * Stream text inference token-by-token via SSE.
     *
     * Returns a TextStream with:
     *   - `.textStream` — AsyncIterable<string> for text deltas as they arrive
     *   - `.reasoningStream` — AsyncIterable<string> for reasoning deltas
     *   - `.text()` — Promise<string> for the full accumulated text
     *   - `.result()` — Promise<TextStreamResult> for final metadata
     *
     * Options:
     *   - `signal` — AbortSignal to cancel the stream.
     *
     * Usage:
     *   const stream = client.stream({ model: '...', messages: [...] })
     *   for await (const word of stream.textStream) { console.log(word) }
     */
    stream: (params: Record<string, unknown>, options?: StreamOptions) => Promise<TextStream>;
    /**
     * Force a refresh of the model registry from the remote endpoint.
     * Useful when a day-zero model has been launched and you want it
     * available immediately without waiting for the next TTL cycle.
     */
    refreshRegistry: () => Promise<void>;
    /**
     * Poll for the result of a previously submitted async task.
     * Used internally by the SDK during async task execution.
     */
    getResponse: (params: UtilityMap['getResponse']['params'], options?: RunOptions) => Promise<UtilityMap['getResponse']['result'][]>;
    /**
     * Retrieve the original request and response for a previously executed task.
     * Looks up archived task data by `taskUUID`.
     */
    getTaskDetails: (params: UtilityMap['getTaskDetails']['params'], options?: RunOptions) => Promise<UtilityMap['getTaskDetails']['result'][]>;
    /**
     * Search for models.
     */
    modelSearch: (params: UtilityMap['modelSearch']['params'], options?: RunOptions) => Promise<UtilityMap['modelSearch']['result'][]>;
    /**
     * Upload a model.
     */
    modelUpload: (params: UtilityMap['modelUpload']['params'], options?: RunOptions) => Promise<UtilityMap['modelUpload']['result'][]>;
    /**
     * Upload an image.
     *
     * @deprecated Use `mediaStorage` instead, which handles any media type and supports deletion.
     */
    imageUpload: (params: UtilityMap['imageUpload']['params'], options?: RunOptions) => Promise<UtilityMap['imageUpload']['result'][]>;
    /**
     * Store or delete media in your Runware account.
     */
    mediaStorage: (params: UtilityMap['mediaStorage']['params'], options?: RunOptions) => Promise<UtilityMap['mediaStorage']['result'][]>;
    /**
     * Manage account settings.
     */
    accountManagement: (params: UtilityMap['accountManagement']['params'], options?: RunOptions) => Promise<UtilityMap['accountManagement']['result'][]>;
    /**
     * Public read-only metadata about Runware's curated model catalog —
     * listings, single model details, examples, pricing, capabilities, creators.
     * Backed by the content service, separate from the inference API.
     */
    content: ContentClient;
};
type ClientConfig = Partial<SDKConfig> & {
    apiKey: string;
};
/**
 * Create a Runware SDK client. Returns a ready-to-use `RunwareClient` with
 * `.run()`, `.stream()`, and utility methods like `.modelSearch()`.
 *
 * The only required field is `apiKey`. Everything else has sensible defaults:
 *   - `transport`: `'websocket'` (use `'rest'` for stateless serverless)
 *   - `timeout`/`pollTimeout`: 20 min (covers video, 3D, large upscale)
 *   - `retry`/`reconnect`: built-in with exponential backoff
 *
 * For WebSocket, call `.connect()` before the first request. For REST it's a
 * no-op (each request is a standalone HTTP call).
 *
 * @example
 *   const client = await createClient({ apiKey: process.env.RUNWARE_API_KEY })
 *   await client.connect()
 *   const images = await client.run({ model: 'runware:101@1', positivePrompt: 'a cat' })
 */
export declare const createClient: (userConfig: ClientConfig) => Promise<RunwareClient>;
export {};
//# sourceMappingURL=client.d.ts.map