import type { ContextOperationRequest } from '../context.ts'; import type { HumanReviewOptions } from '../review/index.ts'; import type { ChildWorkflowOperationCallbacks } from './child-workflow.ts'; import type { Engine } from './index.ts'; import type { ActivityOperationCallbacks } from './operations-activity.ts'; import type { CoordinationOperationCallbacks } from './operations-coordination.ts'; import type { DataOperationCallbacks } from './operations-data.ts'; import { type OperationWithCallerStack } from './operations-router.ts'; import type { StateOperationCallbacks } from './operations-state.ts'; import type { StreamOperationCallbacks } from './operations-stream.ts'; import type { TimeOperationCallbacks } from './operations-time.ts'; import type { ConditionOperationCallbacks } from './operations-wait-condition.ts'; import { type UpdateCallbacks } from './updates.ts'; export declare function createChildWorkflowOperationCallbacks(engine: Engine): ChildWorkflowOperationCallbacks; export declare function createActivityOperationCallbacks(engine: Engine): ActivityOperationCallbacks; export declare function createCoordinationOperationCallbacks(engine: Engine): CoordinationOperationCallbacks; export declare function createConditionOperationCallbacks(engine: Engine): ConditionOperationCallbacks; export declare function createDataOperationCallbacks(engine: Engine): DataOperationCallbacks; export declare function createStateOperationCallbacks(engine: Engine): StateOperationCallbacks; export declare function createStreamOperationCallbacks(engine: Engine): StreamOperationCallbacks; export declare function createTimeOperationCallbacks(engine: Engine): TimeOperationCallbacks; export declare function createUpdateCallbacks(engine: Engine): UpdateCallbacks; export declare function completeOperationForEngine(engine: Engine, workflowId: string, value: unknown): void; /** * Fail the pending operation for a workflow, feeding the error to the generator * so it re-throws at the `yield*` site (catchable by the workflow body). Used by * the wait-condition processor when the user predicate throws, so a throwing * predicate surfaces as a workflow failure instead of parking the run forever. */ export declare function failOperationForEngine(engine: Engine, workflowId: string, operation: OperationWithCallerStack, error: unknown): void; export declare function runOperationWithResultForEngine(engine: Engine, workflowId: string, operation: OperationWithCallerStack, execute: () => Promise): Promise; export declare function runOperationWithoutResultForEngine(engine: Engine, workflowId: string, operation: OperationWithCallerStack, execute: () => Promise): Promise; export declare function executeSubOperationForEngine(engine: Engine, workflowId: string, operation: ContextOperationRequest, signal?: AbortSignal, speculativeState?: import('./speculative-execution-state.ts').SpeculativeExecutionState): Promise; export declare function processReviewOperationForEngine(engine: Engine, workflowId: string, options: HumanReviewOptions): Promise;