Invoke executes the callback logic and returns the invocation result.

NewCompletionHTTPClient constructs a [CompletionHTTPClient] from given options for sending Nexus operation completion callbacks via HTTP.

NewExecutionStore returns a new execution store

NewMockLibrary creates a new mock instance.

NewMockWorker creates a new mock instance.

NewTestVisibilitySearchAttributesMapper creates a new VisibilitySearchAttributesMapper. For testing only.

NexusServices returns a list of nexus.Service instances to register with the __temporal_system Nexus endpoint.

ParseHistoryBranchInfo parses the history branch for branch information

ProcessTimeRange generates buffered actions according to the schedule spec for the given time range. The parameter manual is propagated to the return

RecordWorkerHeartbeat receive heartbeat request from the worker.

RemoveRemoteCluster removes remote cluster.

SetRequestLinks records the links contributed by the given request on the component, replacing any prior entry for the same request ID. Passing nil/em

TruncateUTF8 truncates s to no more than n _bytes_, and returns a valid utf-8 string as long as the input is a valid utf-8 string. Note that truncatio

Validate checks that the given links do not exceed the configured count and per-link size limits, and that each link's variant has its required fields

WithDeadlineBuffer returns a child context with a deadline that ensures that at least buffer amount of time remains after the child deadline expires a

defaultListRequest returns the standard ListNamespacesRequest used by the registry.

TODO(pri): remove

hasWordAt is a simple test to check if it matches the whole word: it checks if the adjacent characters are not alphanumeric if they exist.

Returns the next highest fair level.

Returns true if a < b lexicographically.

mergeWorkflowExecutionOptions copies the given paths in `src` struct to `dst` struct and returns the merged opts and the options to reapply

newTaggedMetricsHandler returns a metrics handler tagged with the Scheduler's namespace and backend.

readSchemaDir returns a sorted list of subdir names that hold the schema changes for versions in the range startVer < ver <= endVer when endVer is emp

nolint:revive,cognitive-complexity

ShouldExecuteTimeSkipping checks if one mutable state should execute time skipping, i.e. there is no in-flight work and there is a time point to skip

startManager builds and starts the scaleManager. Call this after configuring EXPECTs and tweaking s.settings. Pass initial=nil to start with no prior

Poll task and assert no error and that a non-nil task is returned

validateRates verifies TasksAddRate and/or TasksDispatchRate in a dedicated await block. This should be called immediately after the relevant operatio

AddAndSwitchVersionHistory adds a VersionHistory and switch the current branch if necessary based on the Version of the last VersionHistoryItem. Retur

Deserialize mutates the given params object with the value of the component when parsing an HTTP path, e.g. setting the value of a variable to "test-n