GetTaskQueueUserData gets versioned user data. This data would only exist if a user uses APIs that generate it, such as the worker versioning related

MustToPayload converts a value to a Payload using the default data converter.

New creates a new cache with the given options

NewDefaultOutgoingRateLimiter returns a default rate limiter for outgoing traffic, using fixed burst ratio of 2 and fixed 1 minute refresh interval

NewJSONPBEncoder creates a new JSONPBEncoder.

NewPagingIterator create a new paging iterator

OnTasks will be called once per batch of tasks added, either sync match or async. The NumTasks count may be estimated based on assumptions of load bal

ReasonTag is a generic tag can be used anywhere a reason is needed. Make sure that the value is of limited cardinality.

Register namespace using persistence API because: 1. The Retention period is set to 0 for archival tests, and this can't be done through FE, 2. Update

StartNamespaceMetricCapture starts a metrics capture scoped to this test's namespace. Namespace captures are safe on shared clusters because reads are

Abort marks the task as aborted, usually means task executor shutdown

DefaultFailureConverter returns the package's default [FailureConverter] implementation. Translates [HandlerError], [OperationError] and [FailureError

DeploymentVersionFromDeployment Temporary helper function to convert Deployment to WorkerDeploymentVersion proto until we update code to use the new p

GetResolver returns the service resolver for a service in the cluster.

Key returns tag for Key

LogEvent appends an event with the given message. Messages longer than the configured maximum length are truncated at a UTF-8 rune boundary; once the

LookupN looks up n hosts that owns the resource identified by the given key, if n is greater than total number of hosts, all hosts will be returned in

NewNoopCollection creates a new noop collection.

OpLog returns a compacted operation log from the root state machine. The operation log maintains a sequence of state changes, while compaction ensures

ReadHistoryBranchByBatch returns history node data for a branch ByBatch

history engine shard ShardID returns tag for ShardID

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

Validate determines whether a task should proceed with execution based on the current context, component state, task attributes, and task data. This

createRandomExternalNexusServer creates a mock nexus server that listens via a randomized endpointName and return this name to the caller.

hasWordsBefore checks if the given words appears before position pos in s, separated by at least one space, and each word is a whole word. Words must

pollUntilRegistered registers versioned pollers for the given deployment. tqTypes controls which task queue types to poll; it defaults to workflow onl

AddedTasks is called on a batch of tasks added. This is called in the task add path, so it shouldn't block.

DeleteHistoryBranch removes a branch If this is the last branch to delete, it will also remove the root node

EXPECT returns an object that allows the caller to indicate expected use.

Fail logs an error using `staticMessage` to indicate a failed assertion. `staticMessage` is expected to be a static string to help with grouping and

Gauge obtains a gauge for the given name.

Get gets the value of a test hook from the registry. TestHooks should be used sparingly, see comment on TestHooks.

MkdirTemp is a helper function which creates a temporary directory, and they are automatically removed after test is completed

NewMockCounterIface creates a new mock instance.

NewMySQLConfig returns a new MySQL config for test

NewPostgreSQLConfig returns a new MySQL config for test

NewTransition creates a new [Transition] from the given source states to a destination state for a given event. The apply function is called after ver

SearchAttributeValue returns the value for a given SearchAttribute with compile-time type safety. The return type T is inferred from the SearchAttribu

SetCondition sets the condition to access this edge

WithDedicatedCluster requests a dedicated (non-shared) cluster for the test. Use this for tests that have cluster-global side effects.