recordUtilizationMetric records the overall capacity utilization ratio.

recordWorkerCountMetric emits a gauge per namespace. When a namespace moves to a different matching node, the old node's gauge goes stale until its en

refForComponent looks up the ComponentRef for a component instance by scanning all executions. It works because Node.CloseTransaction (called after ev

Returning an error from here means that we should retry creating/starting the worker. Returning noWorkerNeeded means any existing worker should be sto

refreshTasksForTimeSkipping re-stamps pending timer tasks against the current accumulated skip when a time-skipping transition happened within the rep

rejects an Update with provided failure.

removeDeploymentVersions removes provided build IDs from the new-format per-deployment map and, when requested, the corresponding entries from the dep

TODO remove this function once we keep all info in DB, e.g. activity / timer / child workflow to deprecate * HasActivityFinishEvent * hasActivityFinis

nolint:revive // cognitive complexity 35 (> max enabled 25)

report Sends runtime metrics to the local metrics collector.

nolint:revive,deep-exit

reschedulePendingActivities reschedules all the activities that are not started, so they are scheduled against the right queue in matching.

reseed rotates the shadow row to break persistent hash collisions over time. The current shadow becomes active, and the next row becomes the new shado

reset resets iterator to a certain state given its encoded representation if it returns an error, the operation will have no effect on the iterator

A minimal interval between workflow starts is used to prevent multiple starts with the same ID too rapidly. If the new workflow is started before the

resolveModuleOriginForSpec reports whether shortHash is reachable from the default branch of mod's repository. It runs two git commands: 1. git clon

resolveReleaseVersion returns the highest version for the previous minor. Stable releases are preferred over pre-releases per semver ordering. Pre-rel

Revives a deleted build ID updating its HLC timestamp. Returns a new build ID leaving the provided one untouched.

rewind moves a timestamp back by 1 millisecond to ensure positive durations in tests

runTDBGCommand is useful for manually testing the TDBG CLI because, in addition to automated checks that we can run on the parsed output, we also just

runWithMatchingBehaviors runs a test with all combinations of matching behaviors.

runningWorkflowID returns the workflow ID associated with the given outstanding request.

sanitizeActualHistoryEventsForEquals clears EventID and Version fields from actual history events if they are not set in the CORRESPONDING expected hi

saveCancellationResult saves the cancellation result by updating the cancellation component.

scheduleIsExpectedNotToFire returns true when a schedule flagged as "overdue" in visibility is actually in a state that legitimately explains the stal

scheduleToCloseDeadline returns the absolute time at which the ScheduleToClose timeout expires, accounting for start delay. Returns zero time if no Sc

scope returns a tag for scope Pre-defined scope tags are in values.go.

scoreAddr scores how likely the given addr is to be a remote address and returns the IP to use when listening. Any address which receives a negative s

send sends message to webhook URL

serializeConflictToken serializes a conflict token as a byte slice.