NewNamespaceConfig initializes a NamespaceConfig with the field values needed to pre-register the namespace via the CreateNamespaces function. Note:

NewNamespaceReplicationQueue creates a new NamespaceReplicationQueue instance

NewNexusEndpointPersistenceMetricsClient creates a NexusEndpointManager to manage nexus endpoints

NewNexusEndpointPersistenceRateLimitedClient creates a NexusEndpointManager to manage nexus endpoints

NewQPSQueue initializes a QPSQueue to collect data points for each workflow execution. The queue size is set to concurrency + 1 to account for up to '

NewQueryParser creates a new query parser for filestore

NewQueuePersistenceMetricsClient creates a client to manage queue

NewQueuePersistenceRateLimitedClient creates a client to manage queue

NewQueueV2 returns an implementation of persistence.QueueV2.

NewRefCountedDBConn returns a logical mysql connection that uses reference counting to decide when to close the underlying connection object. The ref

NewRegistry creates a workers heartbeat registry with the given parameters.

NewRegistry creates a new [Registry].

NewReplicator creates a new replicator for processing replication tasks

NewRetryableClient creates a new instance of workflowservice.WorkflowServiceClient with retry policy

NewRetryableClient creates a new instance of matchingservice.MatchingServiceClient with retry policy

NewRetryableClient creates a new instance of adminservice.AdminServiceClient with retry policy

NewRuntimeMetricsReporter Creates a new RuntimeMetricsReporter.

NewSDKVersionInterceptor creates a new SDKVersionInterceptor with default max set size

NewSQLExecutionStore creates an instance of ExecutionStore

NewSQLVisibilityStore creates an instance of VisibilityStore

NewScavenger returns an instance of executions scavenger daemon The Scavenger can be started by calling the Start() method on the returned object. Cal

NewScheduler returns an initialized CHASM scheduler root component.

NewSentinel returns a sentinel CHASM scheduler that exists only to reserve the schedule ID. Sentinels have no sub-components (other than Info for idle

NewShardManager create a new instance of ShardManager

NewShardOwnershipLost returns new ShardOwnershipLost error.

NewShardPersistenceMetricsClient creates a client to manage shards

NewShardPersistenceRateLimitedClient creates a client to manage shards

NewSortedSetManager returns a new SortedSetManager with the given comparison function and key function.

NewStringersTag returns a tag that will lazily generate the string representation of the provided fmt.Stringer values. Note that it does **not** cache

NewTestBaseWithCassandra returns a persistence test base backed by cassandra datastore

NewTestBaseWithSQL returns a new persistence test base backed by SQL

NewTestCluster returns a new SQL test cluster

NewTestCluster returns a new cassandra test cluster

NewUpdateSchemaTask returns a new instance of UpdateTask

NewVersionMembershipAndReactivationStatusCache wraps the provided cache with a typed API and metrics.

NewVisibilityArchiver creates a new archiver.VisibilityArchiver based on filestore

NewVisibilityArchiver creates a new archiver.VisibilityArchiver based on s3

NewVisibilityStore create a visibility store connecting to ElasticSearch

NOTE: must implement CreateOrUpdateLeaseFunc.

NextNumber returns tag for NextNumber

NexusServices returns all registered Nexus services.

NexusTaskQueueName returns tag for NexusTaskQueueName

NotifyExecution notifies any PollComponent callers waiting on the execution.

NumberChanged returns tag for NumberChanged