EXPECT returns an object that allows the caller to indicate expected use.

IsChasmSystem returns true if name is a system search attribute used by CHASM

NewExecutionManagerDLQWriter creates a new DLQWriter that uses the [ExecutionManager].

NewGlobalTypedSetting creates a setting that uses mapstructure to handle complex structured values. The value from dynamic config will be _merged_ ove

NewMockController creates a new mock instance.

NewMockRateLimiter creates a new mock instance.

NewRetrier is used for creating a new instance of Retrier

NewShardStore returns a new shard store

NexusServiceProcessors returns a list of NexusServiceProcessor instances to register with the __temporal_system Nexus endpoint.

PollTask blocks waiting for a task Returns error when context deadline is exceeded maxDispatchPerSecond is the max rate at which tasks are allowed to

RegisterMachine registers a [StateMachineDefinition] by its type. Returns an [ErrDuplicateRegistration] if the state machine type has already been reg

ReplaceIntoVisibility deletes old row (if it exist) and inserts new row into visibility table

StateValidationIntercept runs ValidateState - see docstring for that method.

UnversionedQueueKey returns the unversioned PhysicalTaskQueueKey of a task queue partition

nolint: revive

encodeChasmBlob encodes CHASM data and task payloads through the env-aware serializer while preserving deterministic proto3 bytes for byte comparisons

get returns true if a specific bit is set.

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

load mutable state, if mutable state's next event ID <= task ID, will attempt to refresh if still mutable state's next event ID <= task ID, will retur

load mutable state, if mutable state's next event ID <= task ID, will attempt to refresh if still mutable state's next event ID <= task ID, will retur

requireWDVTaskQueueStatsRelaxed asserts task queue statistics by allowing for over-counting in multi-partition ramping scenarios. The production code

Sets TemporalWorkerDeployment to the override DeploymentName if present, or`ms.executionInfo.WorkerDeploymentName`. Sets TemporalWorkerDeploymentVersi

verifyTimestampWithinRange asserts if the actual timestamp is set to an appropriate value. It does this check by checking if the timestamp set is with

ComputeNextDelay returns a negative sentinel ("done") when retries are exhausted, and a positive duration when another retry should happen.

wrapTimeSourceWithTimeSkipping wraps ms.timeSource (and the hBuilder's copy) with a time-skipping wrapper. The closure captures ms so the offset track

Abort immediately aborts all incomplete Updates in the Registry.

ActivityTypeKey returns the metadata key for an activity's type, keyed by scheduled event ID.

Add will try to batch input task with the last task in the queue. Since most likely incoming task are ordered by task ID, we only try to batch incomin

Burst returns the burst for this rate limiter