for internal use:

done returns true if this page and all previous pages are complete

drainTasks pops and processes all remaining tasks, printing each one.

drainWorkflowTaskAfterSetCurrent is a helper that sets the current deployment version, drains the initial workflow task from the execution, and ensure

drivePollsUntilRunNotRunning is like drivePollsUntilClosed but exits on any non-RUNNING status. Used for cron, where a run rolls to CONTINUED_AS_NEW r

emitOperationCanceled emits the cancel counter and latency metrics for an operation that completed as canceled.

emitOperationFailed emits the failure counter and latency metrics for an operation that failed non-retryably.

emitOperationSucceeded emits the success counter and latency metrics for an operation that completed successfully.

emitOperationTimedOut emits the timeout counter (tagged with the timeout type) and latency metrics for an operation that timed out.

emitPhysicalBacklogGaugesLocked emits backlog gauges tagged by priority key, along with the legacy task_lag_per_tl gauge. When version-attributed bac

emitScheduleToStartLatency emits the schedule-to-start latency when an async operation starts.

encoding & decoding util

decodeLink encodes the link to Nexus-Link header value. It follows the same format of HTTP Link header: https://developer.mozilla.org/en-US/docs/Web/H

Due to the lack of generics in go this function accepts callback which should return particular item by it index.

encodingTypeFromEnv returns an EncodingType based on the environment variable `TEMPORAL_TEST_DATA_ENCODING`. It defaults to "ENCODING_TYPE_PROTO3" cod

enrichNexusOperationMetrics enhances metrics with additional Nexus operation context based on configuration.

caller to ensure that lock is obtained before call this function

evictByTTL removes entries older than expireBefore from this bucket. Returns the number of entries removed.

executeChasmPureTimers walks a CHASM tree for expired pure task timers, executes them, and returns a count of timers processed.

executePropagationBatch executes a single batch of propagation and returns task queue max versions to check

executeStateMachineTimers gets the state machine timers, processes the expired timers, and returns a count of timers processed.

executeWorkflow just executes a simple no-op workflow that returns "hello" and returns the sdk workflow run.

executionFailed reports whether a closed execution ended in a failure state (failed, terminated, cancelled, or timed out). This drives the [chasm.Busi

exists checks if a path exists

Misc.

extractHistoryEvents extracts all history events from a batch of events sent to persistence. It's unlikely that persistence events would span multiple

extractMutableStateInfo extracts the relevant information to generate a start response with an eager workflow task.

fetchAndAnalyzeWorkflowRuns fetches workflow runs between since and until and counts successes. until is zero for an open-ended (up to now) window.

fetchPage fetches a new page of workflow executions