import type { StoredStreamChunk } from '../core/context.ts'; import type { BulkCancelResult, BulkDeleteResult, BulkRetryFailedResult, BulkSignalResult, BulkTagResult, CoordinatedUpdateResult, ForkOptions, ListFilter, PendingAsyncActivityListOptions, PendingAsyncActivityPage, PurgeResult, RetentionOverview, ReviewListEntry, ReviewListFilter, ScheduleSpec, ScheduleSummary, ScheduleUpdateOptions, SearchAttributeValue, SignalDeliveryOptions, SubmitReviewOptions, WorkflowReplay, WorkflowState, WorkflowTimelineEntry } from '../core/types.ts'; import type { UpdateResult } from './interface.ts'; export type HttpClientRequestContext = { readonly baseUrl: string; readonly headers: Record; }; export declare function listReviewRequests(context: HttpClientRequestContext, filter?: ReviewListFilter): Promise; export declare function submitReviewRequest(context: HttpClientRequestContext, reviewId: string, options: SubmitReviewOptions): Promise; export declare function getStreamChunkRequests(context: HttpClientRequestContext, workflowId: string, key: string, options?: { after?: number; }): Promise; export declare function forkWorkflowRequest(context: HttpClientRequestContext, id: string, options?: ForkOptions): Promise; export declare function getRetentionOverviewRequest(context: HttpClientRequestContext): Promise; export declare function purgeWorkflowRequests(context: HttpClientRequestContext, filter?: ListFilter): Promise; export declare function cancelAllWorkflowRequests(context: HttpClientRequestContext, filter: ListFilter): Promise; export declare function retryFailedAllWorkflowRequests(context: HttpClientRequestContext, filter: ListFilter): Promise; export declare function signalAllWorkflowRequests(context: HttpClientRequestContext, filter: ListFilter, name: string, payload?: unknown): Promise; export declare function deleteAllWorkflowRequests(context: HttpClientRequestContext, filter: ListFilter): Promise; export declare function tagAllWorkflowRequests(context: HttpClientRequestContext, filter: ListFilter, tags: string[]): Promise; export declare function untagAllWorkflowRequests(context: HttpClientRequestContext, filter: ListFilter, tags: string[]): Promise; export declare function submitCoordinatedUpdateRequest(context: HttpClientRequestContext, id: string, name: string, payload?: unknown, options?: { timeout?: number; idempotencyKey?: string; }): Promise; export declare function getAttributesRequest(context: HttpClientRequestContext, id: string): Promise | null>; export declare function setAttributesRequest(context: HttpClientRequestContext, id: string, attributes: Record): Promise; export declare function addTagsRequest(context: HttpClientRequestContext, id: string, tags: string[]): Promise; export declare function removeTagsRequest(context: HttpClientRequestContext, id: string, tags: string[]): Promise; export declare function getTimelineRequest(context: HttpClientRequestContext, id: string): Promise; export declare function replayToRequest(context: HttpClientRequestContext, id: string, step: number): Promise; export declare function getUpdateResultRequest(context: HttpClientRequestContext, updateId: string): Promise; /** Send a named signal (with optional payload + delivery options) to a workflow. */ export declare function signalWorkflowRequest(context: HttpClientRequestContext, id: string, name: string, payload?: unknown, options?: SignalDeliveryOptions): Promise; /** * Complete a deferred ("async") activity by task token, resuming its parked * workflow with `result`. Mirrors `LocalClient.activity.complete` over HTTP. */ export declare function completeAsyncActivityRequest(context: HttpClientRequestContext, token: string, result?: unknown): Promise; /** List durable async activities awaiting completion for one workflow. */ export declare function listPendingAsyncActivitiesRequest(context: HttpClientRequestContext, workflowId: string, options?: PendingAsyncActivityListOptions): Promise; /** * Fail a deferred ("async") activity by task token. A live `Error` cannot cross * the wire, so the error is reduced to `message` + `name` — exactly the fields * the engine itself keeps when failing an async activity — before sending. */ export declare function failAsyncActivityRequest(context: HttpClientRequestContext, token: string, error: unknown): Promise; /** Fetch a workflow's full persisted state, or `null` if it does not exist. */ export declare function getWorkflowRequest(context: HttpClientRequestContext, id: string): Promise; /** Fetch a schedule's current summary, or `null` if it does not exist. */ export declare function getScheduleRequest(context: HttpClientRequestContext, id: string): Promise; /** Cancel a running workflow (`DELETE /v1/workflows/:id`). */ export declare function cancelWorkflowRequest(context: HttpClientRequestContext, id: string): Promise; /** Force-timeout a workflow (`POST /v1/workflows/:id/timeout`). */ export declare function timeoutWorkflowRequest(context: HttpClientRequestContext, id: string): Promise; /** Suspend a running workflow (`POST /v1/workflows/:id/suspend`). */ export declare function suspendWorkflowRequest(context: HttpClientRequestContext, id: string): Promise; /** Pause a recurring schedule (`POST /v1/schedules/:id/pause`). */ export declare function pauseScheduleRequest(context: HttpClientRequestContext, id: string): Promise; /** Resume a paused schedule (`POST /v1/schedules/:id/resume`). */ export declare function resumeScheduleRequest(context: HttpClientRequestContext, id: string): Promise; /** Cancel a recurring schedule (`DELETE /v1/schedules/:id`). */ export declare function cancelScheduleRequest(context: HttpClientRequestContext, id: string): Promise; /** Update a schedule's cadence and mutable options (`PATCH /v1/schedules/:id`). */ export declare function updateScheduleRequest(context: HttpClientRequestContext, id: string, newSpec: string | ScheduleSpec, options?: ScheduleUpdateOptions): Promise; /** * Query a named read-only accessor on a workflow. A no-input query is a GET; * an input payload is sent as a POST body. */ export declare function queryWorkflowRequest(context: HttpClientRequestContext, id: string, name: string, input?: unknown): Promise;