import type { AgentAttachParams, AgentAttachResult, ApplyParams, ApplyResult, DeleteParams, DeleteResult, GetParams, GetResult, InitializeParams, InitializeResult, LogsParams, LogsResult, PlanParams, PlanResult, ResubmitParams, ResubmitResult, RetryParams, RetryResult, StopParams, StopResult, UpdateParams, UpdateResult, WatchParams } from './generated/protocol.js';
import { Connection } from './connection.js';
import type { CallOptions } from './connection.js';
import type { WebSocketLike } from './socket.js';
import { AgentAttachSubscriptionStream, LogsSubscriptionStream } from './subscriptions.js';
import type { WatchSubscription } from './subscriptions.js';
export type { WatchSubscription } from './subscriptions.js';
export interface WebSocketFactoryOptions {
    readonly headers?: Readonly<Record<string, string>>;
}
export interface ConnectOptions {
    readonly protocols?: string | readonly string[];
    readonly webSocketFactory?: (url: string, protocols?: string | readonly string[], options?: WebSocketFactoryOptions) => WebSocketLike | Promise<WebSocketLike>;
    readonly signal?: AbortSignal;
    readonly initialize?: InitializeParams;
    readonly headers?: Readonly<Record<string, string>>;
}
export interface LogsSubscription {
    readonly result: LogsResult;
    readonly stream: LogsSubscriptionStream;
}
export interface AgentAttachSubscription {
    readonly result: AgentAttachResult;
    readonly stream: AgentAttachSubscriptionStream;
}
export interface CoherentWatchSubscription extends WatchSubscription {
    readonly snapshot: GetResult;
}
export interface ConnectInitializedResult {
    readonly connection: Connection;
    readonly client: ClusterClient;
    readonly initializeResult: InitializeResult;
}
export declare class ClusterClient {
    readonly connection: Connection;
    constructor(connection: Connection);
    initialize(params?: InitializeParams, options?: CallOptions): Promise<InitializeResult>;
    plan(params: PlanParams, options?: CallOptions): Promise<PlanResult>;
    apply(params: ApplyParams, options?: CallOptions): Promise<ApplyResult>;
    update(params: UpdateParams, options?: CallOptions): Promise<UpdateResult>;
    stop(params: StopParams, options?: CallOptions): Promise<StopResult>;
    retry(params: RetryParams, options?: CallOptions): Promise<RetryResult>;
    resubmit(params: ResubmitParams, options?: CallOptions): Promise<ResubmitResult>;
    delete(params: DeleteParams, options?: CallOptions): Promise<DeleteResult>;
    get(params?: GetParams, options?: CallOptions): Promise<GetResult>;
    watch(params?: WatchParams, options?: CallOptions): Promise<WatchSubscription>;
    watchColdStart(params?: Omit<WatchParams, 'fromCursor'>, options?: CallOptions): Promise<CoherentWatchSubscription>;
    logs(params?: LogsParams, options?: CallOptions): Promise<LogsSubscription>;
    agentAttach(params: AgentAttachParams, options?: CallOptions): Promise<AgentAttachSubscription>;
}
export declare function connect(url: string, options?: ConnectOptions): Promise<Connection>;
export declare function connectInitialized(url: string, options?: ConnectOptions): Promise<ConnectInitializedResult>;