import type { AgentRequestBase, AgentResponder } from "@mono-agent/agent-contracts";
export interface ProcessJobWakeContext {
    readonly jobId: string;
    readonly chainDepth: number;
}
export type ProcessJobWakeContextResolution = {
    readonly kind: "none";
} | {
    readonly kind: "resolved";
    readonly context: ProcessJobWakeContext;
} | {
    readonly kind: "missed";
};
export interface ProcessJobSteeringTargetLease {
    chainDepth(): number;
    release(): void;
}
/** Register the exact active run whose controller can be raised by a host wake. */
export declare function registerProcessJobSteeringTarget(input: {
    readonly conversationId: string;
    readonly runId: string;
    readonly chainDepth: number;
}): ProcessJobSteeringTargetLease;
/** Run a genuine channel turn with host-owned fan-out depth attached out of band. */
export declare function runWithProcessJobWakeContext<T>(context: ProcessJobWakeContext, operation: () => Promise<T>, deliveryKey: string): Promise<T>;
/**
 * Capture an admitted host wake on the exact request identity that survives
 * the responder-to-harness queue boundary. The association remains outside
 * public/string metadata, prompts, history, traces, and serialized payloads.
 */
export declare function bindProcessJobWakeContextToResponder(responder: AgentResponder): AgentResponder;
/** Resolve only an association previously issued by the app-owned responder seam. */
export declare function processJobWakeContextForRequest(request: Pick<AgentRequestBase, "metadata">): ProcessJobWakeContextResolution;
//# sourceMappingURL=process-jobs-context.d.ts.map