TokensAt returns the number of tokens that will be available at time t

Transition transitions a machine by ID.

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

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

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

Unsubscribe unsubscribes from the shard counter. This closes the ShardCount channel.

Some clients depend on the fact that the runtime's timers do _not_ run synchronously. If UseAsyncTimers(true) is called, then EventTimeSource will beh

ValidateConnectConfig validates params

ValidateLongPollContextTimeoutIsSet checks if the context timeout is set for long poll requests.

ValidateSchedule validates a cron schedule spec

ValidateTransientWorkflowTaskEvents validates that transient workflow task events have sequential event IDs starting from the given offset. Returns an

WithActiveCluster assigns the active cluster to a Namespace during a Clone operation.

WithConfigFile sets a specific configuration file path to load. When provided, only this file will be loaded, bypassing the legacy hierarchical loadin

WithRequestID sets the requestID used when creating a new execution. This option only applies to StartExecution() and UpdateWithStartExecution().

WithTaskGroup sets the task group for the task. The task group is used when the side effect's destination is specified for grouping semantics on the o

WithTotalLimit provides an optional limit to the total number of Updates for workflow run.

WithZone sets the availability zone for configuration loading. This is used to load zone-specific configuration overrides (e.g., "us-east-1a").

This workflow is implemented in a way such that it always CaNs after some history events are added to it and when it has no pending work to do. This i

workflow task WorkflowCommandType returns tag for WorkflowCommandType

WorkflowServiceExtractor returns a RoutingKeyExtractorFunc that extracts the routing key from WorkflowService API requests using the provided RoutingK

WriteSchemaUpdateLog adds an entry to the schema update history table

WriteTaskToDLQ writes a task to the DLQ, creating the underlying queue if it doesn't already exist.

WriteToLog writes all captured tasks to a file in JSON format

addRoutingConfigUserData sets up deployment user data with a current version and an optional ramping version. Pass "" for rampingBuildID to omit rampi

addUniqueTest appends name to tests if not already seen.

call this whenever new tasks are acked or when ackLevelPinnedLocked() may turn from true to false (i.e. when ackLevelPinnedByWriter is set to false or

appendPredicates adds new predicates to the slice of existing predicates dropping any duplicated predicates where duplication is determined by Predica

assertAcceptedUpdateCompletedWorkflowError asserts the full error chain: WorkflowExecutionError -> NexusOperationError -> ApplicationError{Type: "Acce

assertNoNewLogs asserts that no new matching log is emitted during d, i.e. the expectation's match count stays at whatever it is when this is called.

assertRecentActionsNoDuplicateRunIDs verifies that no two entries in RecentActions refer to the same workflow run. Duplicates can occur if the migrati

bulkAfterAction is triggered after bulk processor commit

cachedTaggedScope returns a tally.Scope tagged with the given tags, caching the result so that repeated calls with the same tag combination avoid allo

checkAssignmentConditions checks for validity conditions that must be assessed by looking at the entire set of rules. It returns an error if the new s