UnlockLow unlock with low priority, use LockLow / UnlockLow pair to lock / unlock

Unmarshal an object of type Failure from the protobuf v3 wire format

Unmarshal an object of type DLQJobToken from the protobuf v3 wire format

UpdateNamespace helper method

UpdateSchemaVersion updates the schema version for the keyspace

ValidateUUID parses and validates UUID contents from the given string representation returns: - nil if the input is empty string - error if input is m

ValidateUpdateWorkflowModeState validate workflow update mode & workflow state

VisibilityArchivalState observes the visibility archive configuration (state and URI) for this namespace.

WalkExportedMethods calls the provided callback on each method declared as public on the specified object. This prevents the `mustEmbedUnimplementedFo

WildCardStringToRegexps converts a given slices of string patterns to a slice of regular expressions matching wildcards (*) with any substring.

WithContextValues allows specifying key-value pairs that will be available in the Context via the Value() method whenever the chasm framework starts,

WithFxOptionsForService returns an Option which, when passed as an argument to setupSuite, will append the given list of fx options to the end of the

WithTestVars customizes the default test variables for the environment.

Consider passing the value of "metrics.breakdownByBuildID" dynamic config to this function.

WorkflowFirstEventID returns tag for WorkflowFirstEventID

WorkflowStartedEventID returns tag for WorkflowStartedEventID

addTasks adds both ProcessBuffer and Execute tasks as needed. It should be called when completing processing/executing tasks, to drive backoff/retry.

applyTestifyMFilter filters methods by the -testify.m flag. This is helpful for editor integrations like VSCode that take this suite for a testify sui

assertNoRecv asserts that ch yields no value within d.

captureDroppedOnEngine points the engine's root metrics handler at a capture handler so drops emitted down the partition handler chain are recorded. M

childCmd builds a StartChildWorkflowExecutionCommand with ABANDON parent-close policy and generous (virtual-time) run/task timeouts appropriate for ti

root handler for all cli commands

root handler for all cli commands

Key construction

TODO: why do we need a deep copy here?

TODO (alex): rename this to createLocalNamespace, and everywhere where it is called with isGlobal == true, add call to promoteNamespace.

drain method blocks until all inflight requests are completed This method should be called before updating shard rangeID, otherwise inflight request c

emitLatencyMetrics emits schedule-to-close, schedule-to-start, and start-to-close latencies.

execute invokes an [ImmediateExecutor].

executionForRef looks up an execution by the ref's RunID when present, or falls back to the current run for the business ID when RunID is empty.