NewArchivalQueueFactory creates a new QueueFactory to construct archival queues.

NewArchivalQueueTaskExecutor creates a new queue task executor for the archival queue. If you use this executor, you must monitor for any metrics.Arch

NewAudienceMapper returns a JWTAudienceMapper that always returns the given audience string.

NewBackgroundLowCallerInfo creates a new CallerInfo with BackgroundLow callerType and empty callOrigin. This is equivalent to NewCallerInfo(callerName

NewChasmTaskTypeTypedSettingWithConstrainedDefault creates a setting with a compound default value.

NewChasmTaskTypeTypedSettingWithConverter creates a setting with a custom converter function.

NewClusterMetadataLoader creates a new [ClusterMetadataLoader] that loads cluster metadata from the database.

NewClusterMetadataPersistenceRetryableClient creates a ClusterMetadataManager client to manage cluster metadata

NewConditionalRetryPolicy returns a policy that delegates to whenTrue when predicate(err) is true, and whenFalse otherwise.

NewConfig builds the new Config for worker service

NewDLQMessageHandler returns a DLQMessageHandler instance

NewDLQWriterAdapter creates a new DLQWriter from a QueueV2 [queues.DLQWriter].

NewDefaultHandoverTrackerFactory returns a factory that creates the default OSS HandoverTracker.

NewDefaultIncomingRateLimiter returns a default rate limiter for incoming traffic, using fixed burst ratio of 2 and fixed 1 minute refresh interval

NewDestinationTypedSettingWithConstrainedDefault creates a setting with a compound default value.

NewDestinationTypedSettingWithConverter creates a setting with a custom converter function.

Helper methods for creating tls.Config structs to ensure MinVersion is 1.3

var _ BatchableTask = (*ExecutableSyncHSMTask)(nil)

TODO should workflow task be batched?

NewExecutionPersistenceRetryableClient creates a client to manage executions

NewFactory returns an instance of a factory object which can be used to create data stores that are backed by cassandra

NewFallibleOnceMap creates a [FallibleOnceMap] from a given construct function. construct should be kept light as it is called while holding a lock on

NewGlobalNamespaceRateLimiter creates a namespace-aware rate limiter that uses only a global quota with no per-instance fallback.

NewGlobalTypedSettingWithConstrainedDefault creates a setting with a compound default value.

NewHandlerTestSuite returns a test suite

NewHealthSignalAggregator creates a new instance of HealthSignalAggregatorImpl

NewHistoryIterator returns a new HistoryIterator

NewHistoryTaskQueueManager returns a new manager for history task queues

NewImmediateBackfiller returns an intialized Backfiller component, which should be parented under a Scheduler root node.

NewInternalErrorWithDPanic is a wrapper for service error that will panic if it's in dev environment

NewJSONSizeEstimator returns a new SizeEstimator which uses json encoding to estimate size

NewMetadataPersistenceRetryableClient creates a MetadataManager client to manage metadata

NewMockBulkProcessor creates a new mock instance.

NewMockClient creates a new mock instance.

NewMockErrorHandler creates a new mock instance.

NewMockEventImporter creates a new mock instance.

NewMockExecutableTaskTracker creates a new mock instance.

NewMockHistoryArchiver creates a new mock instance.

NewMockHistoryTaskQueueManager creates a new mock instance.

NewMockJWTAudienceMapper creates a new mock instance.

NewMockMapper creates a new mock instance.

NewMockObjectIteratorWrapper creates a new mock instance.

NewMockPersistence creates a new mock instance.

NewMockQueue creates a new mock instance.

NewMockQueueV2 creates a new mock instance.

NewMockS3API creates a new mock instance.

NewMockShardManager creates a new mock instance.

NewMockStreamReceiver creates a new mock instance.

NewMockSyncStateRetriever creates a new mock instance.

NewMockTaskExecutor creates a new mock instance.

NewMockVisibilityArchiver creates a new mock instance.

NewMockWorkflowResetter creates a new mock instance.

NewMockWriterWrapper creates a new mock instance.

NewMocktaskQueuePartitionManager creates a new mock instance.

NewMocktaskValidator creates a new mock instance.

NewNamespaceIDTypedSettingWithConstrainedDefault creates a setting with a compound default value.

NewNamespaceIDTypedSettingWithConverter creates a setting with a custom converter function.

NewNamespaceReplicationQueue returns a new queue for namespace replication

NewNamespaceTypedSettingWithConstrainedDefault creates a setting with a compound default value.

NewNexusEndpointManager returns a new manager for nexus endpoints

NewNexusEndpointPersistenceRetryableClient creates a NexusEndpointManager client to manage nexus endpoints

NewNoopAuthorizer creates a no-op authorizer

NewNoopClient returns a Client that has no keys (a Collection using it will always return default values).