Find an existing Update in this Registry. Returns nil if Update doesn't exist.

GenerateTypeID generates a unique 32-bit identifier from a fully qualified name (FQN). The generated ID is used to uniquely identify components and ta

IsContextCanceledErr checks if the error is context.Canceled or serviceerror.Canceled error

NewMockExecutionManager creates a new mock instance.

NewMockLogger creates a new mock instance.

NewMockTimerIface creates a new mock instance.

RegisterNamespace is a fake implementation of the RegisterNamespace gRPC method which does nothing.

TrackStateMachineTimer tracks a timer task in the mutable state's StateMachineTimers slice sorted and grouped by deadline. Only a single task for a gi

Unmarshal an object of type NewRunInfo from the protobuf v3 wire format

Registers task as in-flight and moves read level to it. Tasks can be added in increasing order of taskID only.

ActivityID returns tag for an activity ID

Tasks related APIs

AddSearchAttributes add custom search attributes and returns comprehensive information about them. Deprecated. Use operatorservice instead.

AwaitWaitGroup calls Wait on the given wait Returns true if the Wait() call succeeded before the timeout Returns false if the Wait() did not return be

CopyVersionHistoryUntilLCAVersionHistoryItem returns copy of VersionHistory up until LCA item.

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

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

ForkHistoryBranch forks a new branch from a old branch

MaxTime returns the latest of the given time.Time values.

MustGetFreePort returns a TCP port that is available to listen on, for the given (local) host. This works by binding a new TCP socket on port 0, whic

MustParseUUID returns a UUID parsed from the given string representation returns nil if the input is empty string panics if the given input is malform

NewFactory returns an instance of a factory object which can be used to create datastores backed by any kind of SQL store

NewFactory builds a new RPCFactory conforming to the underlying configuration

NewTransition creates a new [Transition] from the given source states to a destination state for a given event. The apply function is called after ver

Now returns the current time.

PollAndHandleActivityTask issues a PollActivityTaskQueueRequest to obtain a new activity task, invokes the handler with the task, and completes/fails

Send returns messages for all Updates that need to be sent to the worker. If includeAlreadySent is set to true, then messages will be created even for

Setup sets up the test base, must be called as part of SetupSuite

========== XDC tags defined here: xdc- ========== SourceCluster returns tag for SourceCluster

Stop is called when the task queue partition manager for the hooks partition is stopped

ToRealTime converts a virtual timestamp from mutable state to wall-clock time, adjusting for accumulated skipped duration which may have happened.

UnexpectedDataLoss creates a serviceerror.DataLoss from a static message and optional error. The error message follows the format "<staticMessage>: <o