import { type Logger } from "@logtape/logtape";
import { BackendPostgres } from "@sonamu-kit/tasks";
import { type RunnableWorkflow, type SchemaInput, type SchemaOutput, type StandardSchemaV1, type WorkflowRunHandle, type WorkflowSpec } from "@sonamu-kit/tasks/internal";
import { type Knex } from "knex";
import { type WorkflowMetadata } from "./decorator";
import { StepWrapper } from "./step-wrapper";
export interface WorkflowOptions {
    concurrency?: number;
    usePubSub?: boolean;
    listenDelay?: number;
}
export type WorkflowFunction<Input, Output> = (params: Readonly<{
    logger: Logger;
    input: Input;
    step: StepWrapper;
    version: string | null;
}>) => Promise<Output> | Output;
export type WorkflowCreateOptions<Input, Output, TSchema extends StandardSchemaV1 | undefined = undefined> = Omit<WorkflowSpec<SchemaOutput<TSchema, Input>, Output, SchemaInput<TSchema, Input>>, "version"> & {
    id: string;
    version: string | null;
    function: WorkflowFunction<SchemaOutput<TSchema, Input>, Output>;
};
export declare class WorkflowManager {
    #private;
    constructor(dbConf: Knex.Config, runMigrations?: boolean);
    get backend(): BackendPostgres;
    get workflowDefinitions(): {
        id: string;
        name: string;
        version: string | null;
        schedules: {
            name: string;
            expression: string;
        }[];
        retryPolicy: import("@sonamu-kit/tasks/internal").SerializableRetryPolicy | undefined;
    }[];
    /**
     * 정의된 워크플로우 및 워크플로우에 대한 scheduled tasks를 동기화합니다.
     */
    synchronize(workflowMap: Map<string, WorkflowMetadata[]>): Promise<void>;
    run<Input, Output, TSchema extends StandardSchemaV1 | undefined = undefined>(options: Omit<WorkflowCreateOptions<Input, Output, TSchema>, "function" | "schema" | "id">, input: SchemaInput<TSchema, Input>): Promise<WorkflowRunHandle<Output>>;
    scheduleTask(workflow: Pick<WorkflowMetadata, "id" | "name" | "version">, schedule: WorkflowMetadata["schedules"][number]): Promise<void>;
    unscheduleTask(name: string): Promise<void>;
    registerWorkflow<Input, Output, TSchema extends StandardSchemaV1 | undefined = undefined>(options: WorkflowCreateOptions<Input, Output, TSchema>): RunnableWorkflow<SchemaOutput<TSchema, Input>, Output, SchemaInput<TSchema, Input>>;
    unregisterWorkflow(workflow: Pick<WorkflowMetadata, "name" | "version" | "id">): Promise<void>;
    setupWorker(options: WorkflowOptions): void;
    startWorker(): Promise<void>;
    stopWorker(): Promise<void>;
    stopSchedules(): Promise<void>;
    destroySchedules(): Promise<void>;
    destroy(): Promise<void>;
    [Symbol.asyncDispose](): Promise<void>;
}
//# sourceMappingURL=workflow-manager.d.ts.map