import { type Task } from "./models.js";
import type { ListInput, SubmitInput, TaskStore } from "./store/base.js";
import { type TaskDef } from "./task.js";
export type SubmitOptions = Omit<SubmitInput, "name" | "payload">;
export interface CallOptions extends SubmitOptions {
    waitTimeoutMs?: number;
    pollMs?: number;
}
/** API-side handle. Thin wrapper over a TaskStore + SDK-orchestrated wait/call. */
export declare class CairnQ {
    private readonly _store;
    constructor(_store: TaskStore);
    static sqlite(path: string, opts?: {
        busyTimeoutMs?: number;
    }): CairnQ;
    /** Multi-host backend. `dsn` is a libpq connection string; requires the
     * optional `pg` package. */
    static postgres(dsn: string, opts?: {
        max?: number;
    }): CairnQ;
    get store(): TaskStore;
    connect(): Promise<void>;
    close(): Promise<void>;
    submit(name: string, payload?: unknown, opts?: SubmitOptions): Promise<Task>;
    submit<P, R>(task: TaskDef<P, R>, payload?: P, opts?: SubmitOptions): Promise<Task>;
    get(taskId: string): Promise<Task | null>;
    getByKey(key: string): Promise<Task | null>;
    list(input?: ListInput): Promise<Task[]>;
    cancel(taskId: string): Promise<Task | null>;
    cancelByKey(key: string): Promise<Task | null>;
    retry(taskId: string, opts?: {
        resetAttempt?: boolean;
    }): Promise<Task | null>;
    retryByKey(key: string, opts?: {
        resetAttempt?: boolean;
    }): Promise<Task | null>;
    wait(taskId: string, opts?: {
        timeoutMs?: number;
        pollMs?: number;
    }): Promise<Task>;
    /** submit + wait. Resolves with the result on success; rejects with
     * TaskFailed / TaskCanceled / TaskTimeout otherwise. Pass a TaskDef and the
     * resolved value is typed as its Result. */
    call(name: string, payload?: unknown, opts?: CallOptions): Promise<unknown>;
    call<P, R>(task: TaskDef<P, R>, payload?: P, opts?: CallOptions): Promise<R>;
}