RejectUnprocessed rejects all Updates that are waiting for a workflow task to be completed. This method should be called after all messages from worke

Use this to get an address for a remote cluster to connect to.

ReplaceIntoActivityInfoMaps replace one or more into activity_info_maps table

DeleteFromChildExecutionInfoMaps replace one or more rows into child_execution_info_maps table

ReplaceIntoRequestCancelInfoMaps replace one or more rows into request_cancel_info_maps table

ReplaceIntoSignalInfoMaps replace one or more rows into signal_info_maps table

ReplaceIntoSignalsRequestedSets replace one or more rows into signals_requested_sets table

ReplaceIntoTimerInfoMaps replace one or more rows into timer_info_maps table

ResolvePassword returns the database password, either from the static Password field or by executing PasswordCommand. If neither is set, it returns an

RolloutAccepts reports whether key falls within the given percentage [0,100] using a stable hash, so dialing the percent up is monotonic: a key accept

ShardCount returns a channel that receives shard count updates.

StartDeploymentTransition starts a transition to the given deployment which must be different from workflows effective deployment. Will fail if the wo

Not needed for V1 func WithEagerLoading( paths []ComponentPath, ) OperationOption { panic("not implemented") } StartExecution creates a new executio

StaticGradualChange returns a GradualChange whose Value always returns def and whose When always returns a time in the past.

StringVariable adds a [StringVariable] component to the [Route].

SubscribeGradualChange is a helper that allows subscribing to a GradualChange[T] as if it was a T. It handles setting a timer for when the setting may

Sync updates the state of the current node to that of the incoming node. Meant to be used by the framework, **not** by components.

TargetClusterTag returns a new target cluster tag.

TerminateWorkflow writes a WorkflowExecutionTerminated event. If a workflow task is currently started it is failed first, and then the terminate event

TrimHistoryBranch validate & trim a history branch

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

* UpdateActivity function updates the existing pending activity via the updater callback. To update an activity, we need to do the following steps: *

ValidateSize validate search attributes are valid for writing and not exceed limits. The search attributes must be unaliased before calling validation

WithEnv sets the environment name for configuration loading (e.g., "development", "production"). If empty, defaults to "development".

WithTags implements [metrics.Handler.WithTags].

WrapTimeSourceWithTimeSkipping returns a TimeSource that adds getOffset() to the base's Now()/Since() on every call. If getOffset is nil, the wrapper

Zero generates a zeroed logical clock for the cluster ID.

assertMutableStateStatus asserts that the mutable state for the given run matches the expected status.

assertResetWorkflowLink asserts that the reset runID is properly recorded in the given run.

this function does not handle reset case, so it should only be used for the case where workflow run is found at local cluster TODO: Future improvement

buildTrailerPairs constructs the gRPC trailer key-value pairs from context metadata. It emits metadata in two formats: 1. Proto format: all entries s

chasmSchedulerEnabled returns true when schedule RPCs should route to CHASM first. Handlers must be capable of falling back to V1 codepaths for schedu

TODO (alex): this should be gone.

commitPriorWeight returns a prior weight multiplier [0.0, 2.0] for a commit, based on its changed files relative to the test name. For now this only r

Concurrent tests for testing approximateBacklogCounter

persistence helper

called with subscriptionLock

called with subscriptionLock

ditherPass spreads a new/reset key's starting pass deterministically over its initial stride [base, base+inc), based on a stable hash of the key. This

call with lock held. Returns true if a match was found but blocked by rate limiting.

findMetricWithTag searches captured metrics for a recording of the named metric that contains the specified tag key/value pair.

finishForward must be called after forwarding a task.

generateValidCallbackToken creates a valid callback token for testing with the given namespace, workflow, and run IDs

getGetTasksCount returns how many times GetTasks was called

getMutableStateByID resolves the current run ID of a workflow via DescribeWorkflowExecution and returns its persistence-layer mutable state.

getOrCreateShardContext returns a shard context for the given shard ID, creating a new one if necessary. If a shard context is created, it will initia

insertRedirectRule replaces a new versioning redirect rule to the task queue user data. It checks the response and returns the conflict token.

isExcludedAPI checks if an API is marked as a non-standard API via proto options.

isFullyRamped returns true if the rule has a ramp percentage of 100 or a ramp of nil

isStandaloneNexusOperationEnabled checks if standalone Nexus operations are enabled for the given namespace.

Lifecycle returns tag for Lifecycle

logBetaBinomial returns the log marginal likelihood of observing k failures in n trials with a Beta(alpha, beta) prior on the failure probability. Wit

this is in the year 2225