import type { ContextOperationRequest } from '../context.ts';
import type { OperationOutcome } from '../types.ts';
import type { EngineInternals } from './internals.ts';
import type { CapturedRejectionReason } from './strategy-helpers.ts';
export type OperationWithCallerStack = {
    callerStack?: string;
};
export type OperationRouterCallbacks = {
    processActivityOperation: (workflowId: string, operation: Extract<ContextOperationRequest, {
        type: 'activity';
    }>) => Promise<void>;
    processSleepOperation: (workflowId: string, operation: Extract<ContextOperationRequest, {
        type: 'sleep';
    }>) => Promise<void>;
    processWaitSignalOperation: (workflowId: string, operation: Extract<ContextOperationRequest, {
        type: 'wait-signal';
    }>) => Promise<void>;
    processWaitUpdateOperation: (workflowId: string, operation: Extract<ContextOperationRequest, {
        type: 'wait-update';
    }>) => Promise<void>;
    processWaitConditionOperation: (workflowId: string, operation: Extract<ContextOperationRequest, {
        type: 'wait-condition';
    }>) => Promise<void>;
    processGetVersionOperation: (workflowId: string, operation: Extract<ContextOperationRequest, {
        type: 'get-version';
    }>) => Promise<void>;
    processParallelOperation: (workflowId: string, operation: Extract<ContextOperationRequest, {
        type: 'parallel';
    }>) => Promise<void>;
    processRaceOperation: (workflowId: string, operation: Extract<ContextOperationRequest, {
        type: 'race';
    }>) => Promise<void>;
    processMemoOperation: (workflowId: string, operation: Extract<ContextOperationRequest, {
        type: 'memo';
    }>) => Promise<void>;
    processChildWorkflowOperation: (workflowId: string, operation: Extract<ContextOperationRequest, {
        type: 'child-workflow';
    }>) => Promise<void>;
    processOffloadOperation: (workflowId: string, operation: Extract<ContextOperationRequest, {
        type: 'offload';
    }>) => Promise<void>;
    processLoadOperation: (workflowId: string, operation: Extract<ContextOperationRequest, {
        type: 'load';
    }>) => Promise<void>;
    processArchiveOperation: (workflowId: string, operation: Extract<ContextOperationRequest, {
        type: 'archive';
    }>) => Promise<void>;
    processStateReadOperation: (workflowId: string, operation: Extract<ContextOperationRequest, {
        type: 'state-read';
    }>) => Promise<void>;
    processStateCommitOperation: (workflowId: string, operation: Extract<ContextOperationRequest, {
        type: 'state-commit';
    }>) => Promise<void>;
    processRunAllOperation: (workflowId: string, operation: Extract<ContextOperationRequest, {
        type: 'run-all';
    }>) => Promise<void>;
    processSpeculateOperation: (workflowId: string, operation: Extract<ContextOperationRequest, {
        type: 'speculate';
    }>) => Promise<void>;
    processStreamOperation: (workflowId: string, operation: Extract<ContextOperationRequest, {
        type: 'stream';
    }>) => Promise<void>;
    processWaitReviewOperation: (workflowId: string, operation: Extract<ContextOperationRequest, {
        type: 'wait-review';
    }>) => Promise<void>;
    finalizePendingTimelineEntry: (workflowId: string, status: 'completed' | 'failed', value: unknown) => void;
    feedOperationResult: (workflowId: string, result: OperationOutcome, originalReason?: CapturedRejectionReason) => void;
};
/**
 * Translate an operation request from a strategy into a {@link ContextOperationRequest}.
 *
 * The inline strategy already produces `ContextOperationRequest` (with `type`).
 * The worker protocol produces `OperationRequest` (with `kind`). This function
 * normalizes both shapes so `processOperation` can switch on `type`.
 */
export declare function translateOperationRequest(_internals: EngineInternals, operationRequest: unknown): ContextOperationRequest;
export declare function processOperation(internals: EngineInternals, workflowId: string, operation: ContextOperationRequest, callbacks: OperationRouterCallbacks): Promise<void>;
export declare function completeOperation(_internals: EngineInternals, workflowId: string, value: unknown, callbacks: Pick<OperationRouterCallbacks, 'finalizePendingTimelineEntry' | 'feedOperationResult'>): void;
export declare function failOperation(_internals: EngineInternals, workflowId: string, operation: OperationWithCallerStack, error: unknown, callbacks: Pick<OperationRouterCallbacks, 'finalizePendingTimelineEntry' | 'feedOperationResult'>): void;
export declare function runOperationWithResult(internals: EngineInternals, workflowId: string, operation: OperationWithCallerStack, execute: () => Promise<unknown>, callbacks: OperationRouterCallbacks): Promise<void>;
export declare function runOperationWithoutResult(internals: EngineInternals, workflowId: string, operation: OperationWithCallerStack, execute: () => Promise<void>, callbacks: OperationRouterCallbacks): Promise<void>;