newRecordTaskStartedContext creates a context for recording activity or workflow task started. The parentCtx from pollActivity/WorkflowTaskQueue endpo

newShardClosedErrorWithShardID when shard is closed and a req cannot be processed

newTaskPersistence creates a new instance of TaskStore

newTelemetryTaskStore returns telemetryTaskStore.

newTemporal returns an instance that hosts full temporal in one process

newTestCluster creates a new test cluster with the given name and cluster size All the nodes in the test cluster will register themselves in Ringpop w

nolint:revive // too many arguments

nexusCompleteOperationSuccess constructs a successful CompleteOperationOptions from the given payloads. Only the first payload is used since Nexus doe

noWaiters returns if there is no waiter that has priority higher or equal to lowestPriority.

normalizeTag applies excludeTags substitution to a single tag. Returns the (possibly modified) tag and whether it was normalized.

notifyOwnershipChanged starts or stops a background routine which watches the Nexus endpoints table version for changes. This is only expected to be c

onCanceled applies the canceled transition or delegates to the store if one is present.

onCompleted applies the succeeded transition or delegates to the store if one is present.

onFailed applies the failed transition or delegates to the store if one is present.

onStarted applies the started transition or delegates to the store if one is present.

openMigrateLog wires summary.logEnc to the --output-log file when the flag is set, returning a cleanup func that closes the file (a no-op when the fla

operationMetricsHandler returns a metrics handler enriched with caller-side Nexus operation tags. It mirrors chasm/lib/nexusoperation Operation.metric

outcome retrieves the activity outcome (result or failure) if the activity has completed. Returns nil if the activity has not completed.

outgoingMessageID returns the ID of the message that is used to Send the Update to the worker.

paginate creates an interactive CLI mode to control the printing of items

parseAlerts scans a gotestsum/go test stdout stream and extracts high-priority alerts such as data races and panics. It returns a slice of alerts in t

parseDeploymentFromVersionKey extracts the deployment name and build ID from a version key string used as the map key in DescribeTaskQueuePartitionRes

parseFailureDetails extracts the actionable part of a JUnit failure Data block.

parseIntLabel returns the value of the given label as an integer.

parsePageTokenValue parses the page token values to be used in the search query. The page token comes from the `sort` field from the previous response

parseRpcName takes the rpc name of a task queue partition and returns a ParseTaskQueuePartition. Returns an error if the given name is not a valid rpc

parseSQLVal handles values for specific search attributes. Returns a string, an int64 or a float64 if there are no errors. For datetime, converts to U