import { TaskModel } from "./models/TaskModel";
import { Repo } from "../repository/Repository";
import { TaskEventModel } from "./models/TaskEventModel";
import { TaskHandlerRegistry } from "./TaskHandlerRegistry";
import { TaskEventBus } from "./TaskEventBus";
import { Adapter, ContextOf } from "../persistence/index";
import { AbsContextual, MaybeContextualArg } from "../utils/ContextualLoggedClass";
export type TaskEngineConfig<A extends Adapter<any, any, any, any>> = {
    adapter: A;
    bus: TaskEventBus;
    registry: TaskHandlerRegistry;
    workerId: string;
    concurrency: number;
    leaseMs: number;
    pollMsIdle: number;
    pollMsBusy: number;
    logTailMax: number;
    streamBufferSize: number;
    maxLoggingBuffer: number;
    loggingBufferTruncation: number;
};
export declare const DefaultTaskEngineConfig: TaskEngineConfig<any>;
export declare class TaskEngine<A extends Adapter<any, any, any, any>> extends AbsContextual<ContextOf<A>> {
    private config;
    private _tasks?;
    private _events?;
    protected get adapter(): A;
    protected get registry(): TaskHandlerRegistry;
    protected get bus(): TaskEventBus;
    protected get tasks(): Repo<TaskModel>;
    protected get events(): Repo<TaskEventModel>;
    protected running: boolean;
    constructor(config: TaskEngineConfig<A>);
    isRunning(): boolean;
    push(task: TaskModel, ...args: MaybeContextualArg<any>): Promise<TaskModel>;
    cancel(id: string, ...args: MaybeContextualArg<any>): Promise<TaskModel>;
    start(): void;
    stop(): void;
    private loop;
    private claimBatch;
    private tryClaim;
    private executeClaimed;
    private runComposite;
    private appendLog;
    private emitStatus;
    private emitLog;
    private emitProgress;
    private persistEvent;
    toString(): string;
}