import type * as grpc from '@grpc/grpc-js'; import type { MethodDefinition } from '@grpc/proto-loader'; import type { AwaitWorkflowCompletionRequest as _memoflow_v1_AwaitWorkflowCompletionRequest, AwaitWorkflowCompletionRequest__Output as _memoflow_v1_AwaitWorkflowCompletionRequest__Output } from '../../memoflow/v1/AwaitWorkflowCompletionRequest.js'; import type { CancelWorkflowRequest as _memoflow_v1_CancelWorkflowRequest, CancelWorkflowRequest__Output as _memoflow_v1_CancelWorkflowRequest__Output } from '../../memoflow/v1/CancelWorkflowRequest.js'; import type { CancelWorkflowResponse as _memoflow_v1_CancelWorkflowResponse, CancelWorkflowResponse__Output as _memoflow_v1_CancelWorkflowResponse__Output } from '../../memoflow/v1/CancelWorkflowResponse.js'; import type { ClaimApprovalRequest as _memoflow_v1_ClaimApprovalRequest, ClaimApprovalRequest__Output as _memoflow_v1_ClaimApprovalRequest__Output } from '../../memoflow/v1/ClaimApprovalRequest.js'; import type { ClaimApprovalResponse as _memoflow_v1_ClaimApprovalResponse, ClaimApprovalResponse__Output as _memoflow_v1_ClaimApprovalResponse__Output } from '../../memoflow/v1/ClaimApprovalResponse.js'; import type { CreateWorkflowEvaluationRequest as _memoflow_v1_CreateWorkflowEvaluationRequest, CreateWorkflowEvaluationRequest__Output as _memoflow_v1_CreateWorkflowEvaluationRequest__Output } from '../../memoflow/v1/CreateWorkflowEvaluationRequest.js'; import type { CreateWorkflowEvaluationResponse as _memoflow_v1_CreateWorkflowEvaluationResponse, CreateWorkflowEvaluationResponse__Output as _memoflow_v1_CreateWorkflowEvaluationResponse__Output } from '../../memoflow/v1/CreateWorkflowEvaluationResponse.js'; import type { DecideApprovalRequest as _memoflow_v1_DecideApprovalRequest, DecideApprovalRequest__Output as _memoflow_v1_DecideApprovalRequest__Output } from '../../memoflow/v1/DecideApprovalRequest.js'; import type { DecideApprovalResponse as _memoflow_v1_DecideApprovalResponse, DecideApprovalResponse__Output as _memoflow_v1_DecideApprovalResponse__Output } from '../../memoflow/v1/DecideApprovalResponse.js'; import type { DeleteScheduleRequest as _memoflow_v1_DeleteScheduleRequest, DeleteScheduleRequest__Output as _memoflow_v1_DeleteScheduleRequest__Output } from '../../memoflow/v1/DeleteScheduleRequest.js'; import type { DeleteScheduleResponse as _memoflow_v1_DeleteScheduleResponse, DeleteScheduleResponse__Output as _memoflow_v1_DeleteScheduleResponse__Output } from '../../memoflow/v1/DeleteScheduleResponse.js'; import type { DescribeWorkflowRequest as _memoflow_v1_DescribeWorkflowRequest, DescribeWorkflowRequest__Output as _memoflow_v1_DescribeWorkflowRequest__Output } from '../../memoflow/v1/DescribeWorkflowRequest.js'; import type { DescribeWorkflowResponse as _memoflow_v1_DescribeWorkflowResponse, DescribeWorkflowResponse__Output as _memoflow_v1_DescribeWorkflowResponse__Output } from '../../memoflow/v1/DescribeWorkflowResponse.js'; import type { DurableOutputChunk as _memoflow_v1_DurableOutputChunk, DurableOutputChunk__Output as _memoflow_v1_DurableOutputChunk__Output } from '../../memoflow/v1/DurableOutputChunk.js'; import type { ForkWorkflowRequest as _memoflow_v1_ForkWorkflowRequest, ForkWorkflowRequest__Output as _memoflow_v1_ForkWorkflowRequest__Output } from '../../memoflow/v1/ForkWorkflowRequest.js'; import type { ForkWorkflowResponse as _memoflow_v1_ForkWorkflowResponse, ForkWorkflowResponse__Output as _memoflow_v1_ForkWorkflowResponse__Output } from '../../memoflow/v1/ForkWorkflowResponse.js'; import type { GetApprovalRequest as _memoflow_v1_GetApprovalRequest, GetApprovalRequest__Output as _memoflow_v1_GetApprovalRequest__Output } from '../../memoflow/v1/GetApprovalRequest.js'; import type { GetApprovalResponse as _memoflow_v1_GetApprovalResponse, GetApprovalResponse__Output as _memoflow_v1_GetApprovalResponse__Output } from '../../memoflow/v1/GetApprovalResponse.js'; import type { GetNamespaceConfigRequest as _memoflow_v1_GetNamespaceConfigRequest, GetNamespaceConfigRequest__Output as _memoflow_v1_GetNamespaceConfigRequest__Output } from '../../memoflow/v1/GetNamespaceConfigRequest.js'; import type { GetNamespaceConfigResponse as _memoflow_v1_GetNamespaceConfigResponse, GetNamespaceConfigResponse__Output as _memoflow_v1_GetNamespaceConfigResponse__Output } from '../../memoflow/v1/GetNamespaceConfigResponse.js'; import type { GetNamespaceStatusCountsRequest as _memoflow_v1_GetNamespaceStatusCountsRequest, GetNamespaceStatusCountsRequest__Output as _memoflow_v1_GetNamespaceStatusCountsRequest__Output } from '../../memoflow/v1/GetNamespaceStatusCountsRequest.js'; import type { GetNamespaceStatusCountsResponse as _memoflow_v1_GetNamespaceStatusCountsResponse, GetNamespaceStatusCountsResponse__Output as _memoflow_v1_GetNamespaceStatusCountsResponse__Output } from '../../memoflow/v1/GetNamespaceStatusCountsResponse.js'; import type { GetSystemMetricsRequest as _memoflow_v1_GetSystemMetricsRequest, GetSystemMetricsRequest__Output as _memoflow_v1_GetSystemMetricsRequest__Output } from '../../memoflow/v1/GetSystemMetricsRequest.js'; import type { GetSystemMetricsResponse as _memoflow_v1_GetSystemMetricsResponse, GetSystemMetricsResponse__Output as _memoflow_v1_GetSystemMetricsResponse__Output } from '../../memoflow/v1/GetSystemMetricsResponse.js'; import type { GetWorkflowHistoryRequest as _memoflow_v1_GetWorkflowHistoryRequest, GetWorkflowHistoryRequest__Output as _memoflow_v1_GetWorkflowHistoryRequest__Output } from '../../memoflow/v1/GetWorkflowHistoryRequest.js'; import type { GetWorkflowHistoryResponse as _memoflow_v1_GetWorkflowHistoryResponse, GetWorkflowHistoryResponse__Output as _memoflow_v1_GetWorkflowHistoryResponse__Output } from '../../memoflow/v1/GetWorkflowHistoryResponse.js'; import type { GetWorkflowResultRequest as _memoflow_v1_GetWorkflowResultRequest, GetWorkflowResultRequest__Output as _memoflow_v1_GetWorkflowResultRequest__Output } from '../../memoflow/v1/GetWorkflowResultRequest.js'; import type { GetWorkflowResultResponse as _memoflow_v1_GetWorkflowResultResponse, GetWorkflowResultResponse__Output as _memoflow_v1_GetWorkflowResultResponse__Output } from '../../memoflow/v1/GetWorkflowResultResponse.js'; import type { ListApprovalsRequest as _memoflow_v1_ListApprovalsRequest, ListApprovalsRequest__Output as _memoflow_v1_ListApprovalsRequest__Output } from '../../memoflow/v1/ListApprovalsRequest.js'; import type { ListApprovalsResponse as _memoflow_v1_ListApprovalsResponse, ListApprovalsResponse__Output as _memoflow_v1_ListApprovalsResponse__Output } from '../../memoflow/v1/ListApprovalsResponse.js'; import type { ListDebouncesRequest as _memoflow_v1_ListDebouncesRequest, ListDebouncesRequest__Output as _memoflow_v1_ListDebouncesRequest__Output } from '../../memoflow/v1/ListDebouncesRequest.js'; import type { ListDebouncesResponse as _memoflow_v1_ListDebouncesResponse, ListDebouncesResponse__Output as _memoflow_v1_ListDebouncesResponse__Output } from '../../memoflow/v1/ListDebouncesResponse.js'; import type { ListNamespacesRequest as _memoflow_v1_ListNamespacesRequest, ListNamespacesRequest__Output as _memoflow_v1_ListNamespacesRequest__Output } from '../../memoflow/v1/ListNamespacesRequest.js'; import type { ListNamespacesResponse as _memoflow_v1_ListNamespacesResponse, ListNamespacesResponse__Output as _memoflow_v1_ListNamespacesResponse__Output } from '../../memoflow/v1/ListNamespacesResponse.js'; import type { ListOutboxEffectsRequest as _memoflow_v1_ListOutboxEffectsRequest, ListOutboxEffectsRequest__Output as _memoflow_v1_ListOutboxEffectsRequest__Output } from '../../memoflow/v1/ListOutboxEffectsRequest.js'; import type { ListOutboxEffectsResponse as _memoflow_v1_ListOutboxEffectsResponse, ListOutboxEffectsResponse__Output as _memoflow_v1_ListOutboxEffectsResponse__Output } from '../../memoflow/v1/ListOutboxEffectsResponse.js'; import type { ListQueuesRequest as _memoflow_v1_ListQueuesRequest, ListQueuesRequest__Output as _memoflow_v1_ListQueuesRequest__Output } from '../../memoflow/v1/ListQueuesRequest.js'; import type { ListQueuesResponse as _memoflow_v1_ListQueuesResponse, ListQueuesResponse__Output as _memoflow_v1_ListQueuesResponse__Output } from '../../memoflow/v1/ListQueuesResponse.js'; import type { ListSchedulesRequest as _memoflow_v1_ListSchedulesRequest, ListSchedulesRequest__Output as _memoflow_v1_ListSchedulesRequest__Output } from '../../memoflow/v1/ListSchedulesRequest.js'; import type { ListSchedulesResponse as _memoflow_v1_ListSchedulesResponse, ListSchedulesResponse__Output as _memoflow_v1_ListSchedulesResponse__Output } from '../../memoflow/v1/ListSchedulesResponse.js'; import type { ListWorkersRequest as _memoflow_v1_ListWorkersRequest, ListWorkersRequest__Output as _memoflow_v1_ListWorkersRequest__Output } from '../../memoflow/v1/ListWorkersRequest.js'; import type { ListWorkersResponse as _memoflow_v1_ListWorkersResponse, ListWorkersResponse__Output as _memoflow_v1_ListWorkersResponse__Output } from '../../memoflow/v1/ListWorkersResponse.js'; import type { ListWorkflowEvaluationsRequest as _memoflow_v1_ListWorkflowEvaluationsRequest, ListWorkflowEvaluationsRequest__Output as _memoflow_v1_ListWorkflowEvaluationsRequest__Output } from '../../memoflow/v1/ListWorkflowEvaluationsRequest.js'; import type { ListWorkflowEvaluationsResponse as _memoflow_v1_ListWorkflowEvaluationsResponse, ListWorkflowEvaluationsResponse__Output as _memoflow_v1_ListWorkflowEvaluationsResponse__Output } from '../../memoflow/v1/ListWorkflowEvaluationsResponse.js'; import type { ListWorkflowsRequest as _memoflow_v1_ListWorkflowsRequest, ListWorkflowsRequest__Output as _memoflow_v1_ListWorkflowsRequest__Output } from '../../memoflow/v1/ListWorkflowsRequest.js'; import type { ListWorkflowsResponse as _memoflow_v1_ListWorkflowsResponse, ListWorkflowsResponse__Output as _memoflow_v1_ListWorkflowsResponse__Output } from '../../memoflow/v1/ListWorkflowsResponse.js'; import type { OverrideWorkflowBuildRequest as _memoflow_v1_OverrideWorkflowBuildRequest, OverrideWorkflowBuildRequest__Output as _memoflow_v1_OverrideWorkflowBuildRequest__Output } from '../../memoflow/v1/OverrideWorkflowBuildRequest.js'; import type { OverrideWorkflowBuildResponse as _memoflow_v1_OverrideWorkflowBuildResponse, OverrideWorkflowBuildResponse__Output as _memoflow_v1_OverrideWorkflowBuildResponse__Output } from '../../memoflow/v1/OverrideWorkflowBuildResponse.js'; import type { QueryWorkflowRequest as _memoflow_v1_QueryWorkflowRequest, QueryWorkflowRequest__Output as _memoflow_v1_QueryWorkflowRequest__Output } from '../../memoflow/v1/QueryWorkflowRequest.js'; import type { QueryWorkflowResponse as _memoflow_v1_QueryWorkflowResponse, QueryWorkflowResponse__Output as _memoflow_v1_QueryWorkflowResponse__Output } from '../../memoflow/v1/QueryWorkflowResponse.js'; import type { ReadWorkflowOutputRequest as _memoflow_v1_ReadWorkflowOutputRequest, ReadWorkflowOutputRequest__Output as _memoflow_v1_ReadWorkflowOutputRequest__Output } from '../../memoflow/v1/ReadWorkflowOutputRequest.js'; import type { RepairWorkflowProjectionRequest as _memoflow_v1_RepairWorkflowProjectionRequest, RepairWorkflowProjectionRequest__Output as _memoflow_v1_RepairWorkflowProjectionRequest__Output } from '../../memoflow/v1/RepairWorkflowProjectionRequest.js'; import type { RepairWorkflowProjectionResponse as _memoflow_v1_RepairWorkflowProjectionResponse, RepairWorkflowProjectionResponse__Output as _memoflow_v1_RepairWorkflowProjectionResponse__Output } from '../../memoflow/v1/RepairWorkflowProjectionResponse.js'; import type { ReplayOutboxEffectRequest as _memoflow_v1_ReplayOutboxEffectRequest, ReplayOutboxEffectRequest__Output as _memoflow_v1_ReplayOutboxEffectRequest__Output } from '../../memoflow/v1/ReplayOutboxEffectRequest.js'; import type { ReplayOutboxEffectResponse as _memoflow_v1_ReplayOutboxEffectResponse, ReplayOutboxEffectResponse__Output as _memoflow_v1_ReplayOutboxEffectResponse__Output } from '../../memoflow/v1/ReplayOutboxEffectResponse.js'; import type { RevealWorkflowHistoryEventPayloadRequest as _memoflow_v1_RevealWorkflowHistoryEventPayloadRequest, RevealWorkflowHistoryEventPayloadRequest__Output as _memoflow_v1_RevealWorkflowHistoryEventPayloadRequest__Output } from '../../memoflow/v1/RevealWorkflowHistoryEventPayloadRequest.js'; import type { RevealWorkflowHistoryEventPayloadResponse as _memoflow_v1_RevealWorkflowHistoryEventPayloadResponse, RevealWorkflowHistoryEventPayloadResponse__Output as _memoflow_v1_RevealWorkflowHistoryEventPayloadResponse__Output } from '../../memoflow/v1/RevealWorkflowHistoryEventPayloadResponse.js'; import type { SignalWorkflowRequest as _memoflow_v1_SignalWorkflowRequest, SignalWorkflowRequest__Output as _memoflow_v1_SignalWorkflowRequest__Output } from '../../memoflow/v1/SignalWorkflowRequest.js'; import type { SignalWorkflowResponse as _memoflow_v1_SignalWorkflowResponse, SignalWorkflowResponse__Output as _memoflow_v1_SignalWorkflowResponse__Output } from '../../memoflow/v1/SignalWorkflowResponse.js'; import type { StartDebouncedRequest as _memoflow_v1_StartDebouncedRequest, StartDebouncedRequest__Output as _memoflow_v1_StartDebouncedRequest__Output } from '../../memoflow/v1/StartDebouncedRequest.js'; import type { StartDebouncedResponse as _memoflow_v1_StartDebouncedResponse, StartDebouncedResponse__Output as _memoflow_v1_StartDebouncedResponse__Output } from '../../memoflow/v1/StartDebouncedResponse.js'; import type { StartWorkflowRequest as _memoflow_v1_StartWorkflowRequest, StartWorkflowRequest__Output as _memoflow_v1_StartWorkflowRequest__Output } from '../../memoflow/v1/StartWorkflowRequest.js'; import type { StartWorkflowResponse as _memoflow_v1_StartWorkflowResponse, StartWorkflowResponse__Output as _memoflow_v1_StartWorkflowResponse__Output } from '../../memoflow/v1/StartWorkflowResponse.js'; import type { StreamWorkflowOutputRequest as _memoflow_v1_StreamWorkflowOutputRequest, StreamWorkflowOutputRequest__Output as _memoflow_v1_StreamWorkflowOutputRequest__Output } from '../../memoflow/v1/StreamWorkflowOutputRequest.js'; import type { UpsertScheduleRequest as _memoflow_v1_UpsertScheduleRequest, UpsertScheduleRequest__Output as _memoflow_v1_UpsertScheduleRequest__Output } from '../../memoflow/v1/UpsertScheduleRequest.js'; import type { UpsertScheduleResponse as _memoflow_v1_UpsertScheduleResponse, UpsertScheduleResponse__Output as _memoflow_v1_UpsertScheduleResponse__Output } from '../../memoflow/v1/UpsertScheduleResponse.js'; import type { VerifyWorkflowProjectionRequest as _memoflow_v1_VerifyWorkflowProjectionRequest, VerifyWorkflowProjectionRequest__Output as _memoflow_v1_VerifyWorkflowProjectionRequest__Output } from '../../memoflow/v1/VerifyWorkflowProjectionRequest.js'; import type { VerifyWorkflowProjectionResponse as _memoflow_v1_VerifyWorkflowProjectionResponse, VerifyWorkflowProjectionResponse__Output as _memoflow_v1_VerifyWorkflowProjectionResponse__Output } from '../../memoflow/v1/VerifyWorkflowProjectionResponse.js'; import type { WorkflowCompletion as _memoflow_v1_WorkflowCompletion, WorkflowCompletion__Output as _memoflow_v1_WorkflowCompletion__Output } from '../../memoflow/v1/WorkflowCompletion.js'; import type { WorkflowOutputChunk as _memoflow_v1_WorkflowOutputChunk, WorkflowOutputChunk__Output as _memoflow_v1_WorkflowOutputChunk__Output } from '../../memoflow/v1/WorkflowOutputChunk.js'; export interface WorkflowServiceClient extends grpc.Client { /** * Await workflow completion via server-streaming (replaces polling). * Returns immediately if already terminal, otherwise streams completion event. * The streamed event type is shared by all completion observers. */ AwaitWorkflowCompletion(argument: _memoflow_v1_AwaitWorkflowCompletionRequest, metadata: grpc.Metadata, options?: grpc.CallOptions): grpc.ClientReadableStream<_memoflow_v1_WorkflowCompletion__Output>; AwaitWorkflowCompletion(argument: _memoflow_v1_AwaitWorkflowCompletionRequest, options?: grpc.CallOptions): grpc.ClientReadableStream<_memoflow_v1_WorkflowCompletion__Output>; /** * Await workflow completion via server-streaming (replaces polling). * Returns immediately if already terminal, otherwise streams completion event. * The streamed event type is shared by all completion observers. */ awaitWorkflowCompletion(argument: _memoflow_v1_AwaitWorkflowCompletionRequest, metadata: grpc.Metadata, options?: grpc.CallOptions): grpc.ClientReadableStream<_memoflow_v1_WorkflowCompletion__Output>; awaitWorkflowCompletion(argument: _memoflow_v1_AwaitWorkflowCompletionRequest, options?: grpc.CallOptions): grpc.ClientReadableStream<_memoflow_v1_WorkflowCompletion__Output>; /** * Cancel a running workflow. */ CancelWorkflow(argument: _memoflow_v1_CancelWorkflowRequest, metadata: grpc.Metadata, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_CancelWorkflowResponse__Output>): grpc.ClientUnaryCall; CancelWorkflow(argument: _memoflow_v1_CancelWorkflowRequest, metadata: grpc.Metadata, callback: grpc.requestCallback<_memoflow_v1_CancelWorkflowResponse__Output>): grpc.ClientUnaryCall; CancelWorkflow(argument: _memoflow_v1_CancelWorkflowRequest, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_CancelWorkflowResponse__Output>): grpc.ClientUnaryCall; CancelWorkflow(argument: _memoflow_v1_CancelWorkflowRequest, callback: grpc.requestCallback<_memoflow_v1_CancelWorkflowResponse__Output>): grpc.ClientUnaryCall; /** * Cancel a running workflow. */ cancelWorkflow(argument: _memoflow_v1_CancelWorkflowRequest, metadata: grpc.Metadata, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_CancelWorkflowResponse__Output>): grpc.ClientUnaryCall; cancelWorkflow(argument: _memoflow_v1_CancelWorkflowRequest, metadata: grpc.Metadata, callback: grpc.requestCallback<_memoflow_v1_CancelWorkflowResponse__Output>): grpc.ClientUnaryCall; cancelWorkflow(argument: _memoflow_v1_CancelWorkflowRequest, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_CancelWorkflowResponse__Output>): grpc.ClientUnaryCall; cancelWorkflow(argument: _memoflow_v1_CancelWorkflowRequest, callback: grpc.requestCallback<_memoflow_v1_CancelWorkflowResponse__Output>): grpc.ClientUnaryCall; ClaimApproval(argument: _memoflow_v1_ClaimApprovalRequest, metadata: grpc.Metadata, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_ClaimApprovalResponse__Output>): grpc.ClientUnaryCall; ClaimApproval(argument: _memoflow_v1_ClaimApprovalRequest, metadata: grpc.Metadata, callback: grpc.requestCallback<_memoflow_v1_ClaimApprovalResponse__Output>): grpc.ClientUnaryCall; ClaimApproval(argument: _memoflow_v1_ClaimApprovalRequest, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_ClaimApprovalResponse__Output>): grpc.ClientUnaryCall; ClaimApproval(argument: _memoflow_v1_ClaimApprovalRequest, callback: grpc.requestCallback<_memoflow_v1_ClaimApprovalResponse__Output>): grpc.ClientUnaryCall; claimApproval(argument: _memoflow_v1_ClaimApprovalRequest, metadata: grpc.Metadata, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_ClaimApprovalResponse__Output>): grpc.ClientUnaryCall; claimApproval(argument: _memoflow_v1_ClaimApprovalRequest, metadata: grpc.Metadata, callback: grpc.requestCallback<_memoflow_v1_ClaimApprovalResponse__Output>): grpc.ClientUnaryCall; claimApproval(argument: _memoflow_v1_ClaimApprovalRequest, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_ClaimApprovalResponse__Output>): grpc.ClientUnaryCall; claimApproval(argument: _memoflow_v1_ClaimApprovalRequest, callback: grpc.requestCallback<_memoflow_v1_ClaimApprovalResponse__Output>): grpc.ClientUnaryCall; /** * Immutable, digest-only evaluator evidence for an exact source/fork pair. * Evaluator identity comes only from authenticated transport state. */ CreateWorkflowEvaluation(argument: _memoflow_v1_CreateWorkflowEvaluationRequest, metadata: grpc.Metadata, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_CreateWorkflowEvaluationResponse__Output>): grpc.ClientUnaryCall; CreateWorkflowEvaluation(argument: _memoflow_v1_CreateWorkflowEvaluationRequest, metadata: grpc.Metadata, callback: grpc.requestCallback<_memoflow_v1_CreateWorkflowEvaluationResponse__Output>): grpc.ClientUnaryCall; CreateWorkflowEvaluation(argument: _memoflow_v1_CreateWorkflowEvaluationRequest, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_CreateWorkflowEvaluationResponse__Output>): grpc.ClientUnaryCall; CreateWorkflowEvaluation(argument: _memoflow_v1_CreateWorkflowEvaluationRequest, callback: grpc.requestCallback<_memoflow_v1_CreateWorkflowEvaluationResponse__Output>): grpc.ClientUnaryCall; /** * Immutable, digest-only evaluator evidence for an exact source/fork pair. * Evaluator identity comes only from authenticated transport state. */ createWorkflowEvaluation(argument: _memoflow_v1_CreateWorkflowEvaluationRequest, metadata: grpc.Metadata, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_CreateWorkflowEvaluationResponse__Output>): grpc.ClientUnaryCall; createWorkflowEvaluation(argument: _memoflow_v1_CreateWorkflowEvaluationRequest, metadata: grpc.Metadata, callback: grpc.requestCallback<_memoflow_v1_CreateWorkflowEvaluationResponse__Output>): grpc.ClientUnaryCall; createWorkflowEvaluation(argument: _memoflow_v1_CreateWorkflowEvaluationRequest, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_CreateWorkflowEvaluationResponse__Output>): grpc.ClientUnaryCall; createWorkflowEvaluation(argument: _memoflow_v1_CreateWorkflowEvaluationRequest, callback: grpc.requestCallback<_memoflow_v1_CreateWorkflowEvaluationResponse__Output>): grpc.ClientUnaryCall; DecideApproval(argument: _memoflow_v1_DecideApprovalRequest, metadata: grpc.Metadata, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_DecideApprovalResponse__Output>): grpc.ClientUnaryCall; DecideApproval(argument: _memoflow_v1_DecideApprovalRequest, metadata: grpc.Metadata, callback: grpc.requestCallback<_memoflow_v1_DecideApprovalResponse__Output>): grpc.ClientUnaryCall; DecideApproval(argument: _memoflow_v1_DecideApprovalRequest, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_DecideApprovalResponse__Output>): grpc.ClientUnaryCall; DecideApproval(argument: _memoflow_v1_DecideApprovalRequest, callback: grpc.requestCallback<_memoflow_v1_DecideApprovalResponse__Output>): grpc.ClientUnaryCall; decideApproval(argument: _memoflow_v1_DecideApprovalRequest, metadata: grpc.Metadata, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_DecideApprovalResponse__Output>): grpc.ClientUnaryCall; decideApproval(argument: _memoflow_v1_DecideApprovalRequest, metadata: grpc.Metadata, callback: grpc.requestCallback<_memoflow_v1_DecideApprovalResponse__Output>): grpc.ClientUnaryCall; decideApproval(argument: _memoflow_v1_DecideApprovalRequest, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_DecideApprovalResponse__Output>): grpc.ClientUnaryCall; decideApproval(argument: _memoflow_v1_DecideApprovalRequest, callback: grpc.requestCallback<_memoflow_v1_DecideApprovalResponse__Output>): grpc.ClientUnaryCall; /** * Remove a schedule. Idempotent — deleting an unknown schedule_id is not * an error. */ DeleteSchedule(argument: _memoflow_v1_DeleteScheduleRequest, metadata: grpc.Metadata, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_DeleteScheduleResponse__Output>): grpc.ClientUnaryCall; DeleteSchedule(argument: _memoflow_v1_DeleteScheduleRequest, metadata: grpc.Metadata, callback: grpc.requestCallback<_memoflow_v1_DeleteScheduleResponse__Output>): grpc.ClientUnaryCall; DeleteSchedule(argument: _memoflow_v1_DeleteScheduleRequest, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_DeleteScheduleResponse__Output>): grpc.ClientUnaryCall; DeleteSchedule(argument: _memoflow_v1_DeleteScheduleRequest, callback: grpc.requestCallback<_memoflow_v1_DeleteScheduleResponse__Output>): grpc.ClientUnaryCall; /** * Remove a schedule. Idempotent — deleting an unknown schedule_id is not * an error. */ deleteSchedule(argument: _memoflow_v1_DeleteScheduleRequest, metadata: grpc.Metadata, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_DeleteScheduleResponse__Output>): grpc.ClientUnaryCall; deleteSchedule(argument: _memoflow_v1_DeleteScheduleRequest, metadata: grpc.Metadata, callback: grpc.requestCallback<_memoflow_v1_DeleteScheduleResponse__Output>): grpc.ClientUnaryCall; deleteSchedule(argument: _memoflow_v1_DeleteScheduleRequest, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_DeleteScheduleResponse__Output>): grpc.ClientUnaryCall; deleteSchedule(argument: _memoflow_v1_DeleteScheduleRequest, callback: grpc.requestCallback<_memoflow_v1_DeleteScheduleResponse__Output>): grpc.ClientUnaryCall; /** * Describe a specific workflow execution. */ DescribeWorkflow(argument: _memoflow_v1_DescribeWorkflowRequest, metadata: grpc.Metadata, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_DescribeWorkflowResponse__Output>): grpc.ClientUnaryCall; DescribeWorkflow(argument: _memoflow_v1_DescribeWorkflowRequest, metadata: grpc.Metadata, callback: grpc.requestCallback<_memoflow_v1_DescribeWorkflowResponse__Output>): grpc.ClientUnaryCall; DescribeWorkflow(argument: _memoflow_v1_DescribeWorkflowRequest, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_DescribeWorkflowResponse__Output>): grpc.ClientUnaryCall; DescribeWorkflow(argument: _memoflow_v1_DescribeWorkflowRequest, callback: grpc.requestCallback<_memoflow_v1_DescribeWorkflowResponse__Output>): grpc.ClientUnaryCall; /** * Describe a specific workflow execution. */ describeWorkflow(argument: _memoflow_v1_DescribeWorkflowRequest, metadata: grpc.Metadata, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_DescribeWorkflowResponse__Output>): grpc.ClientUnaryCall; describeWorkflow(argument: _memoflow_v1_DescribeWorkflowRequest, metadata: grpc.Metadata, callback: grpc.requestCallback<_memoflow_v1_DescribeWorkflowResponse__Output>): grpc.ClientUnaryCall; describeWorkflow(argument: _memoflow_v1_DescribeWorkflowRequest, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_DescribeWorkflowResponse__Output>): grpc.ClientUnaryCall; describeWorkflow(argument: _memoflow_v1_DescribeWorkflowRequest, callback: grpc.requestCallback<_memoflow_v1_DescribeWorkflowResponse__Output>): grpc.ClientUnaryCall; /** * P6.5 — restart-from-step (operational time travel). Creates a NEW run * (fresh run_id, same workflow_id) seeded with checkpoints * 0..=step_seq copied VERBATIM from an existing terminal (or explicitly * paused) run, then dispatches it through the normal start/redispatch * path so it re-executes from step_seq+1 onward. The source run is never * mutated — see ForkWorkflowResponse and the ForkWorkflow handler * (crates/server/src/grpc/workflow_service.rs) for the full contract, * including why forking a RUNNING run is rejected and how claim-check * blob refs (P3.4) are shared (not copied) between the source and the * fork. */ ForkWorkflow(argument: _memoflow_v1_ForkWorkflowRequest, metadata: grpc.Metadata, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_ForkWorkflowResponse__Output>): grpc.ClientUnaryCall; ForkWorkflow(argument: _memoflow_v1_ForkWorkflowRequest, metadata: grpc.Metadata, callback: grpc.requestCallback<_memoflow_v1_ForkWorkflowResponse__Output>): grpc.ClientUnaryCall; ForkWorkflow(argument: _memoflow_v1_ForkWorkflowRequest, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_ForkWorkflowResponse__Output>): grpc.ClientUnaryCall; ForkWorkflow(argument: _memoflow_v1_ForkWorkflowRequest, callback: grpc.requestCallback<_memoflow_v1_ForkWorkflowResponse__Output>): grpc.ClientUnaryCall; /** * P6.5 — restart-from-step (operational time travel). Creates a NEW run * (fresh run_id, same workflow_id) seeded with checkpoints * 0..=step_seq copied VERBATIM from an existing terminal (or explicitly * paused) run, then dispatches it through the normal start/redispatch * path so it re-executes from step_seq+1 onward. The source run is never * mutated — see ForkWorkflowResponse and the ForkWorkflow handler * (crates/server/src/grpc/workflow_service.rs) for the full contract, * including why forking a RUNNING run is rejected and how claim-check * blob refs (P3.4) are shared (not copied) between the source and the * fork. */ forkWorkflow(argument: _memoflow_v1_ForkWorkflowRequest, metadata: grpc.Metadata, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_ForkWorkflowResponse__Output>): grpc.ClientUnaryCall; forkWorkflow(argument: _memoflow_v1_ForkWorkflowRequest, metadata: grpc.Metadata, callback: grpc.requestCallback<_memoflow_v1_ForkWorkflowResponse__Output>): grpc.ClientUnaryCall; forkWorkflow(argument: _memoflow_v1_ForkWorkflowRequest, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_ForkWorkflowResponse__Output>): grpc.ClientUnaryCall; forkWorkflow(argument: _memoflow_v1_ForkWorkflowRequest, callback: grpc.requestCallback<_memoflow_v1_ForkWorkflowResponse__Output>): grpc.ClientUnaryCall; /** * First-class durable approval work items. Reads are namespace/run scoped; * claim and decision actor identity comes only from authenticated transport * state and is never accepted from these messages. */ GetApproval(argument: _memoflow_v1_GetApprovalRequest, metadata: grpc.Metadata, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_GetApprovalResponse__Output>): grpc.ClientUnaryCall; GetApproval(argument: _memoflow_v1_GetApprovalRequest, metadata: grpc.Metadata, callback: grpc.requestCallback<_memoflow_v1_GetApprovalResponse__Output>): grpc.ClientUnaryCall; GetApproval(argument: _memoflow_v1_GetApprovalRequest, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_GetApprovalResponse__Output>): grpc.ClientUnaryCall; GetApproval(argument: _memoflow_v1_GetApprovalRequest, callback: grpc.requestCallback<_memoflow_v1_GetApprovalResponse__Output>): grpc.ClientUnaryCall; /** * First-class durable approval work items. Reads are namespace/run scoped; * claim and decision actor identity comes only from authenticated transport * state and is never accepted from these messages. */ getApproval(argument: _memoflow_v1_GetApprovalRequest, metadata: grpc.Metadata, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_GetApprovalResponse__Output>): grpc.ClientUnaryCall; getApproval(argument: _memoflow_v1_GetApprovalRequest, metadata: grpc.Metadata, callback: grpc.requestCallback<_memoflow_v1_GetApprovalResponse__Output>): grpc.ClientUnaryCall; getApproval(argument: _memoflow_v1_GetApprovalRequest, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_GetApprovalResponse__Output>): grpc.ClientUnaryCall; getApproval(argument: _memoflow_v1_GetApprovalRequest, callback: grpc.requestCallback<_memoflow_v1_GetApprovalResponse__Output>): grpc.ClientUnaryCall; GetNamespaceConfig(argument: _memoflow_v1_GetNamespaceConfigRequest, metadata: grpc.Metadata, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_GetNamespaceConfigResponse__Output>): grpc.ClientUnaryCall; GetNamespaceConfig(argument: _memoflow_v1_GetNamespaceConfigRequest, metadata: grpc.Metadata, callback: grpc.requestCallback<_memoflow_v1_GetNamespaceConfigResponse__Output>): grpc.ClientUnaryCall; GetNamespaceConfig(argument: _memoflow_v1_GetNamespaceConfigRequest, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_GetNamespaceConfigResponse__Output>): grpc.ClientUnaryCall; GetNamespaceConfig(argument: _memoflow_v1_GetNamespaceConfigRequest, callback: grpc.requestCallback<_memoflow_v1_GetNamespaceConfigResponse__Output>): grpc.ClientUnaryCall; getNamespaceConfig(argument: _memoflow_v1_GetNamespaceConfigRequest, metadata: grpc.Metadata, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_GetNamespaceConfigResponse__Output>): grpc.ClientUnaryCall; getNamespaceConfig(argument: _memoflow_v1_GetNamespaceConfigRequest, metadata: grpc.Metadata, callback: grpc.requestCallback<_memoflow_v1_GetNamespaceConfigResponse__Output>): grpc.ClientUnaryCall; getNamespaceConfig(argument: _memoflow_v1_GetNamespaceConfigRequest, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_GetNamespaceConfigResponse__Output>): grpc.ClientUnaryCall; getNamespaceConfig(argument: _memoflow_v1_GetNamespaceConfigRequest, callback: grpc.requestCallback<_memoflow_v1_GetNamespaceConfigResponse__Output>): grpc.ClientUnaryCall; /** * Namespace-scoped administrative reads. Scoped keys may read only their * namespace; global administrators may select any namespace. */ GetNamespaceStatusCounts(argument: _memoflow_v1_GetNamespaceStatusCountsRequest, metadata: grpc.Metadata, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_GetNamespaceStatusCountsResponse__Output>): grpc.ClientUnaryCall; GetNamespaceStatusCounts(argument: _memoflow_v1_GetNamespaceStatusCountsRequest, metadata: grpc.Metadata, callback: grpc.requestCallback<_memoflow_v1_GetNamespaceStatusCountsResponse__Output>): grpc.ClientUnaryCall; GetNamespaceStatusCounts(argument: _memoflow_v1_GetNamespaceStatusCountsRequest, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_GetNamespaceStatusCountsResponse__Output>): grpc.ClientUnaryCall; GetNamespaceStatusCounts(argument: _memoflow_v1_GetNamespaceStatusCountsRequest, callback: grpc.requestCallback<_memoflow_v1_GetNamespaceStatusCountsResponse__Output>): grpc.ClientUnaryCall; /** * Namespace-scoped administrative reads. Scoped keys may read only their * namespace; global administrators may select any namespace. */ getNamespaceStatusCounts(argument: _memoflow_v1_GetNamespaceStatusCountsRequest, metadata: grpc.Metadata, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_GetNamespaceStatusCountsResponse__Output>): grpc.ClientUnaryCall; getNamespaceStatusCounts(argument: _memoflow_v1_GetNamespaceStatusCountsRequest, metadata: grpc.Metadata, callback: grpc.requestCallback<_memoflow_v1_GetNamespaceStatusCountsResponse__Output>): grpc.ClientUnaryCall; getNamespaceStatusCounts(argument: _memoflow_v1_GetNamespaceStatusCountsRequest, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_GetNamespaceStatusCountsResponse__Output>): grpc.ClientUnaryCall; getNamespaceStatusCounts(argument: _memoflow_v1_GetNamespaceStatusCountsRequest, callback: grpc.requestCallback<_memoflow_v1_GetNamespaceStatusCountsResponse__Output>): grpc.ClientUnaryCall; /** * Process and durable outbox health counters. Requires an admin (`*`) API key. */ GetSystemMetrics(argument: _memoflow_v1_GetSystemMetricsRequest, metadata: grpc.Metadata, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_GetSystemMetricsResponse__Output>): grpc.ClientUnaryCall; GetSystemMetrics(argument: _memoflow_v1_GetSystemMetricsRequest, metadata: grpc.Metadata, callback: grpc.requestCallback<_memoflow_v1_GetSystemMetricsResponse__Output>): grpc.ClientUnaryCall; GetSystemMetrics(argument: _memoflow_v1_GetSystemMetricsRequest, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_GetSystemMetricsResponse__Output>): grpc.ClientUnaryCall; GetSystemMetrics(argument: _memoflow_v1_GetSystemMetricsRequest, callback: grpc.requestCallback<_memoflow_v1_GetSystemMetricsResponse__Output>): grpc.ClientUnaryCall; /** * Process and durable outbox health counters. Requires an admin (`*`) API key. */ getSystemMetrics(argument: _memoflow_v1_GetSystemMetricsRequest, metadata: grpc.Metadata, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_GetSystemMetricsResponse__Output>): grpc.ClientUnaryCall; getSystemMetrics(argument: _memoflow_v1_GetSystemMetricsRequest, metadata: grpc.Metadata, callback: grpc.requestCallback<_memoflow_v1_GetSystemMetricsResponse__Output>): grpc.ClientUnaryCall; getSystemMetrics(argument: _memoflow_v1_GetSystemMetricsRequest, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_GetSystemMetricsResponse__Output>): grpc.ClientUnaryCall; getSystemMetrics(argument: _memoflow_v1_GetSystemMetricsRequest, callback: grpc.requestCallback<_memoflow_v1_GetSystemMetricsResponse__Output>): grpc.ClientUnaryCall; /** * Read the authoritative append-only event history for one workflow run. */ GetWorkflowHistory(argument: _memoflow_v1_GetWorkflowHistoryRequest, metadata: grpc.Metadata, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_GetWorkflowHistoryResponse__Output>): grpc.ClientUnaryCall; GetWorkflowHistory(argument: _memoflow_v1_GetWorkflowHistoryRequest, metadata: grpc.Metadata, callback: grpc.requestCallback<_memoflow_v1_GetWorkflowHistoryResponse__Output>): grpc.ClientUnaryCall; GetWorkflowHistory(argument: _memoflow_v1_GetWorkflowHistoryRequest, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_GetWorkflowHistoryResponse__Output>): grpc.ClientUnaryCall; GetWorkflowHistory(argument: _memoflow_v1_GetWorkflowHistoryRequest, callback: grpc.requestCallback<_memoflow_v1_GetWorkflowHistoryResponse__Output>): grpc.ClientUnaryCall; /** * Read the authoritative append-only event history for one workflow run. */ getWorkflowHistory(argument: _memoflow_v1_GetWorkflowHistoryRequest, metadata: grpc.Metadata, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_GetWorkflowHistoryResponse__Output>): grpc.ClientUnaryCall; getWorkflowHistory(argument: _memoflow_v1_GetWorkflowHistoryRequest, metadata: grpc.Metadata, callback: grpc.requestCallback<_memoflow_v1_GetWorkflowHistoryResponse__Output>): grpc.ClientUnaryCall; getWorkflowHistory(argument: _memoflow_v1_GetWorkflowHistoryRequest, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_GetWorkflowHistoryResponse__Output>): grpc.ClientUnaryCall; getWorkflowHistory(argument: _memoflow_v1_GetWorkflowHistoryRequest, callback: grpc.requestCallback<_memoflow_v1_GetWorkflowHistoryResponse__Output>): grpc.ClientUnaryCall; /** * Get the result of a workflow (blocks until complete or timeout). */ GetWorkflowResult(argument: _memoflow_v1_GetWorkflowResultRequest, metadata: grpc.Metadata, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_GetWorkflowResultResponse__Output>): grpc.ClientUnaryCall; GetWorkflowResult(argument: _memoflow_v1_GetWorkflowResultRequest, metadata: grpc.Metadata, callback: grpc.requestCallback<_memoflow_v1_GetWorkflowResultResponse__Output>): grpc.ClientUnaryCall; GetWorkflowResult(argument: _memoflow_v1_GetWorkflowResultRequest, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_GetWorkflowResultResponse__Output>): grpc.ClientUnaryCall; GetWorkflowResult(argument: _memoflow_v1_GetWorkflowResultRequest, callback: grpc.requestCallback<_memoflow_v1_GetWorkflowResultResponse__Output>): grpc.ClientUnaryCall; /** * Get the result of a workflow (blocks until complete or timeout). */ getWorkflowResult(argument: _memoflow_v1_GetWorkflowResultRequest, metadata: grpc.Metadata, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_GetWorkflowResultResponse__Output>): grpc.ClientUnaryCall; getWorkflowResult(argument: _memoflow_v1_GetWorkflowResultRequest, metadata: grpc.Metadata, callback: grpc.requestCallback<_memoflow_v1_GetWorkflowResultResponse__Output>): grpc.ClientUnaryCall; getWorkflowResult(argument: _memoflow_v1_GetWorkflowResultRequest, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_GetWorkflowResultResponse__Output>): grpc.ClientUnaryCall; getWorkflowResult(argument: _memoflow_v1_GetWorkflowResultRequest, callback: grpc.requestCallback<_memoflow_v1_GetWorkflowResultResponse__Output>): grpc.ClientUnaryCall; ListApprovals(argument: _memoflow_v1_ListApprovalsRequest, metadata: grpc.Metadata, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_ListApprovalsResponse__Output>): grpc.ClientUnaryCall; ListApprovals(argument: _memoflow_v1_ListApprovalsRequest, metadata: grpc.Metadata, callback: grpc.requestCallback<_memoflow_v1_ListApprovalsResponse__Output>): grpc.ClientUnaryCall; ListApprovals(argument: _memoflow_v1_ListApprovalsRequest, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_ListApprovalsResponse__Output>): grpc.ClientUnaryCall; ListApprovals(argument: _memoflow_v1_ListApprovalsRequest, callback: grpc.requestCallback<_memoflow_v1_ListApprovalsResponse__Output>): grpc.ClientUnaryCall; listApprovals(argument: _memoflow_v1_ListApprovalsRequest, metadata: grpc.Metadata, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_ListApprovalsResponse__Output>): grpc.ClientUnaryCall; listApprovals(argument: _memoflow_v1_ListApprovalsRequest, metadata: grpc.Metadata, callback: grpc.requestCallback<_memoflow_v1_ListApprovalsResponse__Output>): grpc.ClientUnaryCall; listApprovals(argument: _memoflow_v1_ListApprovalsRequest, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_ListApprovalsResponse__Output>): grpc.ClientUnaryCall; listApprovals(argument: _memoflow_v1_ListApprovalsRequest, callback: grpc.requestCallback<_memoflow_v1_ListApprovalsResponse__Output>): grpc.ClientUnaryCall; /** * Namespace-scoped operator inventory. Input payloads are structurally * absent so a read cannot disclose last-write-wins workflow input. */ ListDebounces(argument: _memoflow_v1_ListDebouncesRequest, metadata: grpc.Metadata, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_ListDebouncesResponse__Output>): grpc.ClientUnaryCall; ListDebounces(argument: _memoflow_v1_ListDebouncesRequest, metadata: grpc.Metadata, callback: grpc.requestCallback<_memoflow_v1_ListDebouncesResponse__Output>): grpc.ClientUnaryCall; ListDebounces(argument: _memoflow_v1_ListDebouncesRequest, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_ListDebouncesResponse__Output>): grpc.ClientUnaryCall; ListDebounces(argument: _memoflow_v1_ListDebouncesRequest, callback: grpc.requestCallback<_memoflow_v1_ListDebouncesResponse__Output>): grpc.ClientUnaryCall; /** * Namespace-scoped operator inventory. Input payloads are structurally * absent so a read cannot disclose last-write-wins workflow input. */ listDebounces(argument: _memoflow_v1_ListDebouncesRequest, metadata: grpc.Metadata, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_ListDebouncesResponse__Output>): grpc.ClientUnaryCall; listDebounces(argument: _memoflow_v1_ListDebouncesRequest, metadata: grpc.Metadata, callback: grpc.requestCallback<_memoflow_v1_ListDebouncesResponse__Output>): grpc.ClientUnaryCall; listDebounces(argument: _memoflow_v1_ListDebouncesRequest, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_ListDebouncesResponse__Output>): grpc.ClientUnaryCall; listDebounces(argument: _memoflow_v1_ListDebouncesRequest, callback: grpc.requestCallback<_memoflow_v1_ListDebouncesResponse__Output>): grpc.ClientUnaryCall; /** * Global namespace catalog. Requires an admin (`*`) API key. */ ListNamespaces(argument: _memoflow_v1_ListNamespacesRequest, metadata: grpc.Metadata, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_ListNamespacesResponse__Output>): grpc.ClientUnaryCall; ListNamespaces(argument: _memoflow_v1_ListNamespacesRequest, metadata: grpc.Metadata, callback: grpc.requestCallback<_memoflow_v1_ListNamespacesResponse__Output>): grpc.ClientUnaryCall; ListNamespaces(argument: _memoflow_v1_ListNamespacesRequest, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_ListNamespacesResponse__Output>): grpc.ClientUnaryCall; ListNamespaces(argument: _memoflow_v1_ListNamespacesRequest, callback: grpc.requestCallback<_memoflow_v1_ListNamespacesResponse__Output>): grpc.ClientUnaryCall; /** * Global namespace catalog. Requires an admin (`*`) API key. */ listNamespaces(argument: _memoflow_v1_ListNamespacesRequest, metadata: grpc.Metadata, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_ListNamespacesResponse__Output>): grpc.ClientUnaryCall; listNamespaces(argument: _memoflow_v1_ListNamespacesRequest, metadata: grpc.Metadata, callback: grpc.requestCallback<_memoflow_v1_ListNamespacesResponse__Output>): grpc.ClientUnaryCall; listNamespaces(argument: _memoflow_v1_ListNamespacesRequest, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_ListNamespacesResponse__Output>): grpc.ClientUnaryCall; listNamespaces(argument: _memoflow_v1_ListNamespacesRequest, callback: grpc.requestCallback<_memoflow_v1_ListNamespacesResponse__Output>): grpc.ClientUnaryCall; /** * Global operator APIs. These require an admin (`*`) API key. */ ListOutboxEffects(argument: _memoflow_v1_ListOutboxEffectsRequest, metadata: grpc.Metadata, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_ListOutboxEffectsResponse__Output>): grpc.ClientUnaryCall; ListOutboxEffects(argument: _memoflow_v1_ListOutboxEffectsRequest, metadata: grpc.Metadata, callback: grpc.requestCallback<_memoflow_v1_ListOutboxEffectsResponse__Output>): grpc.ClientUnaryCall; ListOutboxEffects(argument: _memoflow_v1_ListOutboxEffectsRequest, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_ListOutboxEffectsResponse__Output>): grpc.ClientUnaryCall; ListOutboxEffects(argument: _memoflow_v1_ListOutboxEffectsRequest, callback: grpc.requestCallback<_memoflow_v1_ListOutboxEffectsResponse__Output>): grpc.ClientUnaryCall; /** * Global operator APIs. These require an admin (`*`) API key. */ listOutboxEffects(argument: _memoflow_v1_ListOutboxEffectsRequest, metadata: grpc.Metadata, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_ListOutboxEffectsResponse__Output>): grpc.ClientUnaryCall; listOutboxEffects(argument: _memoflow_v1_ListOutboxEffectsRequest, metadata: grpc.Metadata, callback: grpc.requestCallback<_memoflow_v1_ListOutboxEffectsResponse__Output>): grpc.ClientUnaryCall; listOutboxEffects(argument: _memoflow_v1_ListOutboxEffectsRequest, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_ListOutboxEffectsResponse__Output>): grpc.ClientUnaryCall; listOutboxEffects(argument: _memoflow_v1_ListOutboxEffectsRequest, callback: grpc.requestCallback<_memoflow_v1_ListOutboxEffectsResponse__Output>): grpc.ClientUnaryCall; ListQueues(argument: _memoflow_v1_ListQueuesRequest, metadata: grpc.Metadata, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_ListQueuesResponse__Output>): grpc.ClientUnaryCall; ListQueues(argument: _memoflow_v1_ListQueuesRequest, metadata: grpc.Metadata, callback: grpc.requestCallback<_memoflow_v1_ListQueuesResponse__Output>): grpc.ClientUnaryCall; ListQueues(argument: _memoflow_v1_ListQueuesRequest, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_ListQueuesResponse__Output>): grpc.ClientUnaryCall; ListQueues(argument: _memoflow_v1_ListQueuesRequest, callback: grpc.requestCallback<_memoflow_v1_ListQueuesResponse__Output>): grpc.ClientUnaryCall; listQueues(argument: _memoflow_v1_ListQueuesRequest, metadata: grpc.Metadata, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_ListQueuesResponse__Output>): grpc.ClientUnaryCall; listQueues(argument: _memoflow_v1_ListQueuesRequest, metadata: grpc.Metadata, callback: grpc.requestCallback<_memoflow_v1_ListQueuesResponse__Output>): grpc.ClientUnaryCall; listQueues(argument: _memoflow_v1_ListQueuesRequest, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_ListQueuesResponse__Output>): grpc.ClientUnaryCall; listQueues(argument: _memoflow_v1_ListQueuesRequest, callback: grpc.requestCallback<_memoflow_v1_ListQueuesResponse__Output>): grpc.ClientUnaryCall; /** * List schedules registered in a namespace. */ ListSchedules(argument: _memoflow_v1_ListSchedulesRequest, metadata: grpc.Metadata, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_ListSchedulesResponse__Output>): grpc.ClientUnaryCall; ListSchedules(argument: _memoflow_v1_ListSchedulesRequest, metadata: grpc.Metadata, callback: grpc.requestCallback<_memoflow_v1_ListSchedulesResponse__Output>): grpc.ClientUnaryCall; ListSchedules(argument: _memoflow_v1_ListSchedulesRequest, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_ListSchedulesResponse__Output>): grpc.ClientUnaryCall; ListSchedules(argument: _memoflow_v1_ListSchedulesRequest, callback: grpc.requestCallback<_memoflow_v1_ListSchedulesResponse__Output>): grpc.ClientUnaryCall; /** * List schedules registered in a namespace. */ listSchedules(argument: _memoflow_v1_ListSchedulesRequest, metadata: grpc.Metadata, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_ListSchedulesResponse__Output>): grpc.ClientUnaryCall; listSchedules(argument: _memoflow_v1_ListSchedulesRequest, metadata: grpc.Metadata, callback: grpc.requestCallback<_memoflow_v1_ListSchedulesResponse__Output>): grpc.ClientUnaryCall; listSchedules(argument: _memoflow_v1_ListSchedulesRequest, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_ListSchedulesResponse__Output>): grpc.ClientUnaryCall; listSchedules(argument: _memoflow_v1_ListSchedulesRequest, callback: grpc.requestCallback<_memoflow_v1_ListSchedulesResponse__Output>): grpc.ClientUnaryCall; /** * Connected workers plus RUNNING workflow queues with no compatible * workflow worker. Requires an admin (`*`) API key. */ ListWorkers(argument: _memoflow_v1_ListWorkersRequest, metadata: grpc.Metadata, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_ListWorkersResponse__Output>): grpc.ClientUnaryCall; ListWorkers(argument: _memoflow_v1_ListWorkersRequest, metadata: grpc.Metadata, callback: grpc.requestCallback<_memoflow_v1_ListWorkersResponse__Output>): grpc.ClientUnaryCall; ListWorkers(argument: _memoflow_v1_ListWorkersRequest, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_ListWorkersResponse__Output>): grpc.ClientUnaryCall; ListWorkers(argument: _memoflow_v1_ListWorkersRequest, callback: grpc.requestCallback<_memoflow_v1_ListWorkersResponse__Output>): grpc.ClientUnaryCall; /** * Connected workers plus RUNNING workflow queues with no compatible * workflow worker. Requires an admin (`*`) API key. */ listWorkers(argument: _memoflow_v1_ListWorkersRequest, metadata: grpc.Metadata, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_ListWorkersResponse__Output>): grpc.ClientUnaryCall; listWorkers(argument: _memoflow_v1_ListWorkersRequest, metadata: grpc.Metadata, callback: grpc.requestCallback<_memoflow_v1_ListWorkersResponse__Output>): grpc.ClientUnaryCall; listWorkers(argument: _memoflow_v1_ListWorkersRequest, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_ListWorkersResponse__Output>): grpc.ClientUnaryCall; listWorkers(argument: _memoflow_v1_ListWorkersRequest, callback: grpc.requestCallback<_memoflow_v1_ListWorkersResponse__Output>): grpc.ClientUnaryCall; ListWorkflowEvaluations(argument: _memoflow_v1_ListWorkflowEvaluationsRequest, metadata: grpc.Metadata, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_ListWorkflowEvaluationsResponse__Output>): grpc.ClientUnaryCall; ListWorkflowEvaluations(argument: _memoflow_v1_ListWorkflowEvaluationsRequest, metadata: grpc.Metadata, callback: grpc.requestCallback<_memoflow_v1_ListWorkflowEvaluationsResponse__Output>): grpc.ClientUnaryCall; ListWorkflowEvaluations(argument: _memoflow_v1_ListWorkflowEvaluationsRequest, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_ListWorkflowEvaluationsResponse__Output>): grpc.ClientUnaryCall; ListWorkflowEvaluations(argument: _memoflow_v1_ListWorkflowEvaluationsRequest, callback: grpc.requestCallback<_memoflow_v1_ListWorkflowEvaluationsResponse__Output>): grpc.ClientUnaryCall; listWorkflowEvaluations(argument: _memoflow_v1_ListWorkflowEvaluationsRequest, metadata: grpc.Metadata, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_ListWorkflowEvaluationsResponse__Output>): grpc.ClientUnaryCall; listWorkflowEvaluations(argument: _memoflow_v1_ListWorkflowEvaluationsRequest, metadata: grpc.Metadata, callback: grpc.requestCallback<_memoflow_v1_ListWorkflowEvaluationsResponse__Output>): grpc.ClientUnaryCall; listWorkflowEvaluations(argument: _memoflow_v1_ListWorkflowEvaluationsRequest, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_ListWorkflowEvaluationsResponse__Output>): grpc.ClientUnaryCall; listWorkflowEvaluations(argument: _memoflow_v1_ListWorkflowEvaluationsRequest, callback: grpc.requestCallback<_memoflow_v1_ListWorkflowEvaluationsResponse__Output>): grpc.ClientUnaryCall; /** * List workflows with optional filters. */ ListWorkflows(argument: _memoflow_v1_ListWorkflowsRequest, metadata: grpc.Metadata, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_ListWorkflowsResponse__Output>): grpc.ClientUnaryCall; ListWorkflows(argument: _memoflow_v1_ListWorkflowsRequest, metadata: grpc.Metadata, callback: grpc.requestCallback<_memoflow_v1_ListWorkflowsResponse__Output>): grpc.ClientUnaryCall; ListWorkflows(argument: _memoflow_v1_ListWorkflowsRequest, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_ListWorkflowsResponse__Output>): grpc.ClientUnaryCall; ListWorkflows(argument: _memoflow_v1_ListWorkflowsRequest, callback: grpc.requestCallback<_memoflow_v1_ListWorkflowsResponse__Output>): grpc.ClientUnaryCall; /** * List workflows with optional filters. */ listWorkflows(argument: _memoflow_v1_ListWorkflowsRequest, metadata: grpc.Metadata, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_ListWorkflowsResponse__Output>): grpc.ClientUnaryCall; listWorkflows(argument: _memoflow_v1_ListWorkflowsRequest, metadata: grpc.Metadata, callback: grpc.requestCallback<_memoflow_v1_ListWorkflowsResponse__Output>): grpc.ClientUnaryCall; listWorkflows(argument: _memoflow_v1_ListWorkflowsRequest, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_ListWorkflowsResponse__Output>): grpc.ClientUnaryCall; listWorkflows(argument: _memoflow_v1_ListWorkflowsRequest, callback: grpc.requestCallback<_memoflow_v1_ListWorkflowsResponse__Output>): grpc.ClientUnaryCall; /** * Global-admin escape hatch for a BLOCKED_NONDETERMINISTIC run. Atomically * repins the run and appends an operator audit event before redispatch. */ OverrideWorkflowBuild(argument: _memoflow_v1_OverrideWorkflowBuildRequest, metadata: grpc.Metadata, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_OverrideWorkflowBuildResponse__Output>): grpc.ClientUnaryCall; OverrideWorkflowBuild(argument: _memoflow_v1_OverrideWorkflowBuildRequest, metadata: grpc.Metadata, callback: grpc.requestCallback<_memoflow_v1_OverrideWorkflowBuildResponse__Output>): grpc.ClientUnaryCall; OverrideWorkflowBuild(argument: _memoflow_v1_OverrideWorkflowBuildRequest, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_OverrideWorkflowBuildResponse__Output>): grpc.ClientUnaryCall; OverrideWorkflowBuild(argument: _memoflow_v1_OverrideWorkflowBuildRequest, callback: grpc.requestCallback<_memoflow_v1_OverrideWorkflowBuildResponse__Output>): grpc.ClientUnaryCall; /** * Global-admin escape hatch for a BLOCKED_NONDETERMINISTIC run. Atomically * repins the run and appends an operator audit event before redispatch. */ overrideWorkflowBuild(argument: _memoflow_v1_OverrideWorkflowBuildRequest, metadata: grpc.Metadata, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_OverrideWorkflowBuildResponse__Output>): grpc.ClientUnaryCall; overrideWorkflowBuild(argument: _memoflow_v1_OverrideWorkflowBuildRequest, metadata: grpc.Metadata, callback: grpc.requestCallback<_memoflow_v1_OverrideWorkflowBuildResponse__Output>): grpc.ClientUnaryCall; overrideWorkflowBuild(argument: _memoflow_v1_OverrideWorkflowBuildRequest, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_OverrideWorkflowBuildResponse__Output>): grpc.ClientUnaryCall; overrideWorkflowBuild(argument: _memoflow_v1_OverrideWorkflowBuildRequest, callback: grpc.requestCallback<_memoflow_v1_OverrideWorkflowBuildResponse__Output>): grpc.ClientUnaryCall; /** * Query a running workflow (read-only, does not mutate state). */ QueryWorkflow(argument: _memoflow_v1_QueryWorkflowRequest, metadata: grpc.Metadata, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_QueryWorkflowResponse__Output>): grpc.ClientUnaryCall; QueryWorkflow(argument: _memoflow_v1_QueryWorkflowRequest, metadata: grpc.Metadata, callback: grpc.requestCallback<_memoflow_v1_QueryWorkflowResponse__Output>): grpc.ClientUnaryCall; QueryWorkflow(argument: _memoflow_v1_QueryWorkflowRequest, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_QueryWorkflowResponse__Output>): grpc.ClientUnaryCall; QueryWorkflow(argument: _memoflow_v1_QueryWorkflowRequest, callback: grpc.requestCallback<_memoflow_v1_QueryWorkflowResponse__Output>): grpc.ClientUnaryCall; /** * Query a running workflow (read-only, does not mutate state). */ queryWorkflow(argument: _memoflow_v1_QueryWorkflowRequest, metadata: grpc.Metadata, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_QueryWorkflowResponse__Output>): grpc.ClientUnaryCall; queryWorkflow(argument: _memoflow_v1_QueryWorkflowRequest, metadata: grpc.Metadata, callback: grpc.requestCallback<_memoflow_v1_QueryWorkflowResponse__Output>): grpc.ClientUnaryCall; queryWorkflow(argument: _memoflow_v1_QueryWorkflowRequest, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_QueryWorkflowResponse__Output>): grpc.ClientUnaryCall; queryWorkflow(argument: _memoflow_v1_QueryWorkflowRequest, callback: grpc.requestCallback<_memoflow_v1_QueryWorkflowResponse__Output>): grpc.ClientUnaryCall; /** * DATA-006 durable run output. Offset-addressed and store-backed; callers * may reconnect through another server with the returned resume token. */ ReadWorkflowOutput(argument: _memoflow_v1_ReadWorkflowOutputRequest, metadata: grpc.Metadata, options?: grpc.CallOptions): grpc.ClientReadableStream<_memoflow_v1_DurableOutputChunk__Output>; ReadWorkflowOutput(argument: _memoflow_v1_ReadWorkflowOutputRequest, options?: grpc.CallOptions): grpc.ClientReadableStream<_memoflow_v1_DurableOutputChunk__Output>; /** * DATA-006 durable run output. Offset-addressed and store-backed; callers * may reconnect through another server with the returned resume token. */ readWorkflowOutput(argument: _memoflow_v1_ReadWorkflowOutputRequest, metadata: grpc.Metadata, options?: grpc.CallOptions): grpc.ClientReadableStream<_memoflow_v1_DurableOutputChunk__Output>; readWorkflowOutput(argument: _memoflow_v1_ReadWorkflowOutputRequest, options?: grpc.CallOptions): grpc.ClientReadableStream<_memoflow_v1_DurableOutputChunk__Output>; /** * Maintenance-only operator mutation. Rebuilds projections only when the * authoritative history still has the exact sequence and digest supplied * by a preceding VerifyWorkflowProjection call. */ RepairWorkflowProjection(argument: _memoflow_v1_RepairWorkflowProjectionRequest, metadata: grpc.Metadata, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_RepairWorkflowProjectionResponse__Output>): grpc.ClientUnaryCall; RepairWorkflowProjection(argument: _memoflow_v1_RepairWorkflowProjectionRequest, metadata: grpc.Metadata, callback: grpc.requestCallback<_memoflow_v1_RepairWorkflowProjectionResponse__Output>): grpc.ClientUnaryCall; RepairWorkflowProjection(argument: _memoflow_v1_RepairWorkflowProjectionRequest, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_RepairWorkflowProjectionResponse__Output>): grpc.ClientUnaryCall; RepairWorkflowProjection(argument: _memoflow_v1_RepairWorkflowProjectionRequest, callback: grpc.requestCallback<_memoflow_v1_RepairWorkflowProjectionResponse__Output>): grpc.ClientUnaryCall; /** * Maintenance-only operator mutation. Rebuilds projections only when the * authoritative history still has the exact sequence and digest supplied * by a preceding VerifyWorkflowProjection call. */ repairWorkflowProjection(argument: _memoflow_v1_RepairWorkflowProjectionRequest, metadata: grpc.Metadata, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_RepairWorkflowProjectionResponse__Output>): grpc.ClientUnaryCall; repairWorkflowProjection(argument: _memoflow_v1_RepairWorkflowProjectionRequest, metadata: grpc.Metadata, callback: grpc.requestCallback<_memoflow_v1_RepairWorkflowProjectionResponse__Output>): grpc.ClientUnaryCall; repairWorkflowProjection(argument: _memoflow_v1_RepairWorkflowProjectionRequest, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_RepairWorkflowProjectionResponse__Output>): grpc.ClientUnaryCall; repairWorkflowProjection(argument: _memoflow_v1_RepairWorkflowProjectionRequest, callback: grpc.requestCallback<_memoflow_v1_RepairWorkflowProjectionResponse__Output>): grpc.ClientUnaryCall; ReplayOutboxEffect(argument: _memoflow_v1_ReplayOutboxEffectRequest, metadata: grpc.Metadata, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_ReplayOutboxEffectResponse__Output>): grpc.ClientUnaryCall; ReplayOutboxEffect(argument: _memoflow_v1_ReplayOutboxEffectRequest, metadata: grpc.Metadata, callback: grpc.requestCallback<_memoflow_v1_ReplayOutboxEffectResponse__Output>): grpc.ClientUnaryCall; ReplayOutboxEffect(argument: _memoflow_v1_ReplayOutboxEffectRequest, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_ReplayOutboxEffectResponse__Output>): grpc.ClientUnaryCall; ReplayOutboxEffect(argument: _memoflow_v1_ReplayOutboxEffectRequest, callback: grpc.requestCallback<_memoflow_v1_ReplayOutboxEffectResponse__Output>): grpc.ClientUnaryCall; replayOutboxEffect(argument: _memoflow_v1_ReplayOutboxEffectRequest, metadata: grpc.Metadata, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_ReplayOutboxEffectResponse__Output>): grpc.ClientUnaryCall; replayOutboxEffect(argument: _memoflow_v1_ReplayOutboxEffectRequest, metadata: grpc.Metadata, callback: grpc.requestCallback<_memoflow_v1_ReplayOutboxEffectResponse__Output>): grpc.ClientUnaryCall; replayOutboxEffect(argument: _memoflow_v1_ReplayOutboxEffectRequest, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_ReplayOutboxEffectResponse__Output>): grpc.ClientUnaryCall; replayOutboxEffect(argument: _memoflow_v1_ReplayOutboxEffectRequest, callback: grpc.requestCallback<_memoflow_v1_ReplayOutboxEffectResponse__Output>): grpc.ClientUnaryCall; /** * Reveal one immutable event payload. This is a privileged break-glass read: * a justification is mandatory and plaintext is returned only after its * immutable audit record commits. */ RevealWorkflowHistoryEventPayload(argument: _memoflow_v1_RevealWorkflowHistoryEventPayloadRequest, metadata: grpc.Metadata, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_RevealWorkflowHistoryEventPayloadResponse__Output>): grpc.ClientUnaryCall; RevealWorkflowHistoryEventPayload(argument: _memoflow_v1_RevealWorkflowHistoryEventPayloadRequest, metadata: grpc.Metadata, callback: grpc.requestCallback<_memoflow_v1_RevealWorkflowHistoryEventPayloadResponse__Output>): grpc.ClientUnaryCall; RevealWorkflowHistoryEventPayload(argument: _memoflow_v1_RevealWorkflowHistoryEventPayloadRequest, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_RevealWorkflowHistoryEventPayloadResponse__Output>): grpc.ClientUnaryCall; RevealWorkflowHistoryEventPayload(argument: _memoflow_v1_RevealWorkflowHistoryEventPayloadRequest, callback: grpc.requestCallback<_memoflow_v1_RevealWorkflowHistoryEventPayloadResponse__Output>): grpc.ClientUnaryCall; /** * Reveal one immutable event payload. This is a privileged break-glass read: * a justification is mandatory and plaintext is returned only after its * immutable audit record commits. */ revealWorkflowHistoryEventPayload(argument: _memoflow_v1_RevealWorkflowHistoryEventPayloadRequest, metadata: grpc.Metadata, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_RevealWorkflowHistoryEventPayloadResponse__Output>): grpc.ClientUnaryCall; revealWorkflowHistoryEventPayload(argument: _memoflow_v1_RevealWorkflowHistoryEventPayloadRequest, metadata: grpc.Metadata, callback: grpc.requestCallback<_memoflow_v1_RevealWorkflowHistoryEventPayloadResponse__Output>): grpc.ClientUnaryCall; revealWorkflowHistoryEventPayload(argument: _memoflow_v1_RevealWorkflowHistoryEventPayloadRequest, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_RevealWorkflowHistoryEventPayloadResponse__Output>): grpc.ClientUnaryCall; revealWorkflowHistoryEventPayload(argument: _memoflow_v1_RevealWorkflowHistoryEventPayloadRequest, callback: grpc.requestCallback<_memoflow_v1_RevealWorkflowHistoryEventPayloadResponse__Output>): grpc.ClientUnaryCall; /** * Send a signal to a running workflow. */ SignalWorkflow(argument: _memoflow_v1_SignalWorkflowRequest, metadata: grpc.Metadata, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_SignalWorkflowResponse__Output>): grpc.ClientUnaryCall; SignalWorkflow(argument: _memoflow_v1_SignalWorkflowRequest, metadata: grpc.Metadata, callback: grpc.requestCallback<_memoflow_v1_SignalWorkflowResponse__Output>): grpc.ClientUnaryCall; SignalWorkflow(argument: _memoflow_v1_SignalWorkflowRequest, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_SignalWorkflowResponse__Output>): grpc.ClientUnaryCall; SignalWorkflow(argument: _memoflow_v1_SignalWorkflowRequest, callback: grpc.requestCallback<_memoflow_v1_SignalWorkflowResponse__Output>): grpc.ClientUnaryCall; /** * Send a signal to a running workflow. */ signalWorkflow(argument: _memoflow_v1_SignalWorkflowRequest, metadata: grpc.Metadata, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_SignalWorkflowResponse__Output>): grpc.ClientUnaryCall; signalWorkflow(argument: _memoflow_v1_SignalWorkflowRequest, metadata: grpc.Metadata, callback: grpc.requestCallback<_memoflow_v1_SignalWorkflowResponse__Output>): grpc.ClientUnaryCall; signalWorkflow(argument: _memoflow_v1_SignalWorkflowRequest, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_SignalWorkflowResponse__Output>): grpc.ClientUnaryCall; signalWorkflow(argument: _memoflow_v1_SignalWorkflowRequest, callback: grpc.requestCallback<_memoflow_v1_SignalWorkflowResponse__Output>): grpc.ClientUnaryCall; /** * ── Start debouncing (P6.4) ──────────────────────────────────────────── * * Collapse rapid repeated calls sharing `key` into ONE workflow start, * using the LAST-supplied input (last-write-wins), fired once `window` * elapses since the most recent call. Returns immediately — the actual * StartWorkflow happens later, asynchronously, when the debounce poller * observes the window has closed. */ StartDebounced(argument: _memoflow_v1_StartDebouncedRequest, metadata: grpc.Metadata, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_StartDebouncedResponse__Output>): grpc.ClientUnaryCall; StartDebounced(argument: _memoflow_v1_StartDebouncedRequest, metadata: grpc.Metadata, callback: grpc.requestCallback<_memoflow_v1_StartDebouncedResponse__Output>): grpc.ClientUnaryCall; StartDebounced(argument: _memoflow_v1_StartDebouncedRequest, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_StartDebouncedResponse__Output>): grpc.ClientUnaryCall; StartDebounced(argument: _memoflow_v1_StartDebouncedRequest, callback: grpc.requestCallback<_memoflow_v1_StartDebouncedResponse__Output>): grpc.ClientUnaryCall; /** * ── Start debouncing (P6.4) ──────────────────────────────────────────── * * Collapse rapid repeated calls sharing `key` into ONE workflow start, * using the LAST-supplied input (last-write-wins), fired once `window` * elapses since the most recent call. Returns immediately — the actual * StartWorkflow happens later, asynchronously, when the debounce poller * observes the window has closed. */ startDebounced(argument: _memoflow_v1_StartDebouncedRequest, metadata: grpc.Metadata, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_StartDebouncedResponse__Output>): grpc.ClientUnaryCall; startDebounced(argument: _memoflow_v1_StartDebouncedRequest, metadata: grpc.Metadata, callback: grpc.requestCallback<_memoflow_v1_StartDebouncedResponse__Output>): grpc.ClientUnaryCall; startDebounced(argument: _memoflow_v1_StartDebouncedRequest, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_StartDebouncedResponse__Output>): grpc.ClientUnaryCall; startDebounced(argument: _memoflow_v1_StartDebouncedRequest, callback: grpc.requestCallback<_memoflow_v1_StartDebouncedResponse__Output>): grpc.ClientUnaryCall; /** * Start a new workflow execution. */ StartWorkflow(argument: _memoflow_v1_StartWorkflowRequest, metadata: grpc.Metadata, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_StartWorkflowResponse__Output>): grpc.ClientUnaryCall; StartWorkflow(argument: _memoflow_v1_StartWorkflowRequest, metadata: grpc.Metadata, callback: grpc.requestCallback<_memoflow_v1_StartWorkflowResponse__Output>): grpc.ClientUnaryCall; StartWorkflow(argument: _memoflow_v1_StartWorkflowRequest, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_StartWorkflowResponse__Output>): grpc.ClientUnaryCall; StartWorkflow(argument: _memoflow_v1_StartWorkflowRequest, callback: grpc.requestCallback<_memoflow_v1_StartWorkflowResponse__Output>): grpc.ClientUnaryCall; /** * Start a new workflow execution. */ startWorkflow(argument: _memoflow_v1_StartWorkflowRequest, metadata: grpc.Metadata, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_StartWorkflowResponse__Output>): grpc.ClientUnaryCall; startWorkflow(argument: _memoflow_v1_StartWorkflowRequest, metadata: grpc.Metadata, callback: grpc.requestCallback<_memoflow_v1_StartWorkflowResponse__Output>): grpc.ClientUnaryCall; startWorkflow(argument: _memoflow_v1_StartWorkflowRequest, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_StartWorkflowResponse__Output>): grpc.ClientUnaryCall; startWorkflow(argument: _memoflow_v1_StartWorkflowRequest, callback: grpc.requestCallback<_memoflow_v1_StartWorkflowResponse__Output>): grpc.ClientUnaryCall; /** * P3.5 — subscribe to best-effort streaming step output (ctx.stream()) for * a workflow run. Server-streaming, in-process relay only (single server, * no persistence, no cross-server fanout — see StreamChunk in * worker_service.proto for the full semantics). The stream never * terminates on its own; callers cancel when done (the dashboard's SSE * handler cancels on client disconnect). A subscriber that connects after * a chunk was emitted has already missed it — this is observability, not * a durable log. * The chunk type is the shared wire event, not an RPC-specific wrapper. */ StreamWorkflowOutput(argument: _memoflow_v1_StreamWorkflowOutputRequest, metadata: grpc.Metadata, options?: grpc.CallOptions): grpc.ClientReadableStream<_memoflow_v1_WorkflowOutputChunk__Output>; StreamWorkflowOutput(argument: _memoflow_v1_StreamWorkflowOutputRequest, options?: grpc.CallOptions): grpc.ClientReadableStream<_memoflow_v1_WorkflowOutputChunk__Output>; /** * P3.5 — subscribe to best-effort streaming step output (ctx.stream()) for * a workflow run. Server-streaming, in-process relay only (single server, * no persistence, no cross-server fanout — see StreamChunk in * worker_service.proto for the full semantics). The stream never * terminates on its own; callers cancel when done (the dashboard's SSE * handler cancels on client disconnect). A subscriber that connects after * a chunk was emitted has already missed it — this is observability, not * a durable log. * The chunk type is the shared wire event, not an RPC-specific wrapper. */ streamWorkflowOutput(argument: _memoflow_v1_StreamWorkflowOutputRequest, metadata: grpc.Metadata, options?: grpc.CallOptions): grpc.ClientReadableStream<_memoflow_v1_WorkflowOutputChunk__Output>; streamWorkflowOutput(argument: _memoflow_v1_StreamWorkflowOutputRequest, options?: grpc.CallOptions): grpc.ClientReadableStream<_memoflow_v1_WorkflowOutputChunk__Output>; /** * ── Cron schedules (P6.4) ────────────────────────────────────────────── * * Create or replace a durable cron schedule. Idempotent: calling again * with the same (namespace, schedule_id) replaces the cron expression, * input, task queue, and missed-fire policy, and only resets next_fire_at * if the cron expression changed (a no-op re-registration on every worker * restart — the common case — must not perturb an already-scheduled fire). */ UpsertSchedule(argument: _memoflow_v1_UpsertScheduleRequest, metadata: grpc.Metadata, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_UpsertScheduleResponse__Output>): grpc.ClientUnaryCall; UpsertSchedule(argument: _memoflow_v1_UpsertScheduleRequest, metadata: grpc.Metadata, callback: grpc.requestCallback<_memoflow_v1_UpsertScheduleResponse__Output>): grpc.ClientUnaryCall; UpsertSchedule(argument: _memoflow_v1_UpsertScheduleRequest, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_UpsertScheduleResponse__Output>): grpc.ClientUnaryCall; UpsertSchedule(argument: _memoflow_v1_UpsertScheduleRequest, callback: grpc.requestCallback<_memoflow_v1_UpsertScheduleResponse__Output>): grpc.ClientUnaryCall; /** * ── Cron schedules (P6.4) ────────────────────────────────────────────── * * Create or replace a durable cron schedule. Idempotent: calling again * with the same (namespace, schedule_id) replaces the cron expression, * input, task queue, and missed-fire policy, and only resets next_fire_at * if the cron expression changed (a no-op re-registration on every worker * restart — the common case — must not perturb an already-scheduled fire). */ upsertSchedule(argument: _memoflow_v1_UpsertScheduleRequest, metadata: grpc.Metadata, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_UpsertScheduleResponse__Output>): grpc.ClientUnaryCall; upsertSchedule(argument: _memoflow_v1_UpsertScheduleRequest, metadata: grpc.Metadata, callback: grpc.requestCallback<_memoflow_v1_UpsertScheduleResponse__Output>): grpc.ClientUnaryCall; upsertSchedule(argument: _memoflow_v1_UpsertScheduleRequest, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_UpsertScheduleResponse__Output>): grpc.ClientUnaryCall; upsertSchedule(argument: _memoflow_v1_UpsertScheduleRequest, callback: grpc.requestCallback<_memoflow_v1_UpsertScheduleResponse__Output>): grpc.ClientUnaryCall; /** * Operator read: strictly reduce authoritative execution events and compare * them with the current run/checkpoint/pending-signal projections. */ VerifyWorkflowProjection(argument: _memoflow_v1_VerifyWorkflowProjectionRequest, metadata: grpc.Metadata, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_VerifyWorkflowProjectionResponse__Output>): grpc.ClientUnaryCall; VerifyWorkflowProjection(argument: _memoflow_v1_VerifyWorkflowProjectionRequest, metadata: grpc.Metadata, callback: grpc.requestCallback<_memoflow_v1_VerifyWorkflowProjectionResponse__Output>): grpc.ClientUnaryCall; VerifyWorkflowProjection(argument: _memoflow_v1_VerifyWorkflowProjectionRequest, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_VerifyWorkflowProjectionResponse__Output>): grpc.ClientUnaryCall; VerifyWorkflowProjection(argument: _memoflow_v1_VerifyWorkflowProjectionRequest, callback: grpc.requestCallback<_memoflow_v1_VerifyWorkflowProjectionResponse__Output>): grpc.ClientUnaryCall; /** * Operator read: strictly reduce authoritative execution events and compare * them with the current run/checkpoint/pending-signal projections. */ verifyWorkflowProjection(argument: _memoflow_v1_VerifyWorkflowProjectionRequest, metadata: grpc.Metadata, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_VerifyWorkflowProjectionResponse__Output>): grpc.ClientUnaryCall; verifyWorkflowProjection(argument: _memoflow_v1_VerifyWorkflowProjectionRequest, metadata: grpc.Metadata, callback: grpc.requestCallback<_memoflow_v1_VerifyWorkflowProjectionResponse__Output>): grpc.ClientUnaryCall; verifyWorkflowProjection(argument: _memoflow_v1_VerifyWorkflowProjectionRequest, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_VerifyWorkflowProjectionResponse__Output>): grpc.ClientUnaryCall; verifyWorkflowProjection(argument: _memoflow_v1_VerifyWorkflowProjectionRequest, callback: grpc.requestCallback<_memoflow_v1_VerifyWorkflowProjectionResponse__Output>): grpc.ClientUnaryCall; } export interface WorkflowServiceHandlers extends grpc.UntypedServiceImplementation { /** * Await workflow completion via server-streaming (replaces polling). * Returns immediately if already terminal, otherwise streams completion event. * The streamed event type is shared by all completion observers. */ AwaitWorkflowCompletion: grpc.handleServerStreamingCall<_memoflow_v1_AwaitWorkflowCompletionRequest__Output, _memoflow_v1_WorkflowCompletion>; /** * Cancel a running workflow. */ CancelWorkflow: grpc.handleUnaryCall<_memoflow_v1_CancelWorkflowRequest__Output, _memoflow_v1_CancelWorkflowResponse>; ClaimApproval: grpc.handleUnaryCall<_memoflow_v1_ClaimApprovalRequest__Output, _memoflow_v1_ClaimApprovalResponse>; /** * Immutable, digest-only evaluator evidence for an exact source/fork pair. * Evaluator identity comes only from authenticated transport state. */ CreateWorkflowEvaluation: grpc.handleUnaryCall<_memoflow_v1_CreateWorkflowEvaluationRequest__Output, _memoflow_v1_CreateWorkflowEvaluationResponse>; DecideApproval: grpc.handleUnaryCall<_memoflow_v1_DecideApprovalRequest__Output, _memoflow_v1_DecideApprovalResponse>; /** * Remove a schedule. Idempotent — deleting an unknown schedule_id is not * an error. */ DeleteSchedule: grpc.handleUnaryCall<_memoflow_v1_DeleteScheduleRequest__Output, _memoflow_v1_DeleteScheduleResponse>; /** * Describe a specific workflow execution. */ DescribeWorkflow: grpc.handleUnaryCall<_memoflow_v1_DescribeWorkflowRequest__Output, _memoflow_v1_DescribeWorkflowResponse>; /** * P6.5 — restart-from-step (operational time travel). Creates a NEW run * (fresh run_id, same workflow_id) seeded with checkpoints * 0..=step_seq copied VERBATIM from an existing terminal (or explicitly * paused) run, then dispatches it through the normal start/redispatch * path so it re-executes from step_seq+1 onward. The source run is never * mutated — see ForkWorkflowResponse and the ForkWorkflow handler * (crates/server/src/grpc/workflow_service.rs) for the full contract, * including why forking a RUNNING run is rejected and how claim-check * blob refs (P3.4) are shared (not copied) between the source and the * fork. */ ForkWorkflow: grpc.handleUnaryCall<_memoflow_v1_ForkWorkflowRequest__Output, _memoflow_v1_ForkWorkflowResponse>; /** * First-class durable approval work items. Reads are namespace/run scoped; * claim and decision actor identity comes only from authenticated transport * state and is never accepted from these messages. */ GetApproval: grpc.handleUnaryCall<_memoflow_v1_GetApprovalRequest__Output, _memoflow_v1_GetApprovalResponse>; GetNamespaceConfig: grpc.handleUnaryCall<_memoflow_v1_GetNamespaceConfigRequest__Output, _memoflow_v1_GetNamespaceConfigResponse>; /** * Namespace-scoped administrative reads. Scoped keys may read only their * namespace; global administrators may select any namespace. */ GetNamespaceStatusCounts: grpc.handleUnaryCall<_memoflow_v1_GetNamespaceStatusCountsRequest__Output, _memoflow_v1_GetNamespaceStatusCountsResponse>; /** * Process and durable outbox health counters. Requires an admin (`*`) API key. */ GetSystemMetrics: grpc.handleUnaryCall<_memoflow_v1_GetSystemMetricsRequest__Output, _memoflow_v1_GetSystemMetricsResponse>; /** * Read the authoritative append-only event history for one workflow run. */ GetWorkflowHistory: grpc.handleUnaryCall<_memoflow_v1_GetWorkflowHistoryRequest__Output, _memoflow_v1_GetWorkflowHistoryResponse>; /** * Get the result of a workflow (blocks until complete or timeout). */ GetWorkflowResult: grpc.handleUnaryCall<_memoflow_v1_GetWorkflowResultRequest__Output, _memoflow_v1_GetWorkflowResultResponse>; ListApprovals: grpc.handleUnaryCall<_memoflow_v1_ListApprovalsRequest__Output, _memoflow_v1_ListApprovalsResponse>; /** * Namespace-scoped operator inventory. Input payloads are structurally * absent so a read cannot disclose last-write-wins workflow input. */ ListDebounces: grpc.handleUnaryCall<_memoflow_v1_ListDebouncesRequest__Output, _memoflow_v1_ListDebouncesResponse>; /** * Global namespace catalog. Requires an admin (`*`) API key. */ ListNamespaces: grpc.handleUnaryCall<_memoflow_v1_ListNamespacesRequest__Output, _memoflow_v1_ListNamespacesResponse>; /** * Global operator APIs. These require an admin (`*`) API key. */ ListOutboxEffects: grpc.handleUnaryCall<_memoflow_v1_ListOutboxEffectsRequest__Output, _memoflow_v1_ListOutboxEffectsResponse>; ListQueues: grpc.handleUnaryCall<_memoflow_v1_ListQueuesRequest__Output, _memoflow_v1_ListQueuesResponse>; /** * List schedules registered in a namespace. */ ListSchedules: grpc.handleUnaryCall<_memoflow_v1_ListSchedulesRequest__Output, _memoflow_v1_ListSchedulesResponse>; /** * Connected workers plus RUNNING workflow queues with no compatible * workflow worker. Requires an admin (`*`) API key. */ ListWorkers: grpc.handleUnaryCall<_memoflow_v1_ListWorkersRequest__Output, _memoflow_v1_ListWorkersResponse>; ListWorkflowEvaluations: grpc.handleUnaryCall<_memoflow_v1_ListWorkflowEvaluationsRequest__Output, _memoflow_v1_ListWorkflowEvaluationsResponse>; /** * List workflows with optional filters. */ ListWorkflows: grpc.handleUnaryCall<_memoflow_v1_ListWorkflowsRequest__Output, _memoflow_v1_ListWorkflowsResponse>; /** * Global-admin escape hatch for a BLOCKED_NONDETERMINISTIC run. Atomically * repins the run and appends an operator audit event before redispatch. */ OverrideWorkflowBuild: grpc.handleUnaryCall<_memoflow_v1_OverrideWorkflowBuildRequest__Output, _memoflow_v1_OverrideWorkflowBuildResponse>; /** * Query a running workflow (read-only, does not mutate state). */ QueryWorkflow: grpc.handleUnaryCall<_memoflow_v1_QueryWorkflowRequest__Output, _memoflow_v1_QueryWorkflowResponse>; /** * DATA-006 durable run output. Offset-addressed and store-backed; callers * may reconnect through another server with the returned resume token. */ ReadWorkflowOutput: grpc.handleServerStreamingCall<_memoflow_v1_ReadWorkflowOutputRequest__Output, _memoflow_v1_DurableOutputChunk>; /** * Maintenance-only operator mutation. Rebuilds projections only when the * authoritative history still has the exact sequence and digest supplied * by a preceding VerifyWorkflowProjection call. */ RepairWorkflowProjection: grpc.handleUnaryCall<_memoflow_v1_RepairWorkflowProjectionRequest__Output, _memoflow_v1_RepairWorkflowProjectionResponse>; ReplayOutboxEffect: grpc.handleUnaryCall<_memoflow_v1_ReplayOutboxEffectRequest__Output, _memoflow_v1_ReplayOutboxEffectResponse>; /** * Reveal one immutable event payload. This is a privileged break-glass read: * a justification is mandatory and plaintext is returned only after its * immutable audit record commits. */ RevealWorkflowHistoryEventPayload: grpc.handleUnaryCall<_memoflow_v1_RevealWorkflowHistoryEventPayloadRequest__Output, _memoflow_v1_RevealWorkflowHistoryEventPayloadResponse>; /** * Send a signal to a running workflow. */ SignalWorkflow: grpc.handleUnaryCall<_memoflow_v1_SignalWorkflowRequest__Output, _memoflow_v1_SignalWorkflowResponse>; /** * ── Start debouncing (P6.4) ──────────────────────────────────────────── * * Collapse rapid repeated calls sharing `key` into ONE workflow start, * using the LAST-supplied input (last-write-wins), fired once `window` * elapses since the most recent call. Returns immediately — the actual * StartWorkflow happens later, asynchronously, when the debounce poller * observes the window has closed. */ StartDebounced: grpc.handleUnaryCall<_memoflow_v1_StartDebouncedRequest__Output, _memoflow_v1_StartDebouncedResponse>; /** * Start a new workflow execution. */ StartWorkflow: grpc.handleUnaryCall<_memoflow_v1_StartWorkflowRequest__Output, _memoflow_v1_StartWorkflowResponse>; /** * P3.5 — subscribe to best-effort streaming step output (ctx.stream()) for * a workflow run. Server-streaming, in-process relay only (single server, * no persistence, no cross-server fanout — see StreamChunk in * worker_service.proto for the full semantics). The stream never * terminates on its own; callers cancel when done (the dashboard's SSE * handler cancels on client disconnect). A subscriber that connects after * a chunk was emitted has already missed it — this is observability, not * a durable log. * The chunk type is the shared wire event, not an RPC-specific wrapper. */ StreamWorkflowOutput: grpc.handleServerStreamingCall<_memoflow_v1_StreamWorkflowOutputRequest__Output, _memoflow_v1_WorkflowOutputChunk>; /** * ── Cron schedules (P6.4) ────────────────────────────────────────────── * * Create or replace a durable cron schedule. Idempotent: calling again * with the same (namespace, schedule_id) replaces the cron expression, * input, task queue, and missed-fire policy, and only resets next_fire_at * if the cron expression changed (a no-op re-registration on every worker * restart — the common case — must not perturb an already-scheduled fire). */ UpsertSchedule: grpc.handleUnaryCall<_memoflow_v1_UpsertScheduleRequest__Output, _memoflow_v1_UpsertScheduleResponse>; /** * Operator read: strictly reduce authoritative execution events and compare * them with the current run/checkpoint/pending-signal projections. */ VerifyWorkflowProjection: grpc.handleUnaryCall<_memoflow_v1_VerifyWorkflowProjectionRequest__Output, _memoflow_v1_VerifyWorkflowProjectionResponse>; } export interface WorkflowServiceDefinition extends grpc.ServiceDefinition { AwaitWorkflowCompletion: MethodDefinition<_memoflow_v1_AwaitWorkflowCompletionRequest, _memoflow_v1_WorkflowCompletion, _memoflow_v1_AwaitWorkflowCompletionRequest__Output, _memoflow_v1_WorkflowCompletion__Output>; CancelWorkflow: MethodDefinition<_memoflow_v1_CancelWorkflowRequest, _memoflow_v1_CancelWorkflowResponse, _memoflow_v1_CancelWorkflowRequest__Output, _memoflow_v1_CancelWorkflowResponse__Output>; ClaimApproval: MethodDefinition<_memoflow_v1_ClaimApprovalRequest, _memoflow_v1_ClaimApprovalResponse, _memoflow_v1_ClaimApprovalRequest__Output, _memoflow_v1_ClaimApprovalResponse__Output>; CreateWorkflowEvaluation: MethodDefinition<_memoflow_v1_CreateWorkflowEvaluationRequest, _memoflow_v1_CreateWorkflowEvaluationResponse, _memoflow_v1_CreateWorkflowEvaluationRequest__Output, _memoflow_v1_CreateWorkflowEvaluationResponse__Output>; DecideApproval: MethodDefinition<_memoflow_v1_DecideApprovalRequest, _memoflow_v1_DecideApprovalResponse, _memoflow_v1_DecideApprovalRequest__Output, _memoflow_v1_DecideApprovalResponse__Output>; DeleteSchedule: MethodDefinition<_memoflow_v1_DeleteScheduleRequest, _memoflow_v1_DeleteScheduleResponse, _memoflow_v1_DeleteScheduleRequest__Output, _memoflow_v1_DeleteScheduleResponse__Output>; DescribeWorkflow: MethodDefinition<_memoflow_v1_DescribeWorkflowRequest, _memoflow_v1_DescribeWorkflowResponse, _memoflow_v1_DescribeWorkflowRequest__Output, _memoflow_v1_DescribeWorkflowResponse__Output>; ForkWorkflow: MethodDefinition<_memoflow_v1_ForkWorkflowRequest, _memoflow_v1_ForkWorkflowResponse, _memoflow_v1_ForkWorkflowRequest__Output, _memoflow_v1_ForkWorkflowResponse__Output>; GetApproval: MethodDefinition<_memoflow_v1_GetApprovalRequest, _memoflow_v1_GetApprovalResponse, _memoflow_v1_GetApprovalRequest__Output, _memoflow_v1_GetApprovalResponse__Output>; GetNamespaceConfig: MethodDefinition<_memoflow_v1_GetNamespaceConfigRequest, _memoflow_v1_GetNamespaceConfigResponse, _memoflow_v1_GetNamespaceConfigRequest__Output, _memoflow_v1_GetNamespaceConfigResponse__Output>; GetNamespaceStatusCounts: MethodDefinition<_memoflow_v1_GetNamespaceStatusCountsRequest, _memoflow_v1_GetNamespaceStatusCountsResponse, _memoflow_v1_GetNamespaceStatusCountsRequest__Output, _memoflow_v1_GetNamespaceStatusCountsResponse__Output>; GetSystemMetrics: MethodDefinition<_memoflow_v1_GetSystemMetricsRequest, _memoflow_v1_GetSystemMetricsResponse, _memoflow_v1_GetSystemMetricsRequest__Output, _memoflow_v1_GetSystemMetricsResponse__Output>; GetWorkflowHistory: MethodDefinition<_memoflow_v1_GetWorkflowHistoryRequest, _memoflow_v1_GetWorkflowHistoryResponse, _memoflow_v1_GetWorkflowHistoryRequest__Output, _memoflow_v1_GetWorkflowHistoryResponse__Output>; GetWorkflowResult: MethodDefinition<_memoflow_v1_GetWorkflowResultRequest, _memoflow_v1_GetWorkflowResultResponse, _memoflow_v1_GetWorkflowResultRequest__Output, _memoflow_v1_GetWorkflowResultResponse__Output>; ListApprovals: MethodDefinition<_memoflow_v1_ListApprovalsRequest, _memoflow_v1_ListApprovalsResponse, _memoflow_v1_ListApprovalsRequest__Output, _memoflow_v1_ListApprovalsResponse__Output>; ListDebounces: MethodDefinition<_memoflow_v1_ListDebouncesRequest, _memoflow_v1_ListDebouncesResponse, _memoflow_v1_ListDebouncesRequest__Output, _memoflow_v1_ListDebouncesResponse__Output>; ListNamespaces: MethodDefinition<_memoflow_v1_ListNamespacesRequest, _memoflow_v1_ListNamespacesResponse, _memoflow_v1_ListNamespacesRequest__Output, _memoflow_v1_ListNamespacesResponse__Output>; ListOutboxEffects: MethodDefinition<_memoflow_v1_ListOutboxEffectsRequest, _memoflow_v1_ListOutboxEffectsResponse, _memoflow_v1_ListOutboxEffectsRequest__Output, _memoflow_v1_ListOutboxEffectsResponse__Output>; ListQueues: MethodDefinition<_memoflow_v1_ListQueuesRequest, _memoflow_v1_ListQueuesResponse, _memoflow_v1_ListQueuesRequest__Output, _memoflow_v1_ListQueuesResponse__Output>; ListSchedules: MethodDefinition<_memoflow_v1_ListSchedulesRequest, _memoflow_v1_ListSchedulesResponse, _memoflow_v1_ListSchedulesRequest__Output, _memoflow_v1_ListSchedulesResponse__Output>; ListWorkers: MethodDefinition<_memoflow_v1_ListWorkersRequest, _memoflow_v1_ListWorkersResponse, _memoflow_v1_ListWorkersRequest__Output, _memoflow_v1_ListWorkersResponse__Output>; ListWorkflowEvaluations: MethodDefinition<_memoflow_v1_ListWorkflowEvaluationsRequest, _memoflow_v1_ListWorkflowEvaluationsResponse, _memoflow_v1_ListWorkflowEvaluationsRequest__Output, _memoflow_v1_ListWorkflowEvaluationsResponse__Output>; ListWorkflows: MethodDefinition<_memoflow_v1_ListWorkflowsRequest, _memoflow_v1_ListWorkflowsResponse, _memoflow_v1_ListWorkflowsRequest__Output, _memoflow_v1_ListWorkflowsResponse__Output>; OverrideWorkflowBuild: MethodDefinition<_memoflow_v1_OverrideWorkflowBuildRequest, _memoflow_v1_OverrideWorkflowBuildResponse, _memoflow_v1_OverrideWorkflowBuildRequest__Output, _memoflow_v1_OverrideWorkflowBuildResponse__Output>; QueryWorkflow: MethodDefinition<_memoflow_v1_QueryWorkflowRequest, _memoflow_v1_QueryWorkflowResponse, _memoflow_v1_QueryWorkflowRequest__Output, _memoflow_v1_QueryWorkflowResponse__Output>; ReadWorkflowOutput: MethodDefinition<_memoflow_v1_ReadWorkflowOutputRequest, _memoflow_v1_DurableOutputChunk, _memoflow_v1_ReadWorkflowOutputRequest__Output, _memoflow_v1_DurableOutputChunk__Output>; RepairWorkflowProjection: MethodDefinition<_memoflow_v1_RepairWorkflowProjectionRequest, _memoflow_v1_RepairWorkflowProjectionResponse, _memoflow_v1_RepairWorkflowProjectionRequest__Output, _memoflow_v1_RepairWorkflowProjectionResponse__Output>; ReplayOutboxEffect: MethodDefinition<_memoflow_v1_ReplayOutboxEffectRequest, _memoflow_v1_ReplayOutboxEffectResponse, _memoflow_v1_ReplayOutboxEffectRequest__Output, _memoflow_v1_ReplayOutboxEffectResponse__Output>; RevealWorkflowHistoryEventPayload: MethodDefinition<_memoflow_v1_RevealWorkflowHistoryEventPayloadRequest, _memoflow_v1_RevealWorkflowHistoryEventPayloadResponse, _memoflow_v1_RevealWorkflowHistoryEventPayloadRequest__Output, _memoflow_v1_RevealWorkflowHistoryEventPayloadResponse__Output>; SignalWorkflow: MethodDefinition<_memoflow_v1_SignalWorkflowRequest, _memoflow_v1_SignalWorkflowResponse, _memoflow_v1_SignalWorkflowRequest__Output, _memoflow_v1_SignalWorkflowResponse__Output>; StartDebounced: MethodDefinition<_memoflow_v1_StartDebouncedRequest, _memoflow_v1_StartDebouncedResponse, _memoflow_v1_StartDebouncedRequest__Output, _memoflow_v1_StartDebouncedResponse__Output>; StartWorkflow: MethodDefinition<_memoflow_v1_StartWorkflowRequest, _memoflow_v1_StartWorkflowResponse, _memoflow_v1_StartWorkflowRequest__Output, _memoflow_v1_StartWorkflowResponse__Output>; StreamWorkflowOutput: MethodDefinition<_memoflow_v1_StreamWorkflowOutputRequest, _memoflow_v1_WorkflowOutputChunk, _memoflow_v1_StreamWorkflowOutputRequest__Output, _memoflow_v1_WorkflowOutputChunk__Output>; UpsertSchedule: MethodDefinition<_memoflow_v1_UpsertScheduleRequest, _memoflow_v1_UpsertScheduleResponse, _memoflow_v1_UpsertScheduleRequest__Output, _memoflow_v1_UpsertScheduleResponse__Output>; VerifyWorkflowProjection: MethodDefinition<_memoflow_v1_VerifyWorkflowProjectionRequest, _memoflow_v1_VerifyWorkflowProjectionResponse, _memoflow_v1_VerifyWorkflowProjectionRequest__Output, _memoflow_v1_VerifyWorkflowProjectionResponse__Output>; }