Allow validates the URL by: 1. true, nil if the provided url matches the rule and passed validation for the given rule. 2. false, nil if the URL does

call with lock held

allowedBufferedStarts returns the number of BufferedStarts that the Backfiller should buffer, taking into account buffer limits and concurrent backfil

analyzeArtifactForCIBreakers analyzes a single artifact for CI breakers. A test is a CI breaker if it has a failure with the "(final)" suffix, meaning

appendSeparatedTags adds the sorted list of tags using the DogStatsd/InfluxDB supported tagging protocol. For example, if the stat is `hello.world` an

appendSeparatedTags adds the sorted list of tags using the DogStatsd/InfluxDB supported tagging protocol. For example, if the stat is `hello.world` an

appendSyntheticFailure adds a failure entry under a "testrunner" suite for events outside any real testcase (e.g. timeout killing gotestsum pre-write)

appendTaskLocked appends a task to the queue for the given key, creating the queue and spawning a worker if needed. Must be called with s.mu held. q i

appendTransientEvents queries mutable state for transient/speculative events and appends them to the response. This function attempts to use cached tr

applyActivityOptionsToStartRequest copies normalized values from ActivityOptions back to the StartActivityExecutionRequest.

applyBackoff updates start's BackoffTime based on err and the retry policy. `now` is the framework clock captured at task start - using time.Now would

applyCompletedRetention removes the oldest completed BufferedStarts beyond the retention limit.

applyPendingComponentMetadata writes staged per-component framework metadata (request links and user metadata) onto the node's ChasmComponentAttribute

nolint:revive // This method is long but it's more readable to keep the logic in one place since it's all related to constructing the completion reque

revive:disable-next-line:cognitive-complexity

archivalEnabled returns true if archival is enabled for either history or visibility. For both history and visibility, we check that archival is enabl

attachBatchOperationStats attaches statistics on the number of individual successes and failures to the memo of this workflow.

attemptScheduleTime returns when the given attempt was scheduled to run: the activity's schedule time plus start delay for the first attempt, or calcu

authorizeTargetNamespaces authorizes cross-namespace commands in RespondWorkflowTaskCompleted. Commands like SignalExternalWorkflow, StartChildWorkflo

backfillShardCount is to add backward compatibility to the svc based cluster connection. It sets the shard count for newMetadata to the number of shar

backoffDelay returns the amount of delay that should be added when retrying.

bootstrap ring pop service by discovering the bootstrap hosts and joining the ring pop cluster

buildCLI is the main entry point for the temporal server

buildCallbackInfosFromChasm reads callbacks from the CHASM workflow component and converts them to API format. TODO(long-nt-tran): move this to chasm/

buildCallbackInfosFromHSM reads callbacks from HSM and converts them to API format.

buildChasmCallbackInfo converts a single CHASM callback to API CallbackInfo format. Returns nil if the callback should not be included in the response