/**
 * @license
 * Copyright 2024 Google LLC
 * SPDX-License-Identifier: Apache-2.0
 */
import type { AsRemoteMessage, HarnessRunner, RemoteMessage, RemoteRunConfig, RunDiagnosticsLevel, RunEventTarget, SecretResult } from "@breadboard-ai/types";
import { GraphDescriptor, InputValues, InspectableRunObserver, Schema } from "@breadboard-ai/types";
export type SecretRemoteMessage = AsRemoteMessage<SecretResult>;
export type HarnessRemoteMessage = RemoteMessage | SecretRemoteMessage;
export type MessageConsumer = (message: HarnessRemoteMessage) => Promise<void>;
export type FetchType = typeof globalThis.fetch;
export declare const remoteMessageTransform: () => TransformStream<string, HarnessRemoteMessage>;
export declare const emptyGraph: () => GraphDescriptor;
export declare class HttpClient {
    #private;
    constructor(url: string, key: string, diagnostics: RunDiagnosticsLevel, writer: MessageConsumer, signal: AbortSignal | null, fetch?: FetchType);
    fetching(): boolean;
    lastMessage(): HarnessRemoteMessage | null;
    send(inputs: InputValues): Promise<boolean>;
}
declare const RemoteRunner_base: RunEventTarget;
export declare class RemoteRunner extends RemoteRunner_base implements HarnessRunner {
    #private;
    constructor(config: RemoteRunConfig, fetch?: FetchType);
    addObserver(observer: InspectableRunObserver): void;
    running(): boolean;
    secretKeys(): string[] | null;
    inputSchema(): Schema | null;
    run(inputs?: InputValues): Promise<boolean>;
}
export {};
//# sourceMappingURL=remote-runner.d.ts.map