import type { ChannelSchema, ONIConfig, ONICheckpointer } from "./types.js";
import type { ONISkeletonV3 } from "./graph.js";
export interface TaskOptions {
    /** Retry policy */
    maxAttempts?: number;
    initialDelay?: number;
}
export interface TaskDef<TInput, TOutput> {
    name: string;
    invoke: (input: TInput, config?: ONIConfig) => Promise<TOutput>;
}
export declare function task<TInput, TOutput>(name: string, fn: (input: TInput, config?: ONIConfig) => Promise<TOutput> | TOutput, opts?: TaskOptions): TaskDef<TInput, TOutput>;
export interface EntrypointOptions<S extends Record<string, unknown>> {
    channels: ChannelSchema<S>;
    checkpointer?: ONICheckpointer<S>;
    /** Node name (default: "entrypoint") */
    name?: string;
}
/**
 * Create a compiled skeleton from a single async function.
 * The function receives full state and returns a partial update.
 *
 * @example
 * const app = entrypoint(
 *   { channels: { query: lastValue(() => ""), answer: lastValue(() => "") } },
 *   async (state) => {
 *     const answer = await myLLM(state.query);
 *     return { answer };
 *   }
 * );
 */
export declare function entrypoint<S extends Record<string, unknown>>(opts: EntrypointOptions<S>, fn: (state: S, config?: ONIConfig) => Promise<Partial<S>> | Partial<S>): ONISkeletonV3<S>;
export declare function pipe<S extends Record<string, unknown>>(opts: EntrypointOptions<S>, ...tasks: Array<(state: S, config?: ONIConfig) => Promise<Partial<S>> | Partial<S>>): ONISkeletonV3<S>;
export declare function branch<S extends Record<string, unknown>>(condition: (state: S) => string, branches: Record<string, (state: S, config?: ONIConfig) => Promise<Partial<S>> | Partial<S>>, opts: EntrypointOptions<S>): ONISkeletonV3<S>;
export { interrupt, getUserInput, getUserApproval, getUserSelection } from "./hitl/interrupt.js";
//# sourceMappingURL=functional.d.ts.map