assertWorkflowIsPaused is a helper method which asserts that, - the workflow status is paused. - the workflow has the correct pause info. - the Tempor

filterWorkers returns all WorkerHeartbeats in a namespace for which predicate(hb) returns true. System workers are excluded unless includeSystemWorker

validateVersionWfParams is a helper that verifies if the fields used for generating Worker Deployment Version related workflowID's are valid

AddTask adds a task to the task queue. This method will first attempt a synchronous match with a poller. When that fails, task will be written to data

ContextCounterAdd adds value to counter within metrics context.

DescribeWorkflow mocks base method.

Do calls f() on a worker goroutine. If the call can't be started within targetDelay, it adds another worker. If Stop is called concurrently, Do may or

EncodeValue encodes search attribute value and IndexedValueType to Payload.

GenerateRandomString is used for generate test string

GetValue returns a set of values and associated constraints for a key. Not all constraints are valid for all keys. The returned slice of ConstrainedV

Members returns all known hosts available for this service.

MergeMapOfPayload returns a new map resulting from merging map `src` into `dst`. If a key in `src` already exists in `dst`, then the value in `src` re

NewArchiverProvider returns a new Archiver provider

NewHTTPClient creates a new [HTTPClient] from provided [HTTPClientOptions]. BaseURL and Service are required.

NewMockVisibilityQueryConverter creates a new mock instance.

SelectFromVisibility returns one or more rows from visibility table Required filter params: - getClosedWorkflowExecution - retrieves single row - {nam

StartTransaction sets up the mutable state for transacting.

TODO (alex-update): move this from workflow context.

VersionedBuildIdSearchAttribute returns the search attribute value for a versioned build ID

approxDuration asserts actual is within 10s of expected. Each skip loses (event_time - command_apply_time) of wall clock because AccumulatedSkippedDur

deepCopyForMapstructure does a simple deep copy of T. Fancy cases (anything other than plain old data) is not handled and will panic.

drainWorkflowTaskAfterSetCurrent is a helper that sets the current deployment version, drains the initial workflow task from the execution, and ensure

executeHistoryReplicationTasksUntil executes buffered history event replication tasks until the specified event type is encountered.

Pass either versionSet or build ID

ActivityTypeTag returns a new activity type tag.

Appendf appends a formatted issue to the set.

AvailableMembers returns all hosts available for this service that are accepting requests (not draining).

BuildId returns empty if this is not a Versioning v2 queue.

DeleteChild marks a child node and all its descendants as deleted, removing them from the cache. No transitions will be allowed after deleting a child

FullyQualifiedName creates a fully qualified name (FQN) by combining a library name and a component or task name. The FQN is used to uniquely identify

GetType returns type of search attribute from type map.

GetVersionHistory gets the VersionHistory according to index provided.