Gets the next scheduled time after `after`, making use of a cache. If the cache needs to be refilled, try to refill it starting from `cacheBase` inste

Extracts a nexusContext from the given ctx and returns an operationContext with tagged metrics and logging. Resolves the context's namespace name to a

getOrReadthroughNamespace returns namespace information if it exists or reads through to the persistence layer and updates internal entry if it doesn'

getPhysicalTaskQueueManagerImpl extracts the physicalTaskQueueManagerImpl for the given taskQueuePartitionManager

getQuota returns the effective resource limit for a host given the per instance and per cluster limits. The "resource" here could be requests per seco

getRetention returns the retention period for this task generator's workflow execution. The retention period represents how long the workflow data sho

getSetIds returns an arbitrary but consistent member of the set, and the rest of the set. We want Add and Poll requests for the same set to converge o

getTaskManager returns the underlying testTaskManager (which is accessed differently depending on mode)

Returns a correctly typed value for fieldName retrieved from a row populated by a MapScan operation. Returns the zero value for the provided type and

getWorkflowHistory loads the workflow history based on given mutable state information from the DB.

globalNS builds a global (replicated) namespace whose active cluster is activeCluster. Only global namespaces return false from ActiveInCluster when t

groupFailuresByTest groups failures by normalized test name

handleAssignmentRuleNilRamp mutates and returns rule object to convert nil ramp to 100%

handleError should be called on errors from worker creation or run. it will attempt to refresh the worker again at a later time.

handleNamespaceCreationReplicationTask handles the namespace creation replication task

handlePatch creates backfillers to fulfill the given patch request.

TODO: support cancelling activity task

hasActivityPauseEntries checks if the TemporalPauseInfo search attribute contains any activity pause entries.

hasNext returns true if there are more pages to fetch

hasValidRamp returns true if the rule has a ramp percentage within [0, 100] or a ramp of nil

hasWordAfter checks if the given word appears after position pos in s, separated by at least one space, and is a whole word.

TODO (maybe): - Funcs like WithTime, WithAttributes, WithPayloadLimit(100) and pass them to PrintHistory - oneof support - enums as strings not as int

historyHasEventType reports whether the workflow's history contains at least one event of the given type.