ResolvedMetricTagConfig returns the configured metric tag config, defaulting to an empty config when the receiver or the setting is nil (e.g. in tests

RespondActivityTaskCanceled is called by application worker when it is successfully canceled an ActivityTask. It will result in a new 'ActivityTaskCa

RespondActivityTaskCompleted is called by application worker when it is done processing an ActivityTask. It will result in a new 'ActivityTaskComplet

RespondActivityTaskFailed is called by application worker when it is done processing an ActivityTask. It will result in a new 'ActivityTaskFailed' ev

Response from a worker (via frontend) to a Nexus task, unblocks the corresponding DispatchNexusTask request.

Response from a worker (via frontend) to a Nexus task, unblocks the corresponding DispatchNexusTask request.

RespondQueryTaskCompleted is called by frontend to respond query completed.

RespondWorkflowTaskCompleted is called by application worker to complete a WorkflowTask handed as a result of 'PollWorkflowTaskQueue' API call. Compl

RespondWorkflowTaskFailed is called by application worker to indicate failure. This results in WorkflowTaskFailedEvent written to the history and a n

RewriteScheduleIDQuery rewrites ScheduleId comparisons in the query string to WorkflowId comparisons before the query reaches the visibility store con

RunCreateTest tests schema version table creation

RunDropTest tests the drop methods in DB implementation

RunInitiatorTag creates a tag indicating how a workflow run was initiated. It handles both new workflow runs and continuations from previous runs. Whe

RunParseFileTest runs a test against the ParseFile method

RunQueueV2TestSuite executes interface-level tests for a queue persistence-layer implementation. There should be more implementation-specific tests th

RunSetupTest exercises the SetupSchema task

RunUpdateSchemaTest tests schema update

RunUpdateTest tests update of schema and schema version tables

ScheduleClient mocks base method.

ScheduleWorkflowTask is used for creating a workflow task for already started workflow execution. This is mainly used by transfer queue processor dur

SecondaryVisibilityConfigExist returns whether user specified secondaryVisibilityStore in config

SelectAllFromChasmNodeMaps returns all rows related to a particular workflow from the chasm_node_maps table.

SendMsg mocks base method.

SendMsg mocks base method.

SendSlackMessage sends the message to Slack webhook

NOTE: DO NOT MODIFY UNLESS ALSO APPLIED TO ./service/frontend/token_deprecated.go

SetDraining sets the draining state (synchronized through ringpop)

Equals compares two vertex func (he *HistoryEventVertex) Equals( v Vertex, ) bool { return strings.EqualFold(he.name, v.GetName()) && he.data == v.

SetOutputFile sets the file path for writing captured messages on-demand

This is for breaking fx cycle dependency. ChasmEngine -> ShardController -> ShardContextFactory -> HistoryEngineFactory -> QueueFactory -> ChasmEngine

SetVersions sets headers for internal communications.

Setup sets up schema tables

ShardQueueAcks returns tag for shard queue ack levels

(-- api-linter: core::0136::prepositions=disabled aip.dev/not-precedent: "With" is needed here. --) SignalWithStartWorkflowExecution is used to ens

SignalWorkflowExecution is used to send a signal event to running workflow execution. This results in WorkflowExecutionSignaled event recorded in the

Size returns the size of the object, in bytes, once serialized

Size returns the size of the object, in bytes, once serialized

Start starts the scavenger

StartNamespaceMetricCaptureFor starts a metrics capture scoped to the provided namespace.

StartNexusOperation starts a Nexus operation on the __temporal_system endpoint.

StartOperation implements the nexus.Handler interface.

StartOperation calls the configured Nexus endpoint to start an operation. This method has the following possible outcomes: 1. The operation complete

StartOperationResponseToError converts a StartOperationResponse proto into a Go error. Returns nil for success variants (SyncSuccess, AsyncSuccess).

StartWorkflowExecution starts a new long running workflow instance. It will create the instance with 'WorkflowExecutionStarted' event in history and

TODO(bergundy): This Environment should be host level once shard level workflow cache is deprecated.

StreamServerInterceptor returns a gRPC stream server interceptor that captures stream messages

StripPrincipal removes principal headers from incoming metadata to prevent external callers from spoofing principal identity.

SupportsPartitions returns true for partition types that can be split into multiple partitions for load distribution. When false, partition count must