import type { ContextOperationRequest } from '../context.ts';
import type { EngineInternals } from './internals.ts';
import type { ActivityOperationCallbacks } from './operations-activity.ts';
import type { OperationWithCallerStack } from './operations-router.ts';
type MemoOperation = Extract<ContextOperationRequest, {
    type: 'memo';
}>;
type OffloadOperation = Extract<ContextOperationRequest, {
    type: 'offload';
}>;
type LoadOperation = Extract<ContextOperationRequest, {
    type: 'load';
}>;
type ArchiveOperation = Extract<ContextOperationRequest, {
    type: 'archive';
}>;
export type DataOperationCallbacks = {
    runOperationWithResult: (workflowId: string, operation: OperationWithCallerStack, execute: () => Promise<unknown>) => Promise<void>;
    persistCheckpoint: (workflowId: string, operation: ContextOperationRequest) => Promise<void>;
    getActivityOperationCallbacks?: () => ActivityOperationCallbacks;
};
export declare function processMemoOperation(internals: EngineInternals, workflowId: string, operation: MemoOperation, callbacks: DataOperationCallbacks): Promise<void>;
export declare function processOffloadOperation(internals: EngineInternals, workflowId: string, operation: OffloadOperation, callbacks: DataOperationCallbacks): Promise<void>;
export declare function processLoadOperation(internals: EngineInternals, workflowId: string, operation: LoadOperation, callbacks: DataOperationCallbacks): Promise<void>;
/**
 * Read an offloaded value back out of storage by `workflowId` + `key`, decoding
 * it with the same codec {@link processOffloadOperation} wrote it with.
 *
 * This is the post-completion sibling of the in-workflow `ctx.load()` read
 * (see {@link processLoadOperation}): `ctx.load()` is restricted to the running
 * workflow's own offloads and throws on a miss, whereas this external reader
 * lets a consumer read a *terminal* workflow's offloaded output after
 * `handle.result()` resolves — the artifact survives normal completion
 * (`completeWorkflow`/`failWorkflow` preserve `offload:` keys) and is swept only
 * when the workflow is terminated/cancelled.
 *
 * @returns The decoded offload value, or `null` when no value is stored under
 *   that key (either the key was never written, or the artifact was swept).
 */
export declare function getOffloadFromInternals(internals: EngineInternals, workflowId: string, key: string): Promise<unknown>;
export declare function processArchiveOperation(internals: EngineInternals, workflowId: string, operation: ArchiveOperation, callbacks: DataOperationCallbacks): Promise<void>;
export {};