import { type CatalogWeftClient, type WeftClientConnection } from '../operation-client-runtime.ts'; export declare const CATALOG_OPERATION_NAMES: readonly ["weft.activities.complete", "weft.activities.fail", "weft.alerts.list", "weft.catalog.diagnostics", "weft.recover.all", "weft.retention.get", "weft.reviews.decision.submit", "weft.reviews.get", "weft.reviews.list", "weft.schedules.cancel", "weft.schedules.create", "weft.schedules.get", "weft.schedules.list", "weft.schedules.pause", "weft.schedules.resume", "weft.schedules.update", "weft.storage.capabilities", "weft.system.lease", "weft.system.metrics", "weft.system.principal", "weft.system.registry", "weft.task.queues.list", "weft.tasks.diagnostics", "weft.tasks.get", "weft.updates.result.get", "weft.worker.deployments.drain", "weft.worker.deployments.resume", "weft.workers.diagnostics", "weft.workers.drain", "weft.workers.list", "weft.workers.rejections", "weft.workers.resume", "weft.workflows.active.get", "weft.workflows.activities.pending.list", "weft.workflows.aggregate", "weft.workflows.attributes.get", "weft.workflows.attributes.set", "weft.workflows.bulk.cancel", "weft.workflows.bulk.delete", "weft.workflows.bulk.retryfailed", "weft.workflows.bulk.signal", "weft.workflows.bulk.tags", "weft.workflows.cancel", "weft.workflows.checkpoints.get", "weft.workflows.checkpoints.list", "weft.workflows.events.list", "weft.workflows.finalizer.get", "weft.workflows.fork", "weft.workflows.get", "weft.workflows.list", "weft.workflows.purge", "weft.workflows.query", "weft.workflows.replay", "weft.workflows.result.get", "weft.workflows.resume", "weft.workflows.revisions.activate", "weft.workflows.revisions.get", "weft.workflows.revisions.install", "weft.workflows.revisions.list", "weft.workflows.revisions.preload", "weft.workflows.scheduleprovenance.get", "weft.workflows.signal", "weft.workflows.start", "weft.workflows.startorsignal", "weft.workflows.streams.chunks", "weft.workflows.suspend", "weft.workflows.tags.add", "weft.workflows.tags.remove", "weft.workflows.timeline.get", "weft.workflows.timeout", "weft.workflows.update"]; export type CatalogOperationName = (typeof CATALOG_OPERATION_NAMES)[number]; export declare const CLIENT_OPERATION_NAMES: readonly ["weft.activities.complete", "weft.activities.fail", "weft.alerts.list", "weft.catalog.diagnostics", "weft.recover.all", "weft.retention.get", "weft.reviews.decision.submit", "weft.reviews.get", "weft.reviews.list", "weft.schedules.cancel", "weft.schedules.create", "weft.schedules.get", "weft.schedules.list", "weft.schedules.pause", "weft.schedules.resume", "weft.schedules.update", "weft.storage.capabilities", "weft.system.lease", "weft.system.metrics", "weft.system.principal", "weft.system.registry", "weft.task.queues.list", "weft.tasks.diagnostics", "weft.tasks.diagnostics.deadletters.clear", "weft.tasks.get", "weft.updates.result.get", "weft.worker.deployments.drain", "weft.worker.deployments.resume", "weft.workers.diagnostics", "weft.workers.drain", "weft.workers.list", "weft.workers.rejections", "weft.workers.resume", "weft.workflows.active.get", "weft.workflows.activities.pending.list", "weft.workflows.aggregate", "weft.workflows.attributes.get", "weft.workflows.attributes.set", "weft.workflows.bulk.cancel", "weft.workflows.bulk.delete", "weft.workflows.bulk.retryfailed", "weft.workflows.bulk.signal", "weft.workflows.bulk.tags", "weft.workflows.cancel", "weft.workflows.checkpoints.get", "weft.workflows.checkpoints.list", "weft.workflows.events.list", "weft.workflows.finalizer.get", "weft.workflows.fork", "weft.workflows.get", "weft.workflows.list", "weft.workflows.purge", "weft.workflows.query", "weft.workflows.replay", "weft.workflows.result.get", "weft.workflows.resume", "weft.workflows.revisions.activate", "weft.workflows.revisions.get", "weft.workflows.revisions.install", "weft.workflows.revisions.list", "weft.workflows.revisions.preload", "weft.workflows.scheduleprovenance.get", "weft.workflows.signal", "weft.workflows.start", "weft.workflows.startorsignal", "weft.workflows.streams.chunks", "weft.workflows.suspend", "weft.workflows.tags.add", "weft.workflows.tags.remove", "weft.workflows.timeline.get", "weft.workflows.timeout", "weft.workflows.update"]; export type ClientOperationName = (typeof CLIENT_OPERATION_NAMES)[number]; export declare const CLIENT_REST_OPERATION_BINDINGS: { readonly 'weft.tasks.diagnostics.deadletters.clear': { readonly method: "DELETE"; readonly path: "/tasks/diagnostics/dead-letter/:operationId"; readonly inputSources: { readonly operationId: { readonly kind: "path"; readonly pathParam: "operationId"; }; }; readonly success: { readonly kind: "json"; readonly status: 200; }; }; }; type SharedActivityContractHashArti_d7d91df4 = { readonly activityContractHash?: string; readonly artifactDigest?: string; readonly buildId?: string; readonly deploymentName?: string; readonly workflowRevision?: string; }; type SharedAffectedWorkersDeploymen_e4c61ae8 = { readonly affectedWorkers: number; readonly deploymentName: string; readonly health: 'active' | 'draining' | 'drained'; readonly inFlight: number; readonly target: 'deployment'; }; type SharedAffectedWorkersHealthInF_c3f6ebcc = { readonly affectedWorkers: number; readonly health: 'active' | 'draining' | 'drained'; readonly inFlight: number; readonly target: 'worker'; readonly workerId: string; }; type SharedAttributesBulkConcurrenc_0f0d07d6 = { readonly attributes?: ReadonlyArray; readonly bulkConcurrency?: number; readonly confirmationToken?: string; readonly createdAt?: SharedGtGteLt_d9a61361; readonly dryRun?: boolean; readonly executionDeadline?: SharedGtGteLt_d9a61361; readonly failureCategory?: 'application' | 'timeout' | 'cancellation' | 'resource' | 'system' | ReadonlyArray<'application' | 'timeout' | 'cancellation' | 'resource' | 'system'>; readonly idPrefix?: string; readonly limit?: number; readonly offset?: number; readonly parentWorkflowExecutionToken?: string; readonly parentWorkflowId?: string; readonly requestId?: string; readonly scheduleId?: string; readonly status?: 'pending' | 'running' | 'completed' | 'failed' | 'cancelled' | 'timed-out' | 'suspended' | ReadonlyArray<'pending' | 'running' | 'completed' | 'failed' | 'cancelled' | 'timed-out' | 'suspended'>; readonly tags?: ReadonlyArray; readonly type?: string; readonly updatedAt?: SharedGtGteLt_d9a61361; }; type SharedAttributesCreatedAtExecu_47f8e20e = { readonly attributes?: ReadonlyArray; readonly createdAt?: SharedGtGteLt_d9a61361; readonly executionDeadline?: SharedGtGteLt_d9a61361; readonly failureCategory?: 'application' | 'timeout' | 'cancellation' | 'resource' | 'system' | ReadonlyArray<'application' | 'timeout' | 'cancellation' | 'resource' | 'system'>; readonly idPrefix?: string; readonly limit?: number; readonly offset?: number; readonly parentWorkflowExecutionToken?: string; readonly parentWorkflowId?: string; readonly scheduleId?: string; readonly status?: 'pending' | 'running' | 'completed' | 'failed' | 'cancelled' | 'timed-out' | 'suspended' | ReadonlyArray<'pending' | 'running' | 'completed' | 'failed' | 'cancelled' | 'timed-out' | 'suspended'>; readonly tags?: ReadonlyArray; readonly type?: string; readonly updatedAt?: SharedGtGteLt_d9a61361; }; type SharedBackoffMultiplierInitial_64d024ea = { readonly backoffMultiplier: number; readonly initialBackoff: number | string; readonly maxAttempts: number; readonly maxBackoff: number | string; readonly nonRetryableErrors?: ReadonlyArray; }; type SharedGtGteKey_e658e64c = { readonly gt?: unknown; readonly gte?: unknown; readonly key: unknown; readonly lt?: unknown; readonly lte?: unknown; readonly value?: unknown; }; type SharedGtGteLt_d9a61361 = { readonly gt?: number; readonly gte?: number; readonly lt?: number; readonly lte?: number; }; export type ClientOperationTypes = { 'weft.activities.complete': { readonly input: { readonly result?: unknown; readonly token: string; }; readonly output: { readonly ok: true; }; readonly faults: 'InvalidParams' | 'NotFound'; }; 'weft.activities.fail': { readonly input: { readonly error: { readonly message: string; readonly name?: string; }; readonly token: string; }; readonly output: { readonly ok: true; }; readonly faults: 'InvalidParams' | 'NotFound'; }; 'weft.alerts.list': { readonly input: {}; readonly output: { readonly items: ReadonlyArray<{ readonly currentValue: number; readonly firedAt: number | null; readonly metric: 'workflow.failure_rate' | 'activity.p99_duration' | 'storage.size'; readonly threshold: number; readonly window: string | null; }>; }; readonly faults: never; }; 'weft.catalog.diagnostics': { readonly input: { readonly name: string; readonly revision: string; }; readonly output: { readonly active: boolean; readonly activeRevision?: string; readonly installed: boolean; readonly name: string; readonly references: { readonly activeExecutionRealms: number; readonly inFlightStarts: number; readonly nonTerminalRuns: number; readonly pendingDispatches: number; readonly pinnedSchedules: number; readonly registeredDefinitions: number; readonly retainedRecoveryRecords: number; }; readonly removable: boolean; readonly revision: string; readonly source?: { readonly kind: 'module'; readonly lastFailureCategory?: 'application' | 'timeout' | 'cancellation' | 'resource' | 'system'; readonly loadDurationMs?: number; readonly requestedRevision: string; readonly state: 'idle' | 'loading' | 'ready' | 'failed' | 'cancelled'; readonly waiterCount: number; }; }; readonly faults: never; }; 'weft.recover.all': { readonly input: {}; readonly output: { readonly recovered: ReadonlyArray; }; readonly faults: 'Conflict'; }; 'weft.retention.get': { readonly input: {}; readonly output: unknown; readonly faults: never; }; 'weft.reviews.decision.submit': { readonly input: { readonly decision?: unknown; readonly feedback?: unknown; readonly reviewId: string; readonly reviewer?: unknown; readonly sectionDecisions?: unknown; readonly workflowId?: unknown; }; readonly output: { readonly ok: true; }; readonly faults: 'NotFound'; }; 'weft.reviews.get': { readonly input: { readonly reviewId: string; readonly workflowId: string; }; readonly output: unknown; readonly faults: 'NotFound'; }; 'weft.reviews.list': { readonly input: { readonly reviewType?: string; readonly status?: 'pending' | 'completed'; readonly workflowId?: string; }; readonly output: { readonly items: ReadonlyArray<{ readonly allowPartial: boolean; readonly artifact: unknown; readonly createdAt: number; readonly reviewId: string; readonly reviewType: string; readonly reviewers: ReadonlyArray; readonly status: 'pending'; readonly timeout?: number; readonly webhookUrl?: string; readonly workflowId: string; } | { readonly allowPartial: boolean; readonly artifact: unknown; readonly createdAt: number; readonly decision: 'approved' | 'rejected' | 'needs-changes'; readonly feedback?: string; readonly reviewId: string; readonly reviewType: string; readonly reviewer: string; readonly reviewers: ReadonlyArray; readonly sectionDecisions?: Record; readonly status: 'completed'; readonly timeout?: number; readonly timestamp: number; readonly webhookUrl?: string; readonly workflowId: string; }>; }; readonly faults: never; }; 'weft.schedules.cancel': { readonly input: { readonly scheduleId: string; }; readonly output: unknown; readonly faults: 'Conflict' | 'NotFound'; }; 'weft.schedules.create': { readonly input: { readonly backfill?: unknown; readonly cronExpression?: unknown; readonly description?: unknown; readonly every?: unknown; readonly id?: unknown; readonly input?: unknown; readonly jitter?: unknown; readonly overlap?: unknown; readonly revisionPolicy?: unknown; readonly type: unknown; }; readonly output: { readonly id: string; }; readonly faults: 'Conflict' | 'NotFound'; }; 'weft.schedules.get': { readonly input: { readonly scheduleId: string; }; readonly output: unknown; readonly faults: 'Conflict' | 'NotFound'; }; 'weft.schedules.list': { readonly input: { readonly limit?: unknown; readonly offset?: unknown; readonly status?: unknown; readonly workflowType?: unknown; }; readonly output: unknown; readonly faults: 'Conflict'; }; 'weft.schedules.pause': { readonly input: { readonly scheduleId: string; }; readonly output: unknown; readonly faults: 'Conflict' | 'NotFound'; }; 'weft.schedules.resume': { readonly input: { readonly scheduleId: string; }; readonly output: unknown; readonly faults: 'Conflict' | 'NotFound'; }; 'weft.schedules.update': { readonly input: { readonly backfill?: unknown; readonly cronExpression?: unknown; readonly description?: unknown; readonly every?: unknown; readonly jitter?: unknown; readonly overlap?: unknown; readonly revisionPolicy?: unknown; readonly scheduleId: string; }; readonly output: null; readonly faults: 'Conflict' | 'InvalidParams' | 'NotFound'; }; 'weft.storage.capabilities': { readonly input: {}; readonly output: { readonly atomicBatch: boolean; readonly boundedRangeDelete: boolean; readonly conditionalBatch: boolean; readonly persistence: 'ephemeral' | 'local' | 'remote'; readonly readAfterWrite: 'linearizable' | 'session' | 'eventual'; readonly scanConsistency: 'snapshot' | 'best-effort'; }; readonly faults: never; }; 'weft.system.lease': { readonly input: {}; readonly output: { readonly expiresAt?: number; readonly fencingEpoch?: number; readonly heldSince?: number; readonly holderId?: string; readonly holdsLease: boolean; readonly lastRenewedAt?: number; readonly lossReason?: 'deposed' | 'renewal-unconfirmable'; readonly mode: 'none' | 'lease'; readonly status: 'disabled' | 'healthy' | 'no-lease' | 'contested'; }; readonly faults: never; }; 'weft.system.metrics': { readonly input: {}; readonly output: unknown; readonly faults: never; }; 'weft.system.principal': { readonly input: {}; readonly output: { readonly method: 'jwt' | 'api-key' | 'mtls' | 'stdio-local' | 'unauthenticated'; readonly scopes: ReadonlyArray<'workflows:read' | 'workflows:write' | 'workflows:admin' | 'schedules:read' | 'schedules:write' | 'signals:write' | 'updates:write' | 'queries:read' | 'reviews:read' | 'reviews:write' | 'attributes:read' | 'attributes:write' | 'tags:write' | 'streams:read' | 'events:read' | 'storage:read' | 'storage:write' | 'storage:admin' | 'workers:write' | 'system:read' | 'system:admin'>; readonly subject: string | null; }; readonly faults: never; }; 'weft.system.registry': { readonly input: {}; readonly output: { readonly activeRevisions: unknown; readonly activities: unknown; readonly generatedAt: string; readonly registryVersion: 2; readonly workflows: ReadonlyArray; }; readonly faults: never; }; 'weft.task.queues.list': { readonly input: {}; readonly output: { readonly items: ReadonlyArray<{ readonly backlog: number; readonly connectedWorkers: number; readonly inFlight: number; readonly oldestEnqueuedAt: number | null; readonly oldestQueuedAgeMs: number | null; readonly queue: string; readonly schedulingPolicy: 'priority' | 'fifo' | 'lifo'; readonly waitingPollers: number; }>; }; readonly faults: never; }; 'weft.tasks.diagnostics': { readonly input: { readonly includeExpectedDelayed: boolean; readonly limit: number; readonly operationId?: string; readonly queue?: string; readonly retryStormMinimumAttempts: number; readonly staleHeartbeatAfterMs: number; readonly staleQueuedAfterMs: number; readonly unadoptedAfterMs: number; readonly workflowId?: string; }; readonly output: { readonly items: ReadonlyArray<{ readonly activityName?: string; readonly deadLetterReason?: 'result-resolution-storage-exhausted'; readonly deadLetteredAt?: number; readonly evidence: ReadonlyArray; readonly executionLatencyMs?: number; readonly heartbeatAgeMs?: number; readonly kind: 'stuck-queued' | 'stale-inflight' | 'retry-storm' | 'all-workers-at-capacity' | 'dead-lettered'; readonly lastRequeueReason?: string; readonly operationId?: string; readonly queue?: string; readonly queueLatencyMs?: number; readonly requeueCount: number; readonly resolutionReason?: string; readonly retryAttempts?: number; readonly retryCount: number; readonly state: 'queued' | 'inflight' | 'resolved' | 'capacity' | 'dead-lettered'; readonly storageError?: string; readonly workerId?: string; readonly workflowId?: string; } | { readonly availableAt: number; readonly evidence: ReadonlyArray; readonly kind: 'delayed'; readonly operationId: string; readonly queue: string; readonly requeueCount: number; readonly retryCount: number; readonly state: 'queued'; readonly workflowId?: string; } | { readonly adopted: false; readonly evidence: ReadonlyArray; readonly kind: 'unadopted-terminal'; readonly operationId: string; readonly queue: string; readonly state: 'resolved'; readonly terminalAt: number; readonly workflowId?: string; }>; readonly limit: number; readonly summary: { readonly allWorkersAtCapacity: number; readonly deadLettered: number; readonly delayed: number; readonly retryStorms: number; readonly staleInflight: number; readonly stuckQueued: number; readonly unadoptedTerminal: number; }; }; readonly faults: never; }; 'weft.tasks.diagnostics.deadletters.clear': { readonly input: { readonly operationId: string; }; readonly output: { readonly ok: true; }; readonly faults: 'NotFound'; }; 'weft.tasks.get': { readonly input: { readonly operationId: string; }; readonly output: { readonly activityName: string; readonly attempt: number; readonly availableAt: number; readonly createdAt: number; readonly executionRequirement?: SharedActivityContractHashArti_d7d91df4; readonly fairShareKey?: string; readonly firstQueuedAt: number; readonly headerKeys: ReadonlyArray; readonly lastDispatchedAt?: number; readonly lastQueuedAt: number; readonly lastRequeueReason?: string; readonly operationId: string; readonly priority?: number; readonly queue: string; readonly requeueCount: number; readonly retryCount: number; readonly retryPolicy?: SharedBackoffMultiplierInitial_64d024ea; readonly scheduleToCloseDeadline?: number; readonly startedAt?: number; readonly state: 'queued'; readonly stickyWorkflowId?: string; readonly visibilityTimeoutMilliseconds: number; readonly workflowExecutionToken?: string; readonly workflowId?: string; readonly workflowRevision?: string; readonly workflowType: string; } | { readonly activityName: string; readonly attempt: number; readonly createdAt: number; readonly executionRequirement?: SharedActivityContractHashArti_d7d91df4; readonly fairShareKey?: string; readonly firstQueuedAt: number; readonly headerKeys: ReadonlyArray; readonly lastHeartbeatAt: number; readonly lastQueuedAt: number; readonly lastRequeueReason?: string; readonly leaseDeadline: number; readonly operationId: string; readonly priority?: number; readonly queue: string; readonly requeueCount: number; readonly retryCount: number; readonly retryPolicy?: SharedBackoffMultiplierInitial_64d024ea; readonly scheduleToCloseDeadline?: number; readonly startedAt: number; readonly state: 'leased'; readonly stickyWorkflowId?: string; readonly visibilityTimeoutMilliseconds: number; readonly workflowExecutionToken?: string; readonly workflowId?: string; readonly workflowRevision?: string; readonly workflowType: string; } | { readonly activityName: string; readonly attempt: number; readonly createdAt: number; readonly executionRequirement?: SharedActivityContractHashArti_d7d91df4; readonly fairShareKey?: string; readonly firstQueuedAt: number; readonly headerKeys: ReadonlyArray; readonly lastHeartbeatAt: number; readonly lastQueuedAt: number; readonly lastRequeueReason?: string; readonly leaseDeadline: number; readonly operationId: string; readonly pendingStatus: 'completed' | 'failed'; readonly priority?: number; readonly queue: string; readonly requeueCount: number; readonly resultDigest: string; readonly retryCount: number; readonly retryPolicy?: SharedBackoffMultiplierInitial_64d024ea; readonly scheduleToCloseDeadline?: number; readonly startedAt: number; readonly state: 'completing'; readonly stickyWorkflowId?: string; readonly visibilityTimeoutMilliseconds: number; readonly workflowExecutionToken?: string; readonly workflowId?: string; readonly workflowRevision?: string; readonly workflowType: string; } | { readonly activityName: string; readonly attempt: number; readonly cancellationReason: string; readonly cancellationRequestedAt: number; readonly createdAt: number; readonly executionRequirement?: SharedActivityContractHashArti_d7d91df4; readonly fairShareKey?: string; readonly firstQueuedAt: number; readonly headerKeys: ReadonlyArray; readonly lastHeartbeatAt: number; readonly lastQueuedAt: number; readonly lastRequeueReason?: string; readonly leaseDeadline: number; readonly operationId: string; readonly priority?: number; readonly queue: string; readonly requeueCount: number; readonly retryCount: number; readonly retryPolicy?: SharedBackoffMultiplierInitial_64d024ea; readonly scheduleToCloseDeadline?: number; readonly startedAt: number; readonly state: 'cancelling'; readonly stickyWorkflowId?: string; readonly visibilityTimeoutMilliseconds: number; readonly workflowExecutionToken?: string; readonly workflowId?: string; readonly workflowRevision?: string; readonly workflowType: string; } | { readonly activityName: string; readonly adopted: boolean; readonly adoptedAt?: number; readonly attempt: number; readonly createdAt: number; readonly disposition: 'resolved'; readonly error?: string; readonly executionRequirement?: SharedActivityContractHashArti_d7d91df4; readonly fairShareKey?: string; readonly headerKeys: ReadonlyArray; readonly operationId: string; readonly priority?: number; readonly queue: string; readonly resultDigest: string; readonly resultStatus: 'completed' | 'failed'; readonly retryPolicy?: SharedBackoffMultiplierInitial_64d024ea; readonly scheduleToCloseDeadline?: number; readonly state: 'terminal'; readonly stickyWorkflowId?: string; readonly terminalAt: number; readonly visibilityTimeoutMilliseconds: number; readonly workflowExecutionToken?: string; readonly workflowId?: string; readonly workflowRevision?: string; readonly workflowType: string; } | { readonly activityName: string; readonly adopted: boolean; readonly adoptedAt?: number; readonly attempt: number; readonly cancellationReason: string; readonly createdAt: number; readonly disposition: 'cancelled'; readonly executionRequirement?: SharedActivityContractHashArti_d7d91df4; readonly fairShareKey?: string; readonly headerKeys: ReadonlyArray; readonly operationId: string; readonly priority?: number; readonly queue: string; readonly retryPolicy?: SharedBackoffMultiplierInitial_64d024ea; readonly scheduleToCloseDeadline?: number; readonly state: 'terminal'; readonly stickyWorkflowId?: string; readonly terminalAt: number; readonly visibilityTimeoutMilliseconds: number; readonly workflowExecutionToken?: string; readonly workflowId?: string; readonly workflowRevision?: string; readonly workflowType: string; } | { readonly activityName: string; readonly adopted: boolean; readonly adoptedAt?: number; readonly attempt: number; readonly createdAt: number; readonly disposition: 'retryExhausted'; readonly error: string; readonly executionRequirement?: SharedActivityContractHashArti_d7d91df4; readonly fairShareKey?: string; readonly headerKeys: ReadonlyArray; readonly operationId: string; readonly priority?: number; readonly queue: string; readonly retryPolicy?: SharedBackoffMultiplierInitial_64d024ea; readonly scheduleToCloseDeadline?: number; readonly state: 'terminal'; readonly stickyWorkflowId?: string; readonly terminalAt: number; readonly visibilityTimeoutMilliseconds: number; readonly workflowExecutionToken?: string; readonly workflowId?: string; readonly workflowRevision?: string; readonly workflowType: string; } | { readonly activityName: string; readonly attempt: number; readonly createdAt: number; readonly deadLetteredAt: number; readonly error?: string; readonly executionRequirement?: SharedActivityContractHashArti_d7d91df4; readonly fairShareKey?: string; readonly headerKeys: ReadonlyArray; readonly lastRequeueReason?: string; readonly operationId: string; readonly pendingStatus: 'completed' | 'failed'; readonly persistenceFailureReason: string; readonly priority?: number; readonly queue: string; readonly requeueCount: number; readonly resultDigest: string; readonly retryCount: number; readonly retryPolicy?: SharedBackoffMultiplierInitial_64d024ea; readonly scheduleToCloseDeadline?: number; readonly state: 'deadLettered'; readonly stickyWorkflowId?: string; readonly visibilityTimeoutMilliseconds: number; readonly workflowExecutionToken?: string; readonly workflowId?: string; readonly workflowRevision?: string; readonly workflowType: string; }; readonly faults: 'NotFound'; }; 'weft.updates.result.get': { readonly input: { readonly updateId: string; }; readonly output: unknown; readonly faults: never; }; 'weft.worker.deployments.drain': { readonly input: { readonly deploymentName: string; readonly reason?: string; }; readonly output: SharedAffectedWorkersHealthInF_c3f6ebcc | SharedAffectedWorkersDeploymen_e4c61ae8; readonly faults: never; }; 'weft.worker.deployments.resume': { readonly input: { readonly deploymentName: string; }; readonly output: SharedAffectedWorkersHealthInF_c3f6ebcc | SharedAffectedWorkersDeploymen_e4c61ae8; readonly faults: never; }; 'weft.workers.diagnostics': { readonly input: { readonly workerId: string; }; readonly output: { readonly worker: { readonly deploymentVersion: { readonly artifactDigest: string; readonly buildId: string; readonly deploymentName: string; readonly manifestDigest: string; readonly manifestVersion: number; readonly protocolVersion: number; readonly runtimeName: string; readonly runtimeVersion: string; readonly sdkVersion: string; readonly workflows: Record; }; readonly instance: { readonly connectedAt: number; readonly health: 'active' | 'draining' | 'drained'; readonly heartbeatAgeMs: number; readonly lastHeartbeatAt: number; readonly queue: string; readonly startedAt: number; readonly workerId: string; }; } | null; }; readonly faults: never; }; 'weft.workers.drain': { readonly input: { readonly reason?: string; readonly workerId: string; }; readonly output: SharedAffectedWorkersHealthInF_c3f6ebcc | SharedAffectedWorkersDeploymen_e4c61ae8; readonly faults: 'NotFound'; }; 'weft.workers.list': { readonly input: {}; readonly output: { readonly deployments: ReadonlyArray<{ readonly activeWorkers: number; readonly buildId: string | null; readonly deploymentName: string | null; readonly drainedWorkers: number; readonly drainingWorkers: number; readonly health: 'active' | 'draining' | 'drained'; readonly inFlight: number; readonly oldestStartedAt: number | null; readonly runtimeVersion: string | null; readonly workers: number; }>; readonly items: ReadonlyArray<{ readonly activities: ReadonlyArray; readonly availableCapacity: number; readonly buildId?: string; readonly capabilities: Record; readonly concurrency: number; readonly connectedAt: number; readonly deploymentName?: string; readonly health: 'active' | 'draining' | 'drained'; readonly heartbeatAgeMs: number; readonly id: string; readonly inFlight: number; readonly lastHeartbeatAt: number; readonly queue: string; readonly runtimeVersion?: string; readonly startedAt: number; }>; readonly routingPolicy: 'least-loaded' | 'round-robin' | 'fair-share'; }; readonly faults: never; }; 'weft.workers.rejections': { readonly input: { readonly limit: number; }; readonly output: { readonly items: ReadonlyArray<{ readonly buildId?: string; readonly code: 'invalid_registration' | 'unsupported_protocol_version' | 'deployment_conflict' | 'registration_rejected'; readonly deploymentName?: string; readonly queue?: string; readonly rejectedAt: number; readonly workerId?: string; }>; readonly limit: number; }; readonly faults: never; }; 'weft.workers.resume': { readonly input: { readonly workerId: string; }; readonly output: SharedAffectedWorkersHealthInF_c3f6ebcc | SharedAffectedWorkersDeploymen_e4c61ae8; readonly faults: 'NotFound'; }; 'weft.workflows.active.get': { readonly input: { readonly name: unknown; }; readonly output: unknown; readonly faults: 'InvalidParams' | 'NotFound'; }; 'weft.workflows.activities.pending.list': { readonly input: { readonly cursor?: string; readonly limit: number; readonly workflowId: string; }; readonly output: { readonly items: ReadonlyArray<{ readonly activityName: string; readonly attempt: number; readonly createdAt: number; readonly operationId: string; readonly step: number; readonly token: string; }>; readonly nextCursor?: string; }; readonly faults: 'InvalidParams' | 'NotFound'; }; 'weft.workflows.aggregate': { readonly input: { readonly attributes?: ReadonlyArray; readonly createdAt?: SharedGtGteLt_d9a61361; readonly executionDeadline?: SharedGtGteLt_d9a61361; readonly failureCategory?: 'application' | 'timeout' | 'cancellation' | 'resource' | 'system' | ReadonlyArray<'application' | 'timeout' | 'cancellation' | 'resource' | 'system'>; readonly groupBy: 'status' | 'type' | 'failureCategory' | { readonly attribute: string; }; readonly idPrefix?: string; readonly limit?: number; readonly parentWorkflowExecutionToken?: string; readonly parentWorkflowId?: string; readonly scheduleId?: string; readonly status?: 'pending' | 'running' | 'completed' | 'failed' | 'cancelled' | 'timed-out' | 'suspended' | ReadonlyArray<'pending' | 'running' | 'completed' | 'failed' | 'cancelled' | 'timed-out' | 'suspended'>; readonly tags?: ReadonlyArray; readonly type?: string; readonly updatedAt?: SharedGtGteLt_d9a61361; }; readonly output: { readonly groups: ReadonlyArray<{ readonly count: number; readonly key: string | null; }>; readonly total: number; readonly truncated: boolean; }; readonly faults: 'Unprocessable'; }; 'weft.workflows.attributes.get': { readonly input: { readonly workflowId: string; }; readonly output: unknown; readonly faults: 'NotFound'; }; 'weft.workflows.attributes.set': { readonly input: { readonly attributes?: unknown; readonly workflowId: string; }; readonly output: { readonly ok: true; }; readonly faults: never; }; 'weft.workflows.bulk.cancel': { readonly input: SharedAttributesBulkConcurrenc_0f0d07d6; readonly output: unknown; readonly faults: never; }; 'weft.workflows.bulk.delete': { readonly input: SharedAttributesBulkConcurrenc_0f0d07d6; readonly output: unknown; readonly faults: 'Unprocessable'; }; 'weft.workflows.bulk.retryfailed': { readonly input: SharedAttributesBulkConcurrenc_0f0d07d6; readonly output: unknown; readonly faults: never; }; 'weft.workflows.bulk.signal': { readonly input: { readonly attributes?: ReadonlyArray; readonly bulkConcurrency?: number; readonly confirmationToken?: string; readonly createdAt?: SharedGtGteLt_d9a61361; readonly dryRun?: boolean; readonly executionDeadline?: SharedGtGteLt_d9a61361; readonly failureCategory?: 'application' | 'timeout' | 'cancellation' | 'resource' | 'system' | ReadonlyArray<'application' | 'timeout' | 'cancellation' | 'resource' | 'system'>; readonly idPrefix?: string; readonly limit?: number; readonly name: string; readonly offset?: number; readonly parentWorkflowExecutionToken?: string; readonly parentWorkflowId?: string; readonly payload?: unknown; readonly requestId?: string; readonly scheduleId?: string; readonly status?: 'pending' | 'running' | 'completed' | 'failed' | 'cancelled' | 'timed-out' | 'suspended' | ReadonlyArray<'pending' | 'running' | 'completed' | 'failed' | 'cancelled' | 'timed-out' | 'suspended'>; readonly tags?: ReadonlyArray; readonly type?: string; readonly updatedAt?: SharedGtGteLt_d9a61361; }; readonly output: unknown; readonly faults: never; }; 'weft.workflows.bulk.tags': { readonly input: { readonly bulkConcurrency?: number; readonly confirmationToken?: string; readonly dryRun?: boolean; readonly filter?: SharedAttributesCreatedAtExecu_47f8e20e; readonly operation: 'add' | 'remove'; readonly requestId?: string; readonly tags: ReadonlyArray; }; readonly output: unknown; readonly faults: never; }; 'weft.workflows.cancel': { readonly input: { readonly workflowId: string; }; readonly output: unknown; readonly faults: 'NotFound'; }; 'weft.workflows.checkpoints.get': { readonly input: { readonly step: number; readonly workflowId: string; }; readonly output: unknown; readonly faults: 'NotFound'; }; 'weft.workflows.checkpoints.list': { readonly input: { readonly workflowId: string; }; readonly output: unknown; readonly faults: never; }; 'weft.workflows.events.list': { readonly input: { readonly workflowId: string; }; readonly output: unknown; readonly faults: 'NotFound'; }; 'weft.workflows.finalizer.get': { readonly input: { readonly workflowId: string; }; readonly output: { readonly attempts: number; readonly status: 'pending'; } | { readonly attempts: number; readonly startedAt: number; readonly status: 'running'; } | { readonly attempts: number; readonly completedAt: number; readonly status: 'succeeded'; } | { readonly attempts: number; readonly error: string; readonly failedAt: number; readonly status: 'failed'; } | null; readonly faults: never; }; 'weft.workflows.fork': { readonly input: { readonly fromStep?: unknown; readonly revision?: string; readonly workflowId: string; }; readonly output: { readonly id: string; }; readonly faults: 'Conflict' | 'NotFound'; }; 'weft.workflows.get': { readonly input: { readonly workflowId: string; }; readonly output: unknown; readonly faults: 'NotFound'; }; 'weft.workflows.list': { readonly input: { readonly attributes?: ReadonlyArray; readonly createdAt?: SharedGtGteLt_d9a61361; readonly executionDeadline?: SharedGtGteLt_d9a61361; readonly failureCategory?: string | ReadonlyArray; readonly idPrefix?: string; readonly include?: string | ReadonlyArray; readonly limit?: number; readonly offset?: number; readonly parentWorkflowExecutionToken?: string; readonly parentWorkflowId?: string; readonly scheduleId?: string; readonly status?: string | ReadonlyArray; readonly tags?: ReadonlyArray; readonly type?: string; readonly updatedAt?: SharedGtGteLt_d9a61361; }; readonly output: unknown; readonly faults: 'Unprocessable'; }; 'weft.workflows.purge': { readonly input: SharedAttributesCreatedAtExecu_47f8e20e; readonly output: unknown; readonly faults: never; }; 'weft.workflows.query': { readonly input: { readonly input?: unknown; readonly queryName: string; readonly workflowId: string; }; readonly output: unknown; readonly faults: 'NotImplemented'; }; 'weft.workflows.replay': { readonly input: { readonly step: string | number; readonly workflowId: string; }; readonly output: unknown; readonly faults: 'Conflict' | 'NotFound'; }; 'weft.workflows.result.get': { readonly input: { readonly workflowId: string; }; readonly output: unknown; readonly faults: 'NotFound' | 'Timeout' | 'Unprocessable'; }; 'weft.workflows.resume': { readonly input: { readonly workflowId: string; }; readonly output: { readonly id: string; }; readonly faults: 'Conflict' | 'NotFound'; }; 'weft.workflows.revisions.activate': { readonly input: { readonly expectedGeneration?: unknown; readonly name: unknown; readonly policy?: unknown; readonly revision: unknown; }; readonly output: unknown; readonly faults: 'Conflict' | 'InvalidParams' | 'NotFound'; }; 'weft.workflows.revisions.get': { readonly input: { readonly name: unknown; readonly revision: unknown; }; readonly output: unknown; readonly faults: 'InvalidParams' | 'NotFound'; }; 'weft.workflows.revisions.install': { readonly input: { readonly manifest: unknown; }; readonly output: unknown; readonly faults: 'Conflict' | 'InvalidParams'; }; 'weft.workflows.revisions.list': { readonly input: { readonly name: unknown; }; readonly output: unknown; readonly faults: 'InvalidParams'; }; 'weft.workflows.revisions.preload': { readonly input: { readonly name: unknown; readonly revision: unknown; }; readonly output: unknown; readonly faults: 'Conflict' | 'InvalidParams' | 'NotFound'; }; 'weft.workflows.scheduleprovenance.get': { readonly input: { readonly workflowId: string; }; readonly output: { readonly occurrence?: number; readonly scheduleId: string; } | null; readonly faults: never; }; 'weft.workflows.signal': { readonly input: { readonly payload?: unknown; readonly signalId?: string; readonly signalName: string; readonly workflowId: string; }; readonly output: { readonly ok: true; }; readonly faults: 'NotFound'; }; 'weft.workflows.start': { readonly input: { readonly executionTimeout?: unknown; readonly id?: unknown; readonly idempotencyKey?: unknown; readonly input?: unknown; readonly searchAttributes?: unknown; readonly startAfter?: unknown; readonly startAt?: unknown; readonly tags?: unknown; readonly type: unknown; }; readonly output: { readonly id: string; }; readonly faults: 'Conflict'; }; 'weft.workflows.startorsignal': { readonly input: { readonly executionTimeout?: unknown; readonly id?: unknown; readonly idempotencyKey?: unknown; readonly input?: unknown; readonly onTerminalConflict?: unknown; readonly searchAttributes?: unknown; readonly signalId?: string; readonly signalName: string; readonly signalPayload?: unknown; readonly startAfter?: unknown; readonly startAt?: unknown; readonly tags?: unknown; readonly type: unknown; }; readonly output: { readonly id: string; readonly outcome: 'started' | 'signalled'; }; readonly faults: 'Conflict'; }; 'weft.workflows.streams.chunks': { readonly input: { readonly after?: unknown; readonly key: string; readonly workflowId: string; }; readonly output: { readonly chunks: ReadonlyArray; }; readonly faults: never; }; 'weft.workflows.suspend': { readonly input: { readonly workflowId: string; }; readonly output: unknown; readonly faults: 'Unprocessable'; }; 'weft.workflows.tags.add': { readonly input: { readonly tags?: unknown; readonly workflowId: string; }; readonly output: { readonly ok: true; }; readonly faults: 'NotFound' | 'Unprocessable'; }; 'weft.workflows.tags.remove': { readonly input: { readonly tags?: unknown; readonly workflowId: string; }; readonly output: { readonly ok: true; }; readonly faults: 'NotFound' | 'Unprocessable'; }; 'weft.workflows.timeline.get': { readonly input: { readonly workflowId: string; }; readonly output: unknown; readonly faults: 'NotFound'; }; 'weft.workflows.timeout': { readonly input: { readonly workflowId: string; }; readonly output: null; readonly faults: 'NotFound'; }; 'weft.workflows.update': { readonly input: { readonly idempotencyKey?: unknown; readonly payload?: unknown; readonly timeout?: unknown; readonly updateName: string; readonly workflowId: string; }; readonly output: { readonly result: unknown; readonly updateId: string; }; readonly faults: 'Timeout' | 'Unprocessable'; }; }; export type CatalogOperationTypes = Pick; export type WeftClient = CatalogWeftClient; export type ClientOperations = CatalogWeftClient; export declare function createWeftClient(connection?: WeftClientConnection): WeftClient; export {};