nolint:revive // cyclomatic complexity

PollReqTokenC returns a channel that can be used to wait for a token that's necessary before making a ForwardPoll API call. After the API call is invo

(-- api-linter: core::0165::response-message-name=disabled aip.dev/not-precedent: --)

ReadSchemaVersion returns the current schema version for the keyspace

RecordHeartbeat records a heartbeat for the activity.

Representation is the string representation of the component for usage in a path definition, e.g. "v1" for a constant slug or "{namespace}" for a vari

RequireTruef is like [RequireTrue] but accepts a format string that is included in the failure message when the condition is not satisfied before the

ResolveSearchAttributeAlias resolves the search attribute alias for the given name. The process is: 1. If the name has the "Temporal", skip mapping to

RoutingKey returns the key and index within the key that should be used to find the owner of a task queue partition.

SelectAllFromActivityInfoMaps returns all rows from activity_info_maps table

SelectAllFromChildExecutionInfoMaps returns all rows into child_execution_info_maps table

SelectAllFromRequestCancelInfoMaps returns all rows from request_cancel_info_maps table

SelectAllFromSignalInfoMaps returns one or more rows from signal_info_maps table

SelectAllFromSignalsRequestedSets returns all rows from signals_requested_sets table

SelectAllFromTimerInfoMaps returns all rows from timer_info_maps table

ServiceErrorType returns tag for ServiceErrorType

Set sets a test hook to a value with the given scope and returns a cleanup function to unset it.

Signal wakes one goroutine waiting on this condition variable, if there is any.

StartGlobalMetricCapture starts a cluster-global metrics capture for this test and automatically stops it during cleanup. Metric capture is cluster-gl

Sync cancels/starts goroutines as necessary so that the running set matches the set of keys in target. To start a new goroutine, it does "go f(ctx, ke

Unmarshal an object of type BuildId from the protobuf v3 wire format

Unmarshal an object of type StateMachineMap from the protobuf v3 wire format

Unmarshal an object of type SyncStateFailure from the protobuf v3 wire format

UnsafeTaskQueueTag returns a new task queue tag. WARNING: Do not use this function directly in production code as it may create high number of unique

UnversionedBuildIdSearchAttribute returns the search attribute value for an unversioned build ID

UseSuiteScopedCluster makes NewEnv use one cluster for all tests under `t`. The cluster is created on first use and torn down when `t` completes. Dep

When returns the time when the value for key will switch from old to new. It may be the zero time for a static GradualChange.

ackMessage returns the inclusive low watermark if present.

--- state methods --- addTask adds a task to a random partition, computing its pass via the counter.

consume updates ready based on the current time and number of new tokens consumed.

createTestNexusEndpointProcessor creates a NexusEndpointProcessor with a mock operation for testing

delay returns the time until the limiter is ready. If the return value is <= 0 then the limiter can go now.

get returns a cluster from the [clusterPool], creating it lazily if needed. For exclusive pools, blocks until a slot is available and registers cleanu

getCreateTaskCount returns how many tasks were added

GetType returns type of search attribute from type map.

getWorkflowRunRequestInfo calls DescribeWorkflowExecution and returns the ExtendedInfo's RequestIDInfo corresponding to the supplied request ID. Fails

getWorkflowTaskFinishEventIDAfterChild gets the event ID of the first WFT completed after the child completed event. It does so by scanning the histor

isHTTP2SafeValue returns true if the string can be used as an HTTP/2 header value. Per RFC 9113 section 8.2.1, header field values must not contain NU