resolveDeferredPointers resolves all deferred pointers in the tree. Returns error if any deferred pointer cannot be resolved, as deferred pointers can

resolveDuplicateWorkflowID determines how to resolve a duplicate workflow ID. Returns non-nil response if an action was required and completed success

resolveSystemAlias resolves a system search attribute alias to its field name. It handles the `Temporal` prefix variations (e.g., "ScheduleId" and "Te

respondToRetriedRequest provides a response in case a start request is retried. NOTE: Workflow is marked as "started" even though the client re-issue

rewriteComparison rewrites a single ComparisonExpr if its LHS is the synthetic ScheduleId SA.

rewriteExpr recursively walks expr and rewrites ScheduleId comparison nodes in-place. Returns true if any rewriting occurred.

rewriteIsExpr rewrites a ScheduleId IS [NOT] NULL expression to use WorkflowId. No prefix rewriting is needed for IS NULL / IS NOT NULL.

run does a single run over all executions and validates them

run does a single run over all executorTask queues

run the test case by simulating a bunch of blocked pollers, sending a final request, and verifying that it is either rate limited or not.

runAttempt runs condition in a goroutine so that an accidental call to the real test's FailNow (runtime.Goexit) terminates only this goroutine. Termi

runBisectAnalysis is the top-level bisect orchestrator called from the generate command. It runs bisect for the top-N flakiest tests and returns their

runOmes runs Omes throughput stress scenario. Retries if Omes fails due to search attribute not being ready yet. Deducts elapsed time from duration on

runOneShotPoller spawns a goroutine to call tqMgr.PollTask on the provided tqMgr. The second return value is a channel of either error or *internalTas

runSweeper periodically removes idle queue entries from the map.

nolint:revive,deep-exit

runWatchLoop starts a goroutine that establishes and maintains a namespace watch. Returns the goroutine handle and a boolean indicating whether the wa

runWorker is the goroutine that processes tasks for a single execution queue. It pops tasks from the slice under the lock and executes them without th

sanitizeActualHistoryEventsForContains clears EventID and Version fields from actual history events if they are not set in the FIRST expected history

sanitizeXML removes characters that are invalid in XML 1.0. Go's xml.Encoder escapes <, >, & etc., but control characters other than \t, \n, \r are no

Note: If the encoding for one of these strings fails, none of them would get saved. But we really don't expect any of the strings to be unencodable, s

saveStartedResult transitions the operation to started in response to an async (pending) start response so it can later complete via callback.

Returns "a - b" per-key, removing zeros.

scheduleTask schedules a BackfillerTask at the given time.

Overwrite the 'client-name' and 'client-version' headers on gRPC requests sent using the Go SDK so they clearly indicate that the request is coming fr

nolint:staticcheck // SA1019 TaskPoller replacement needs to be done holistically.

nolint:staticcheck // SA1019 TaskPoller replacement needs to be done holistically.