getResponse waits for a response on the task's response channel.

initiatedChildEvents returns every StartChildWorkflowExecutionInitiated event in the given parent's history in order. Used to assert the TimeSkippingC

isBacklogNegligible returns true of the age of backlog is less than the threshold. Note that this relies on MustOffer being called when there is a bac

isCyclic returns true if there is a cycle in the DAG of redirect rules.

isDrained returns true if this subqueue has been fully drained: - We've read to the end of the queue (readLevel >= maxReadLevel) - No tasks are outsta

logInternalError emits a log statement for internalMsg, tagged with both internalErr and a reference-id. An opaque error containing the reference-id i

* TODO(pri): rewrite or delete this test func TestReaderSignaling(t *testing.T) { readerNotifications := make(chan struct{}, 1) clearNotifications :

Parses the string into a Range. Accepts strings of the form: - * matches always - x matches when the field equals x - x-z matches

Merge and sort two sets of set IDs

newBuilderWithMaxBatchBytes constructs a fresh HistoryBuilder using the suite's task/time fixtures with MaximumEventBatchSizeInBytes overridden.

Helper to create interceptor with cross-namespace commands enabled

newDB returns an instance of DB, which is a logical connection to the underlying sqlite database

newDialTracer creates a dial tracer that logs errors during dial and produces metrics for different stages of the dial process (Connect)

newExecutionQueueScheduler creates a new executionQueueScheduler.

TODO(pri): old matcher cleanup, move to here var errInvalidTaskQueueType = errors.New("unrecognized task queue type") newPriForwarder returns an insta

newRealSpecProcessor creates a real SpecProcessor for tests.

newReplicationTaskFetcher creates a new fetcher.

newTLSEnv generates a self-signed cert chain for 127.0.0.1 and returns the matching server option and client-side TLSConfigProvider. Both halves trust

newTaskQueueDB returns an instance of an object that represents persistence view of a physical task queue. All mutations / reads to queues wrt persist

newTestHandler creates a Handler wired with the given capture handler, a stub engine, and a mock namespace registry that returns a fixed name.

onTimedOut applies the timed out transition or delegates to the store if one is present.