metricTagConfig returns the configured metric tag config (nil-safe).

newCQLClient returns a new instance of CQLClient

newDetachedContext creates a detached context with the same deadline and values from the given context. Detached context won't be affected if the cont

Create a new rate limit manager for the task queue partition.

newTestEnv creates a TestEnv with the dynamic config this suite needs. Additional per-test options may be passed in opts.

newTestSpecProcessor creates a real SpecProcessor for tests that need actual scheduling logic.

newUpdateChildWorkflow returns a child workflow function that registers an "update" handler and waits for a "stop" signal. If blockOnSignal is true, t

normalizeTagsForCaching applies excludeTags substitution to produce canonical tag values for cache key computation. Returns the original slice unchang

rateLocked returns the rate of increments in a given interval, plus whether the full interval has elapsed.

recordExpectationMatches increments the match counter of every expectation registered at the given level whose matcher matches this log call. It is pu

recordTasks appends tasks to the flattened list by category, wrapping each with metadata

routeSystemCallbackRequest routes a system callback request to the appropriate frontend client based on the callback token's namespace and active clus

We steal some upper bits of the "row type" field to hold a subqueue index. Subqueue 0 must be the same as rowTypeTask (before subqueues were introduce

selectTopFlakyTests selects the top-N flakiest tests that meet minimum signal thresholds. allRuns is the full set of test runs. Returns normalized tes

nolint:staticcheck // SA1019

startTimerCmd returns a StartTimer command with the given duration and timer ID.

startWorkflowWithRetry starts a scanner workflow, retrying until it succeeds or the scanner shuts down. workflowType may be either a registered type-n

Sync version summary with the WorkerDeployment workflow.

nolint:revive

AddEdge adds an edge to the model

AddModel adds a history event model

AddReqTokenC returns a channel that can be used to wait for a token that's necessary before making a ForwardTask or ForwardQueryTask API call. After t

AddWorkflowExecutionUpdateCompletedEvent writes an Update completed event. The data may not be durable when this function returns.

The below are history V2 APIs V2 regards history events growing as a tree, decoupled from workflow concepts AppendHistoryNodes add a node to history n

AppendHistoryNodes add(or override) a node to a history branch

ArchivalURI returns tag for Archival URI

BuildIdIfUsingVersioning returns the given WorkerVersionStamp if it is using versioning, otherwise returns nil.

ChasmEnabled returns true if the mutable state has a real chasm tree. The chasmTree is initialized with a noopChasmTree which is then overwritten with