ParseJSONL parses a JSONL file. We separate this out from [ParseDLQMessages] so that we can reuse it for other JSONL files that don't contain [tdbg.DL

PauseActivity pauses the execution of an activity specified by its ID. Returns a `NotFound` error if there is no pending activity with the provided ID

PauseWorkflowExecution pauses the workflow execution specified in the request.

PeerCert extracts an x509 certificate from given tlsInfo.

PendingOperationState maps a nexus operation status to the corresponding pending API state. Returns PENDING_NEXUS_OPERATION_STATE_UNSPECIFIED for non-

PickRolloutSplit returns two distinct business IDs in the given namespace such that the first is accepted by RolloutAccepts at percent and the second

PinnedBuildIdSearchAttribute creates the pinned search attribute for the BuildIds list, used as a visibility optimization. For pinned workflows using

PollActivityTaskQueue is called by frontend to process ActivityTask from a specific task queue. ActivityTask is dispatched to callers whenever a Sche

PollAndProcessActivityTaskWithID is similar to PollAndProcessActivityTask but using RespondActivityTask...ByID

Returns the information from mutable state of workflow execution. It fails with 'EntityNotExistError' if specified workflow execution in unknown to th

Request from worker (via frontend) to long poll on nexus tasks.

(-- api-linter: core::0134=disabled aip.dev/not-precedent: This service does not follow the update method API --)

PollWorkflowTaskQueue is called by frontend to process WorkflowTask from a specific task queue. A WorkflowTask is dispatched to callers for active wo

PreviousShardRangeID returns tag for PreviousShardRangeID

ProcessAllUpdateCloseCallbacks triggers callbacks for all updates without touching workflow-level callbacks. This is used when the workflow is continu

ProcessInternalRawHistory processes history in the field response.History. History service can send history events in response.History.Events. In that

(-- api-linter: core::0165::response-message-name=disabled aip.dev/not-precedent: --) PurgeDLQMessages purges messages from DLQ.

(-- api-linter: core::0165::response-message-name=disabled aip.dev/not-precedent: --) PurgeDLQMessages purges messages from DLQ.

PutOrDo put the key value in the map, if key does not exists, otherwise, call fn with existing key and value return (value, fn evaluated or not, error

QueryWorkflow is called by frontend to query a workflow.

QueryWorkflow returns query result for a specified workflow execution.

ReadContext returns a new read-only CHASM context.

ReadLevel returns tag for ReadLevel

ReapplyEvents applies stale events to the current workflow and current run.

ReapplyEvents applies stale events to the current workflow and current run.

RebuildMutableState attempts to rebuild mutable state according to persisted history events. NOTE: this is experimental API

RebuildMutableState attempts to rebuild mutable state according to persisted history events. NOTE: this is experimental API

RecordActivityTaskHeartbeat is called by application worker while it is processing an ActivityTask. If worker fails to heartbeat within 'heartbeatTim

RecordActivityTaskStarted is called by the Matchingservice before it hands a workflow task to the application worker in response to a PollActivityTask

RecordChildExecutionCompleted is used for reporting the completion of child workflow execution to parent. This is mainly called by transfer queue proc

RecordWorkflowTaskStarted is called by the Matchingservice before it hands a workflow task to the application worker in response to a PollWorkflowTask

RecvMsg mocks base method.

RecvMsg mocks base method.

RecycleToken should be called when the action being rate limited was not completed for some reason (i.e. a task is not dispatched because it was inval

RefreshWorkflowTasks refreshes all tasks of a workflow.

RefreshWorkflowTasks refreshes all tasks of a workflow.

RegisterTest records t as currently using this cluster. At t's Cleanup it fails t if the cluster was poisoned during t's window. This fails all active

RemoveBuildIds removes given buildIds from versioning data. Assumes that build ids are safe to remove, ex: a set default is never removed unless it is

RemoveIf deletes the given key from the map if fn return true

RemoveSignalMutableState is used to remove a signal request Id that was previously recorded. This is currently used to clean execution info when sign

RemoveTask remove task based on type, taskid, shardid.

ReplicateEventsV2 replicates workflow history events

Replicate task queue user data across clusters, must be done via the owning node for updates in namespace.

ReplicateWorkflowState replicates workflow state

ReprocessRedirectedTasksAfterStop sends tasks in the matcher that came from other physical queues back to be reprocessed. Note this is called after St

RequestCancel requests cancellation of the operation. It creates a Cancellation child component and, if the operation has already started, schedules t

RequestCancelWorkflowExecution is called by application worker when it wants to request cancellation of a workflow instance. It will result in a new '

RequestHeader returns the first value of the named gRPC metadata header from the inbound request context, or "" if absent. Only available when this C

RequestRefresh requests that the membership information be refreshed.

Requiref is like [Require] but adds a formatted message to the timeout failure.

ReserveN calls ReserveN on its list of rate limiters and returns a MultiReservation that is a list of the individual reservation objects indicating ho

ResetActivity resets the execution of an activity specified by its ID. Resetting an activity means: - number of attempts will be reset to 0. - activi

Reset the sticky task queue related information in mutable state of a given workflow. Things cleared are: 1. StickyTaskQueue 2. StickyScheduleToStartT

ResetWorkflowExecution reset an existing workflow execution by a firstEventId of a existing event batch in the history and immediately terminating the

ResolveDuplicateWorkflowID determines how to resolve a workflow ID duplication upon workflow start according to the WorkflowIdReusePolicy (for *comple