newRunQueue returns an instance of task run queue

newScheduledQueue creates a new scheduled queue for the given shard with archival-specific configurations.

============================================================================= Helper Functions =======================================================

newShardPersistence creates an instance of ShardManager

newSharedTLSProvider generates one cert chain for 127.0.0.1 and returns a TLS provider usable as both server and client by every cluster in the suite.

newStatsdScope returns a new statsd scope with a default reporting interval of a second

newStoreFaultInjector returns a new instance of a data store fault injector that will inject errors into the persistence layer based on the provided c

newTask returns a new instance of an executable task which will process a single mutableState

newTask returns a new instance of an executable task which will process a single task queue

newTaskGC returns an instance of a task garbage collector object taskGC internally maintains a delete cursor and attempts to delete a batch of tasks e

newTelemetryClusterMetadataStore returns telemetryClusterMetadataStore.

newTelemetryExecutionStore returns telemetryExecutionStore.

newTelemetryMetadataStore returns telemetryMetadataStore.

newTelemetryNexusEndpointStore returns telemetryNexusEndpointStore.

newTelemetryQueue returns telemetryQueue.

newTelemetryQueueV2 returns telemetryQueueV2.

newTelemetryShardStore returns telemetryShardStore.

newThreadSafeList returns a new thread safe linked list

nextBackoffDeadline returns the earliest BackoffTime among starts that are retrying, or the zero time if none are.

Returns the next matching time for a single interval spec.

nextTask returns the next task to be submitted from this page

nexusContextFromEndpoint returns the nexus context for the given request and a boolean indicating whether the endpoint is valid for dispatching. For s

notify closes all subscriber channels for key, waking any blocked PollComponent callers.

notifyQueueProcessor sends notification to all queue processors for triggering a load NOTE: this method assumes engineFuture is already in a ready sta

onAcceptanceMsg expects the Update to be in stateSent (or stateAdmitted) and returns an error if it finds otherwise. An event is written to the provid