loadTestData returns a map of test names to durations in seconds.

Loads user data from db (called only on initialization of taskQueuePartitionManager).

lockCurrentExecutionIfExists returns current execution or nil if none is found for the workflowID locking it in the DB

initiated by the owning shard

lookupEndpoint gets an endpoint from the registry, preferring to look up by ID and falling back to name lookup. The fallback is needed because endpoin

lookupEndpoint gets an endpoint from the registry, preferring to look up by ID and falling back to name lookup. The fallback is needed because endpoin

Looks up a version set in versioning data based on a build ID associated with a task to determine how to redirect a task. For this function, buildId =

Looks up a version set in versioning data based on worker version capabilities to determine how to redirect a poll request. Requires: caps is not nil

makeValidationFn adapts the TaskValidator interface to the ComponentRef's validation callback format. Returns a validation function that wraps the giv

Returns true if the workflow is running and history event count should trigger a forced termination Prints a log message if history event count is ove

Returns true if the workflow is running and history size should trigger a forced termination Prints a log message if history size is over the error or

Returns true if the workflow is running and mutable state size should trigger a forced termination Prints a log message if mutable state size is over

maxTaskID returns the maximum value of the TaskID present in testTaskManager

gc

gc

maybeUpdateFailoverHistory adds an entry if the Namespace is becoming active in a new cluster.

mergeMessages from the DLQ up to and including the specified message ID, blocking until the merge workflow completes.

methodEntryFromDescriptor extracts the routing key accessor for a method. Returns (entry, ok=true) if the method has a concrete field path annotation,

migrateOldFormatVersions moves versions present in the given deployment from the deprecated old-format slice into the new per-deployment map. nolint:

migrateSchedulesFromStdin reads JSON lines from stdin, one {"namespace","schedule_id"} per line, feeding them to a pool of --workers goroutines that m

migrateSchedulesFromVisibility selects schedules via a visibility query and migrates each. When --query is not supplied the default query is chosen fr

migrateSingleSchedule migrates one schedule and performs the migration immediately.

minNonZeroTime returns the minimum time of a and b, ignoring zero times. If both a and b are zero, it returns zero.

minTaskID returns the minimum value of the TaskID present in testTaskManager