WithBaseWorkerOptions configures default options for workers connected to the test server. WorkflowPanicPolicy is always set to worker.FailWorkflow s

WithChainedFrontendGrpcInterceptors sets a chain of ordered custom grpc interceptors that will be invoked for all Frontend gRPC API calls. The list of

WithClusterLogger sets a custom logger for the test cluster, used instead of the default test logger. Useful for intercepting server log output.

WithCustomArchivers configures custom history and visibility archiver factories on the test's cluster. This implies a dedicated cluster because the fa

WithCustomTaskHandler returns a copy of the Replicator with the custom task handler set.

WithData adds a key-value pair to a Namespace during a Clone operation.

WithEmbedded forces the loader to use only the embedded configuration template. This loads configuration from environment variables only, using the em

WithExtractors returns a new interceptor with additional extractors prepended. The new extractors will be tried before the existing ones.

WithHistoryShardCount sets the number of history shards for the test's cluster. This implies a dedicated cluster, since shard count cannot be changed

WithID assigns the ID to a Namespace during a Clone operation.

WithLogger sets the log.Logger to be used by Registry and its Updates.

WithLogger sets a custom logger for the test's cluster, letting a test intercept server log output. This implies a dedicated cluster, since a custom l

WithMTLS enables mutual TLS on the test's cluster. This implies a dedicated cluster, since the TLS configuration cannot be shared across tests.

WithMetrics sets the metrics.Handler to be used by Registry and its Updates.

WithNamespace sets the namespace name to be used in Registry metrics and logs.

WithRetention assigns the retention duration to a Namespace during a Clone operation.

WithTracerProvider sets the trace.TracerProvider (and by extension the trace.Tracer) to be used by Registry and its Updates.

WorkerDeploymentClient mocks base method.

WorkerVersioningAssignmentRuleCount returns tag for AssignmentRuleCount

WorkerVersioningMaxUpstreamBuildIDs returns tag for RedirectRuleCount

WorkerVersioningRedirectRuleCount returns tag for RedirectRuleCount

WorkflowBranchID returns tag for WorkflowBranchID

WorkflowHistorySizeBytes returns tag for HistorySizeBytes

WorkflowRuleID returns tag for WorkflowRuleID

WorkflowRunTimeout returns the workflow run timeout duration. Returns 0 if no timeout is set.

WorkflowSignalCount returns tag for SignalCount

WorkflowStartedTimestamp returns tag for WorkflowStartedTimestamp

WorkflowTaskFailedCause returns tag for WorkflowTaskFailedCause

WorkflowTaskTimeout returns tag for WorkflowTaskTimeoutSeconds

WorkflowTimeoutType returns tag for WorkflowTimeoutType

WrapError provides each variant the opportunity to wrap the error returned by the task executor for, e.g. to trigger the circuit breaker.

WrapError provides each variant the opportunity to wrap the error returned by the task handler for, e.g. to trigger the circuit breaker.

WriteTaskToDLQ implements [DLQWriter.WriteTaskToDLQ] by calling [queues.DLQWriter.Write].

activityContextFromChasm extracts the activityContext from a chasm.Context. Panics if the context value is missing, which indicates a library registra

activityOptionsFromStartRequest builds an ActivityOptions from the inlined fields of a StartActivityExecutionRequest for use with shared validation lo

Takes a list of loaded build IDs from a search attribute and adds a new build ID to it. Also makes sure that the resulting SA list begins with either

addCompletionCallbacksChasm creates completion callbacks using the CHASM implementation.

addCompletionCallbacksHsm creates completion callbacks using the HSM implementation.

addDeletionTask adds a task to delete workflow history events from primary storage.

This mutates request (but idempotent so safe for retries)

Adds jitter to a nominal time, deterministically (by hashing the given time and a seed).

addNexusOperation adds a Nexus operation component to the workflow.

addWorkflowTasksConcurrent adds taskCount number of tasks for each numWorker concurrently

aliasChasmSearchAttributes aliases CHASM search attribute field names. This function mirrors the pattern of searchattribute.AliasFields for custom sea

allFilesMatchPrefixes returns true if every file in the list starts with one of the given prefixes.

allSubmitted returns true if all executions in this page have been submitted