import { AgentCard, Task, TaskStatusUpdateEvent, TaskArtifactUpdateEvent, MessageSendParams, TaskQueryParams, TaskIdParams, TaskPushNotificationConfig } from "../types";
import { TaskStore } from "../store/task_store";
import { IExecutionEventBus } from "../event/event_bus";
import { MomentoAgentExecutor } from "../agent/executor";
export interface MomentoAgentRequestHandlerOptions {
    momentoApiKey?: string;
    cacheName?: string;
    defaultTtlSeconds?: number;
    agentCard: AgentCard;
    executor: MomentoAgentExecutor;
    taskStore: TaskStore;
    eventBus: IExecutionEventBus;
}
export declare class MomentoAgentRequestHandler {
    private readonly agentCard;
    private readonly taskStore;
    private readonly client;
    private readonly eventBus;
    private readonly executor;
    constructor(opts: MomentoAgentRequestHandlerOptions);
    verifyConnection(): Promise<boolean>;
    getAgentCard(): Promise<AgentCard>;
    /** Send a message, returning the final Task result (or Message, per protocol) */
    sendMessage(params: MessageSendParams): Promise<Task>;
    /** Streaming message interface (yields events as they happen) */
    sendMessageStream(params: MessageSendParams): AsyncGenerator<Task | TaskStatusUpdateEvent | TaskArtifactUpdateEvent, void, undefined>;
    /** Get a task by ID */
    getTask(params: TaskQueryParams): Promise<Task>;
    /** Cancel a task by ID */
    cancelTask(params: TaskIdParams): Promise<Task>;
    /** Set push notification config (if agent supports it) */
    setTaskPushNotificationConfig(params: TaskPushNotificationConfig): Promise<TaskPushNotificationConfig>;
    /** Get push notification config (if agent supports it) */
    getTaskPushNotificationConfig(params: TaskIdParams): Promise<TaskPushNotificationConfig>;
    /** Resubscribe to an existing task's event stream */
    resubscribe(params: TaskIdParams): AsyncGenerator<Task | TaskStatusUpdateEvent | TaskArtifactUpdateEvent, void, undefined>;
}
//# sourceMappingURL=request_handler.d.ts.map