OperationResult returns tag for OperationResult

paginateWorkers applies cursor-based pagination to a list of workers. Workers are sorted by WorkerInstanceKey for deterministic ordering. Returns the

parseArtifactName extracts run_id, job_id, and matrix_name from artifact name. Functional tests: junit-xml--{run_id}--{job_id}--{run_attempt}--{matrix

parseFlags creates a FlagSet, calls setup to register flags, and parses args. Returns remaining (non-flag) arguments.

pickClientForRead mutates the given proto. Callers should copy the proto before if necessary.

pollActivityTaskQueueResponse returns the poll response for an activity task that is already marked as started. This method should only be called when

pollWorkflowTaskQueueResponse returns the poll response for a workflow task that is already marked as started. This method should only be called when

popTask returns the task with minimum (pri, pass, index) from a random partition.

processUpdateCloseCallbacks triggers only update-level callbacks, leaving workflow-level callbacks untouched. This is used when the workflow is contin

Returns the next matching time (without jitter), or the zero value if no time matches.

readDLQTasks from the transfer task DLQ for this cluster and return them.

recordNexusTaskRequest emits the nexus_task_requests metric with namespace, operation, client_name, and is_internal tags.

replaceRedirectRule replaces a new versioning redirect rule to the task queue user data. It checks the response and returns the conflict token.

reschedulePendingWorkflowTask reschedules the pending WFT if it is not started yet. The currently scheduled WFT will be rejected when attempting to st

if this is a transient WFT (attempt > 1), we make sure to keep the following from the previous attempt: - BuildId of the previous attempt to be able t

revertOnError undoes every applied increment if *err is non-nil. Intended to be deferred against a function's named return error.

runBisectForTest runs the full bisect pipeline for a single test name. commitMetas is a pre-populated, read-only cache of commit metadata (SHA → Commi

runForeverWithInterval runs scanFn immediately, then again on every tick of scanInterval, until the activity context is canceled or scanFn returns an

runScan ties the per-scanner pieces together: list namespaces, fan out a single visibility query per namespace, and emit per-namespace metrics. Cluste

runScanActivity executes the long-running scan activity. The activity is expected to run 'infinitely', timing out on server restart and being retried

runningWorkflowExecutions returns the list of workflow executions that have been started but not yet completed.