import type { DomainEventLog, Queues, SixbDefinitions, Storage } from "@sixb/core";
import type { LoggingService } from "@sixb/core/internal/logging";
import { type PrimitiveExecutionHost } from "@sixb/core/internal/primitive-execution";
import type { QueueWorkerFailureDecision } from "@sixb/core/internal/workers";
import { QueueWorker } from "@sixb/core/internal/workers";
import type { ActionRunRequestedQueueJob, ClaimedQueueJob } from "@sixb/core/queues";
import { ACTION_RUN_FAILURE_CODES } from "@sixb/core/storage";
export interface ActionWorkerHost extends PrimitiveExecutionHost {
    readonly events: DomainEventLog;
    readonly storage: Storage;
    readonly queues: Queues;
    readonly logging?: LoggingService;
    readonly definitions: Pick<SixbDefinitions, "actions">;
}
export interface ActionWorkerOptions {
    readonly leaseMs?: number;
}
export declare class ActionWorker extends QueueWorker<ActionRunRequestedQueueJob, typeof ACTION_RUN_FAILURE_CODES> {
    private readonly host;
    private readonly idleWithoutDefinitions;
    constructor(host: ActionWorkerHost, options?: ActionWorkerOptions);
    protected run(signal: AbortSignal): Promise<void>;
    protected execute(claimed: ClaimedQueueJob<ActionRunRequestedQueueJob>, signal: AbortSignal): Promise<void>;
    protected onExecutionError(_claimed: ClaimedQueueJob<ActionRunRequestedQueueJob>, _error: unknown): Promise<QueueWorkerFailureDecision>;
    protected onAbortError(_claimed: ClaimedQueueJob<ActionRunRequestedQueueJob>, _error: unknown): Promise<QueueWorkerFailureDecision>;
}
//# sourceMappingURL=worker.d.ts.map