GetVisibilityIndex return visibility index name from Elasticsearch config or empty string if it is not defined.

IsServiceClientTransientError checks if the error is a transient error.

NewConfig returns new service config with default values

this will be done by the nexus handler? alternatively the engine can be a global variable, but not a good practice in fx.

NewMockEngine creates a new mock instance.

NewMockTransactionManager creates a new mock instance.

NewPrioritySemaphore creates a new semaphore with the given maximum combined weight for concurrent access, capable of handling multiple priority level

NewRateLimiter returns a new rate limiter that can handle dynamic configuration updates

NewSearchAttributeKeyword creates a new keyword search attribute given a predefined chasm field

NewTLSConfigProviderFromConfig creates a new TLS Config provider from RootTLS config. A custom cert provider factory can be optionally injected via ce

OnProtocolMessage delivers a message to the Update state machine. The Body field of *protocolpb.Message parameter is expected to be one of *updatepb.R

SendToChannel sends to ch using the TestEnv context.

Serialize returns the actual value of the slug when used in an HTTP path, e.g. "v1" for a constant slug or "test-namespace" for a variable.

SetEngineForTest sets s.engine. Only used by tests.

SetPartitionScale is called on the root partition to propagate new scale info to child partitions.

SetVersionsForTests sets headers as they would be received from the client. Must be used in tests only.

TargetCluster returns tag for TargetCluster

WorkflowTypeTag returns a new workflow type tag.

calculateTimeSkippingTransition determines the next skip target. Candidates (in collection order): pending user timers, activity retry backoffs, workf

forBothConverters runs fn as two parallel subtests, one with the legacy visibility query converter and one with the unified converter. TODO: Remove on

isForwarded returns true if the underlying task is forwarded by a remote matching host forwarded tasks are already marked as started in history

Returns the earliest time that matches this calendar spec that is after the given time. All times are considered to have 1 second resolution.

setState assigns the current state to a new value returning the original value.

ActivityTaskQueueKey returns the metadata key for an activity's task queue, keyed by scheduled event ID.

CompleteOperation sends a completion callback for a Nexus operation to the given URL with the given completion details.

ExecutionKey returns the execution key for the execution the context is operating on.

GenerateVersionWorkflowID is a helper that generates a system accepted workflowID which are used in our Worker Deployment Version workflows

Deprecated: Marked as deprecated in temporal/server/api/matchingservice/v1/request_response.proto.

HandleBusyWorkflow is called when a task encounters a busy workflow error. It routes the task to the ExecutionQueueScheduler for sequential processing