truncateToSlackLimit truncates text to stay within Slack's block text limit Slack blocks have a 3000 character limit per text field

typeDispatch routes a polled workflow task to a handler keyed by the workflow type name. Returns an error for unexpected types so a test failure pinpo

Unloads a task queue partition by id. If unloadPM is given and the loaded partition for queueID does not match unloadPM, then nothing is unloaded from

called on namespace state change callback, membership change, and dynamic config change

updateSingleNamespace updates the cache with a namespace if it's newer than what we have. Returns true if the namespace state changed. When updatedVia

For use in tests

useScheduledAction returns true when the Scheduler should allow scheduled actions to be taken. When decrement is true, the schedule's state's `Remain

validateAccess performs the access rule check on a node. When the context's intent is OperationIntentProgress, This check validates that all of a nod

validateActivityTaskToken validates a task token against the current activity state.

ValidateAndNormalizeActivityAttributes validates and normalizes the common activity request attributes. This validation is shared by both standalone a

validateAndResolveArchetypeID validates the archetype and archetypeID fields and returns the resolved archetype ID. It performs the following checks:

validateChasmSideEffectTask completes validation of a CHASM side effect task after mutable state load/physical task validation. See [chasm.Node.Valid

validateExpectedTime returns false if the times are set but aren't equal.

validateTask runs taskInstance's registered validation handler. This method assumes component value is already hydrated.

waitForPropagation waits for all partitions of tq to mention newBuildID in their versioning data (in any position). Pass 0 for partitionCount to make

waitForTimeSkippingInfoSynced blocks until the standby cluster's TimeSkippingInfo agrees with the active's on Config and AccumulatedSkippedDuration. L

Checks if n number of threads are blocked in semaphore.

wciValidationStatusToComputeStatus converts a WCI ValidationStatus to the public ComputeStatus proto. A successful validation results in an empty erro

withStdin redirects os.Stdin to a temp file containing content for the duration of fn. A regular file is not a character device, so the command's pipe

Accept returns a connection to the server for a client.

ActivityMatchWorkflowRules checks if the activity matches any of the workflow rules and takes action based on the matched rule. If activity is changed

AddEmptyVersionHistory adds an empty VersionHistory to VersionHistories. It reuses an existing empty VersionHistory if one already exists. Returns: -

Alive returns true if the scavenger is still running

general Archetype returns tag for Archetype

ArchivalRequestNamespace returns tag for RequestNamespace

ArchivalRequestNamespaceID returns tag for RequestNamespaceID

ArchivalRequestRunID returns tag for RequestRunID

ArchivalRequestWorkflowID returns tag for RequestWorkflowID

AssignedBuildIdSearchAttribute returns the search attribute value for the currently assigned build ID

Authorize uses the policy's authorizer to authorize a request based on provided claims and call target. Logs and emits metrics when unauthorized. Retu

BlobSizeViolationOperation returns tag for BlobSizeViolationOperation

CleanSpec sets default values in ranges.

CleanupRuleTombstones clears all deleted rules from versioning data if the rule was deleted more than retentionTime ago. Clones data to avoid mutating

CommandHandler returns a [CommandHandler] for a given command type and a boolean indicating whether it was found.

CompareVersionHistoryItem compares 2 version history items

TODO: change the value returned so it can also be used by persistence metrics client. For now, it's only used by rate limit client, and we don't reall

ConvertOverrideToV32 reads from deprecated fields and returns a new object with ONLY the equivalent non-deprecated v0.32 fields. Should be used to rep