MigrateSchedule migrates a schedule between V1 (workflow-backed) and V2 (CHASM-backed) implementations.

NewCollection creates a new collection. For subscriptions to work, you must call Start/Stop. Get will work without Start/Stop.

NewLRU creates a new LRU cache of the given size, setting initial capacity to the max size

Refresh refreshes all tasks needed for the state machine to make progress or those have side effects.

RequestID returns tag for RequestID

Reserve returns a Reservation that indicates how long the caller must wait before event happen.

Size gets the estimated size in bytes of this predicate. Implementation may keep this estimate rough and mostly account for elements that may take up

WithExpected marks retained objects whose reflected path or type name matches pattern as expected. A trailing '*' matches any suffix.

hasEventType returns true if any event in the slice has the given type.

newTestEnv creates a TestEnv with the dynamic config this suite needs and registers the workflows/activities the tests use.

AllowN attempts to allow a request to go through. The method returns immediately with a true or false indicating if the request can make progress

AppendRawHistoryNodes add a node of raw histories to history node table

nolint:revive

Close closes the factory

CreateHistoryStartWorkflowRequest create a start workflow request for history. Assumes startRequest is valid. See frontend workflow_handler for detail

EXPECT returns an object that allows the caller to indicate expected use.

FailNow is called by require.* on failure. It stops the current attempt. Unlike testing.TB.FailNow(), this does NOT mark the test as failed.

FilterSlice iterates over elements of a slice, returning a new slice of all elements predicate returns true for.

Immediate returns an effects.Controller that executes effects immediately upon insertion. Useful in contexts where you don't actually want to delay ef

IsNotFoundError checks if the error is a not found error.

IsVersionFromSameCluster return true if 2 version are used for the same cluster

NewDeserializationError returns a DeserializationError

NewZapLogger returns a new zap based logger from zap.Logger

ProtoReflect implements [protoreflect.ProtoMessage].

QueryWithAnyNamespaceDivision returns a modified workflow visibility query that disables special handling of namespace division and so matches workflo

ReadComponent returns the result of evaluating readFn against the component identified by the component reference. opts are currently ignored.

Context is not bound to any component, so all methods needs to take in component as a parameter NOTE: component created in the current transaction won

Register registers all command handlers and event definitions from a [Library]. Returns an [ErrDuplicateRegistration] if a handler or definition is al

SetCallerType set caller type in the context. Existing caller type will be overwritten if exists and new caller type is not empty.

Timestamp returns tag for Timestamp

UnaliasFields returns SearchAttributes struct where each search attribute alias is replaced with field name.

WatchNamespaces returns a channel that receives events when namespaces are created, updated, or deleted. It returns an error if the watch cannot be st

all calls to addFault should be done before starting to call methods on testTaskManager

getScheduleEntryFromVisibility polls visibility using ListSchedules until it finds a schedule with the given id and for which the optional predicate f