NewObjectLeakCheck creates an object leak checker.

NewOpenTelemetryProviderWithPrometheus creates a new OpenTelemetry provider with a Prometheus exporter.

NewOpenTelemetryProviderWithStatsd creates a new OpenTelemetry provider with a StatsD exporter.

NewOperatorHandlerImpl creates a gRPC handler for operatorservice

NewPagingIteratorWithToken create a new paging iterator with initial token

NewPredefinedTaskBlobDeserializer returns a TaskBlobProtoDeserializer that works for the stock task categories of the server. You need to extend this

NewPreemptableCallerInfo creates a new CallerInfo with Preemptable callerType and empty callOrigin. This is equivalent to NewCallerInfo(callerName, Ca

NewPriorityQueue create a new priority queue

NewPrompter creates a new Prompter. In most cases, the first argument should be [github.com/urfave/cli/v2.Context].

NewQueryParser creates a new query parser for filestore

NewQueuePersistenceRetryableClient creates a client to manage queue

NewSQLConnTestSuite returns the test suite

NewScavenger returns an instance of executorTask queue scavenger daemon The Scavenger can be started by calling the Start() method on the returned obj

NewScavenger returns an instance of history scavenger daemon The Scavenger can be started by calling the Run() method on the returned object. Calling

NewSearchAttributeKeywordList creates a new keyword list search attribute given a predefined chasm field

NewSearchAttributeText creates a new text search attribute given a predefined chasm field

NewSearchAttributesMap creates a new SearchAttributeMap from raw values.

NewSelectedAPIsForwardingPolicy creates a forwarding policy for selected APIs based on namespace

NewServerStatsHandler creates a new gRPC stats handler that tracks each request with an encapsulating span using the provided TracerProvider and TextM

NewSetupSchemaTask returns a new instance of SetupTask

NewSetupSchemaTestSuite returns a test suite

NewShardIDTypedSettingWithConstrainedDefault creates a setting with a compound default value.

NewShardIDTypedSettingWithConverter creates a setting with a custom converter function.

NewShardPersistenceRetryableClient creates a client to manage shards

NewStandaloneActivity creates a new activity component and adds associated tasks to start execution.

NewStarter creates a new starter, fails if getting the active namespace fails.

NewStatsdExporter creates a new StatsD exporter that implements the OpenTelemetry metric.Exporter interface

NewTaskManager creates a new instance of TaskManager

NewTaskPersistenceMetricsClient creates a client to manage tasks

NewTaskPersistenceRateLimitedClient creates a client to manage tasks

NewTaskProcessor creates a new replication task processor.

NewTaskQueueTypedSettingWithConstrainedDefault creates a setting with a compound default value.

NewTaskTypeTypedSettingWithConstrainedDefault creates a setting with a compound default value.

NewTaskTypeTypedSettingWithConverter creates a setting with a custom converter function.

NewTimer is a pass-through to time.NewTimer.

NewTimer creates a Timer that will send the current time on a channel after at least duration d. It returns the channel and the Timer.

NewUpdateSchemaTestSuite returns a test suite

NewValidator create a new namespace attribute Validator

NewVersionChecker constructs a new VersionChecker

NewVersionTestSuite returns a test suite

NewVisibilityArchiver creates a new archiver.VisibilityArchiver based on filestore

NewVisibilityManagerDual create a visibility manager that operate on multiple manager implementations based on dynamic config.

NewWorkerWithOptions returns a Temporal worker on the specified task queue. WorkflowPanicPolicy is always set to worker.FailWorkflow so that workflow

NewWorkflowHandler creates a gRPC handler for workflowservice

Next return the next item

NextTime provides a peek at the next time in the spec following 'after'.

NexusOperationInvocationData loads invocation data (Input, Header, NexusLinks) from the scheduled history event.

NormalizeAndValidatePartition validates a TaskQueue proto object as a task queue partition, and normalizes its fields. Note that a TaskQueue proto hol

OldUpdateState updates the queue state with the given value. This is used by old backlog manager (not subqueue-enabled). TODO(pri): old matcher cleanu

Paginate returns up to n elements in the set that compare greater than gtKey. If there are more than n such elements, it also returns the key of the l

Panic implements log.Logger.

ParseDurationDefaultSeconds is like time.ParseDuration, but supports unit "d" for days (always interpreted as exactly 24 hours), and also supports uni