makeTimeSkippingMS builds a running mutable state, snapshots it to a persistence proto, and returns the persistence proto plus the workflow key. The c

matchAndConvert can't be a method of Collection because methods can't be generic, but we can take a *Collection as an argument.

normalizeTestName strips all trailing parenthesized suffixes from test names, e.g. "(retry 1)", "(final)", "(timeout)".

normalizeVersionString take a valid semver string and returns the input as-is with the 'v' prefix removed if present

overrideWorkflowRunTimeout override the run timeout according to execution timeout

pOfP returns the crossP-th percentile of per-key keyP-th percentiles.

parseHistory accept history in a formatHistoryEvents format and return slice of history events w/o attributes and maps of event attributes for every e

performReset is a helper method to reset the given workflow run and assert that it is successful.

record adds or removes a task from the tracker.

recordDroppedTask records the tasks_dropped counter on the given physical-queue handler. It is a no-op when reason is dropReasonUnspecified (a non-dro

runBisect computes posterior probability for each candidate culprit commit. obs must be sorted by CommitIdx ascending (chronological). The model: ther

serialize sets or updates serializedValue field of the node n with serialized value. It sets node's valueState to valueStateSynced and updates LastUpd

setTrailerInOpts finds the grpc.TrailerCallOption in opts and populates it.

setValue sets the value field of the node. If the node is a component or data node, the index from node value to node (valueToNode) is also updated.

startWorkflow starts a workflow in the cluster and replicates the initial workflow events to the other cluster.

testPinnedCaN_UpgradeOnCaN tests ContinueAsNew of a Pinned workflow with InitialVersioningBehavior set to AUTO_UPGRADE using task polling directly (wi

validateOnConflictOptions validates the on_conflict_options of a start request: - attach_completion_callbacks requires attach_request_id. A completion

waitForRedirectRulePropagation waits for all partitions of tq to have the given redirect rule in their versioning data

ApplyTypeMap set type for all valid search attributes which don't have it. It doesn't do any validation and just skip invalid or already set search at

ArchetypeDisplayName returns the human-readable name for a given archetype ID. This method should only be used by CHASM framework internal code, NOT C

ArchetypeID returns tag for Archetype

ArchetypeIDOf returns the ArchetypeID for the given component Go type. This method should only be used by CHASM framework internal code, NOT CHASM lib

AssertFiredOnce asserts that the callback was triggered exactly once.

CalculateExternalPayloadSize calculates the total size and count of all external payloads in the given history events.

Close closes the iterator and releases any allocated resources

CommitBuildID makes the following changes. If no worker that can accept tasks for the target build ID has been seen recently, the operation will fail.

Connect returns a connection to a client for the server.

ContextCounterGet returns value and true if successfully retrieved value

ContextMetadataGetAll retrieves all metadata from the context as a map copy.