import type { DispatchQueue } from '@fabric-harness/sdk'; /** Minimal Temporal client surface needed to start a dispatch workflow. */ export interface TemporalDispatchClientLike { workflow: { start(workflowType: string, options: { taskQueue: string; workflowId: string; args: unknown[]; }): Promise; }; } export interface TemporalDispatchQueueOptions { client: TemporalDispatchClientLike; taskQueue: string; /** Workflow-id prefix; combined with the dispatchId for idempotent starts. */ workflowIdPrefix?: string; } /** * Durable dispatch queue. `enqueue` starts a `dispatchWorkflow` keyed by the * `dispatchId`, so delivery survives worker/process restarts and a duplicate * `dispatchId` maps to the same workflow id (idempotent admission). Implements * the SDK's {@link DispatchQueue}; pair with `createTemporalDispatchActivities` * on the worker. When `runtime: 'temporal'` is configured, this is the default * dispatch queue (D4) unless an explicit queue is supplied. */ export declare function temporalDispatchQueue(options: TemporalDispatchQueueOptions): DispatchQueue; //# sourceMappingURL=dispatch.d.ts.map