/**
 * RemoteAgent 本机 RPC Client。
 *
 * 职责说明（中文）
 * - 为 `RemoteAgent(rpc://...)` 提供最小客户端实现。
 * - 复用逐行 JSON（NDJSON）协议，与本机 RPC Server 对接。
 * - 当前只承载 Session actor 所需方法。
 */
import type { AgentCreateSessionInput, AgentListSessionsInput, AgentArchiveSessionInput, AgentArchiveSessionsInput, AgentArchiveSessionResult, AgentArchiveSessionsResult, AgentCleanArchiveResult, AgentSessionInfo, AgentSessionSetOptions, AgentSessionStatus, AgentSessionSummaryPage, AgentSessionSystemSnapshot, RemoteSessionSetInput } from "../../types/agent/SessionTypes.js";
import type { ListSessionMessagesInput, SessionMessagePage } from "../../types/session/SessionMessage.js";
import type { JsonValue } from "../../types/common/Json.js";
import type { AgentSessionStopResult } from "../../types/sdk/AgentSessionStop.js";
import type { PluginActionResult } from "../../types/plugin/PluginAction.js";
import type { PluginAvailability, PluginView } from "../../types/plugin/PluginRuntime.js";
import type { PluginSnapshot } from "../../types/plugin/PluginState.js";
import type { SessionMutation } from "../../types/session/SessionMutation.js";
import type { RespondSessionInteractionInput, SessionInteractionResult, SessionPendingInteraction } from "../../types/session/SessionInteraction.js";
import type { AgentSessionPromptInput } from "../../types/sdk/AgentSessionPrompt.js";
import type { RpcClientEndpoint, RpcInternalStatus, RpcSessionSubscription, RpcSystemPromptPayload } from "../../types/rpc/RpcProtocol.js";
export type { RpcClientEndpoint, RpcSessionSubscription, RpcSystemPromptPayload, } from "../../types/rpc/RpcProtocol.js";
/**
 * RPC Client。
 */
export declare class RpcClient {
    private readonly endpoint;
    private socket;
    private connect_promise;
    private buffered;
    private readonly pending_requests;
    private readonly subscriptions;
    private request_sequence;
    constructor(endpoint: RpcClientEndpoint);
    /**
     * 列出远程 session。
     */
    list_sessions(input?: AgentListSessionsInput): Promise<AgentSessionSummaryPage>;
    /**
     * 创建远程 session。
     */
    create_session(input?: AgentCreateSessionInput): Promise<AgentSessionInfo>;
    /**
     * 归档远程 session。
     */
    archive_session(input: AgentArchiveSessionInput): Promise<AgentArchiveSessionResult>;
    /**
     * 列出远程已归档 session。
     */
    archive_sessions(input?: AgentArchiveSessionsInput): Promise<AgentArchiveSessionsResult>;
    /**
     * 清空远程已归档 session。
     */
    clean_archive(): Promise<AgentCleanArchiveResult>;
    /**
     * 获取远程 session 信息。
     */
    get_session(session_id: string): Promise<AgentSessionInfo>;
    /**
     * 发送 prompt。
     */
    prompt_session(params: {
        session_id: string;
        input: AgentSessionPromptInput;
    }): Promise<{
        id: string;
    }>;
    /**
     * 停止远程 session 当前 turn。
     */
    stop_session(session_id: string): Promise<AgentSessionStopResult>;
    /**
     * 把一次显式历史压缩加入远程 Session 的有序输入队列。
     */
    compact_session(session_id: string): Promise<{
        id: string;
    }>;
    /**
     * 读取 session records。
     */
    get_session_messages(params: {
        session_id: string;
        input?: ListSessionMessagesInput;
    }): Promise<SessionMessagePage>;
    /**
     * 读取 system snapshot。
     */
    get_session_system(session_id: string): Promise<AgentSessionSystemSnapshot>;
    get_session_interactions(session_id: string): Promise<SessionPendingInteraction[]>;
    get_session_status(session_id: string): Promise<AgentSessionStatus>;
    set_session(session_id: string, input: RemoteSessionSetInput, options?: AgentSessionSetOptions): Promise<void>;
    respond_session_interaction(session_id: string, input: RespondSessionInteractionInput): Promise<SessionInteractionResult>;
    /**
     * 分叉 session。
     */
    fork_session(params: {
        session_id: string;
        message_id?: string;
    }): Promise<AgentSessionInfo>;
    /**
     * 订阅 session 事件。
     */
    subscribe_session(params: {
        session_id: string;
        on_ready: () => void;
        on_event: (event: SessionMutation) => void;
        on_close: (error?: unknown) => void;
    }): Promise<RpcSessionSubscription>;
    /**
     * 读取 Agent 内部状态。
     */
    get_internal_status(): Promise<RpcInternalStatus>;
    /**
     * 清空 Agent runtime 内指定 session 的消息。
     */
    clear_internal_session_messages(session_id: string): Promise<{
        session_id: string;
        cleared: boolean;
    }>;
    /**
     * 清空 Agent runtime 内指定 session 的 chat history。
     */
    clear_internal_chat_history(session_id: string): Promise<{
        session_id: string;
        cleared: boolean;
    }>;
    /**
     * 解析 Agent runtime 内指定 session 的 system prompt。
     */
    resolve_internal_system_prompt(session_id: string): Promise<RpcSystemPromptPayload>;
    /**
     * 列出 Agent runtime 注册的 plugin catalog。
     */
    list_internal_plugin_catalog(): Promise<PluginView[]>;
    /**
     * 列出 Agent runtime 内 plugin 状态。
     */
    list_internal_plugin_states(): Promise<PluginSnapshot[]>;
    /**
     * 检查 Agent runtime 内 plugin 可用性。
     */
    get_internal_plugin_availability(plugin_name: string): Promise<PluginAvailability>;
    /**
     * 执行 Agent runtime 内 plugin action。
     */
    run_internal_plugin_action(params: {
        plugin_name: string;
        action_name: string;
        payload?: JsonValue;
    }): Promise<PluginActionResult<JsonValue> & {
        plugin_name?: string;
        action_name?: string;
    }>;
    /**
     * 关闭底层连接。
     */
    close(): Promise<void>;
    private request;
    private ensure_connected;
    private consume_data;
    private consume_line;
    private fail_all_pending;
    private fail_all_subscriptions;
}
/**
 * 解析 rpc url。
 */
export declare function parse_rpc_url(url_input: string): RpcClientEndpoint;
//# sourceMappingURL=RpcClient.d.ts.map