Encode a blob for a given task category to a human-readable format by deserializing the blob into a proto message and then pretty-printing it using pr

EnhanceContext returns a new context with [MappedClaims] and [AuthHeader] values.

Err returns a joined error of lr.Errors.

ErrorType returns a best effort guess at the most meaningful type name for the given error. If any of err's underlying errors implement TypedError, th

EventDefinition returns an [EventDefinition] for a given type and a boolean indicating whether it was found.

EvictSelfAt is similar to EvictSelf but causes the change to take effect on all hosts at that absolute time (assuming it's in the future). This proces

ExponentialBackoffAlgorithm calculates the backoff duration using exponential algorithm. The result is initInterval * (backoffCoefficient ^ (currentAt

Failed implements testlogger.TestingT.

FirstEventVersion returns tag for FirstEventVersion

FormatDuration converts a duration into a string representation in millisecond resolution.

FormatPinnedVersionNotInTaskQueueError formats the error message when a pinned version is not present in a task queue.

GenerateDeleteHistoryEventTask adds a tasks.DeleteHistoryEventTask to the mutable state. This task is used to delete the history events of the workflo

Get returns the value corresponding to the key, if it exist

GetAuthInfo extracts auth info from TLS info and headers. Returns nil if either the policy's claimMapper or authorizer are nil or when there is no aut

GetBackoffForNextSchedule calculates the backoff time for the next run given a cronSchedule, current scheduled time, and now.

GetBeginNodeID gets node id from last ancestor

GetBuildIdDeltas compares all active build ids in prev and curr sets and returns sets of added and removed build ids.

GetClientNameAndVersion extracts SDK name and version from context headers

GetCommonServiceOptions returns an fx.Option which combines all the common dependencies for a service. Why do we need this? We are propagating depende

GetCompletionEvent retrieves the workflow completion event from mutable state

GetCustomSearchAttributesMapper is a temporary solution to be able to get search attributes with from persistence if forceSearchAttributesCacheRefresh

GetDLQService returns a DLQService based on FlagDLQVersion.

GetEffectiveDeployment returns the effective deployment in the following order: 1. DeploymentVersionTransition.Deployment: this is returned when the w

GetFairnessWeightOverrides returns current fairness weight overrides for this queue.

GetHostInfoProvider for testing

GetPerTaskQueueFamilyScope returns "namespace" and "taskqueue" tags. "taskqueue" will be "__omitted__" if taskQueueBreakdown is false.