ValidateNotTransitioned returns a [consts.ErrStaleReference] if the machine has transitioned since the task was generated.

ValidateQueryRequest validates the query visibility request

ValidateState validates: 1. Namespace is specified in task token if there is a `task_token` field. 2. Namespace is specified in request if there is a

ValidateVisibilityArchivalRequest validates the archive visibility request

VerifyCompatibleVersion ensures that the installed version is greater than or equal to the expected version.

VersionSetQueueKey returns a PhysicalTaskQueueKey of a task queue partition with the given version set id.

VersionWorkflow is implemented in a way where it always CaNs after some history events are added to it and it has no pending work to do. This is to ke

VisibilityConfigExist returns whether user specified visibilityStore in config

WithAuthorizer sets a low level authorizer to allow/deny all API calls

WithClaimMapper configures a role mapper for authorization

WithConfig sets a custom configuration

WithDetached marks the registrable component as detached. Detached components ignore parent lifecycle validation, allowing them to continue operating

WithInFlightLimit provides an optional limit to the number of incomplete Updates that a Registry instance will allow.

WithLogger sets a custom logger

WithPersistenceFaultInjection requests a dedicated cluster with the given persistence fault injection config.

WithPruneType prevents Track from descending into values whose reflected type matches pattern. Named types match their package-qualified name. A trail

WithTimeout sets a custom timeout for the test-scoped context.

WorkerVersion returns tag for worker build ID

WorkflowHandlerName returns tag for WorkflowHandlerName

WorkflowSize returns tag for WorkflowSize

WorkflowTimerID returns tag for WorkflowTimerID

activityPendingRetry returns true if an activity has failed and retry has scheduled but not yet started

call with_out_ lock held

persistence helper

attemptScheduleTimeForRetry computes the time a retried attempt is scheduled to start, as complete_time + retry_interval. Returns nil if either field

bestEffortHandlerErrorFromResponse attempts to read a handler error from the response, but falls back to an unexpected response error.

buildBroadcastHostPort return the listener hostport from an existing tchannel and overrides the address with broadcastAddress if specified

buildCatalog builds a catalog from the list of pending metric definitions. It is safe to call this method multiple times. This method is thread-safe.

buildGitHubURL constructs GitHub Actions URL from run/job IDs If jobID == "unknown": https://github.com/{repo}/actions/runs/{runID} Otherwise: https:/

buildReports builds TestReport slice from grouped failures, sorts by FailureCount/TotalRuns descending. numerator and denominator return the rate comp

bypassRateLimit bypasses the rate limit and calls the function directly. It exists to maintain the same number of stack trace frames as when rateLimit

--- latencyStats ---

calculatePercentUnder calculates the percentage of durations under a threshold

Calls delete dlq job and verify the output

cancelOutstandingPoll cancel outstanding poll if context was canceled and returns true. Otherwise returns false.

captureCurrentBranchToken extracts the current branch token from a workflow's mutable state.

captureNPollDeadlines injects a mock partition manager, runs n sequential polls, and returns the context deadline observed inside each pm.PollTask cal

chasmCallbacksEnabled returns true if CHASM callbacks are enabled for this workflow.

checkForNamespaceCaptureMisuse panics when all queried metrics that produced recordings were namespace-scoped. Metrics with no recordings are treated

classifyFailure returns "timeout", "crash", or "flaky" based on the test name. Uses Contains (not HasSuffix) so it works on both raw and normalized na

This mutates memo

This mutates searchAttributes