NewMockTask creates a new mock instance.

TaskID mocks base method.

Test checks if the given entity statisfy the predicate or not

cmdsResponse wraps a list of commands in a RespondWorkflowTaskCompletedRequest.

Low-level mock helpers:

Delete deletes an element in the cache

ExternalWorkerDeploymentVersionFromDeployment Temporary helper function to convert Deployment to WorkerDeploymentVersion proto until we update code to

NewArchivalConfig constructs a new valid ArchivalConfig

ReadRawHistoryBranch returns history node raw data for a branch ByBatch NOTE: this API should only be used by 3+DC

listVersioningRules lists rules and checks that the result is successful, returning the response.

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

ErrorToFailure converts an [error] to a [Failure]. Note that the provided error may be nil.

GetWorkflowType returns the type of the workflow that owns this state machine tree.

NewMockTrackableExecutableTask creates a new mock instance.

RequireHistoryEvent returns the single event matching the given event type. It fails the test if no matching event is found or if more than one is fou

RequireTrue runs `condition` repeatedly until it returns true, or until the timeout expires. The timeout is capped at the test's deadline, if one is s

TODO (alex): change to nsName namespace.Name

TerminateWorkflow mocks base method.

ValidateAndCapProtoDuration validates protobuf durations for two conditions: 1. the seconds and nanos fields have the same sign (to avoid serializatio

addNewDefaultBuildID updates build ID info on a task queue with a new build ID in a new default set.

newTestEnv creates a TestEnv with the dynamic config this suite needs. Additional per-test options may be passed in opts.

waitForVersionSetPropagation waits for all partitions of tq to mention newBuildID in their versioning data (in any position).

DecodeValue decodes search attribute value from Payload using (in order): 1. passed type t. 2. type from MetadataType field, if t is not specified. al

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

For returns the test-scoped context for tb. The context is canceled when the test ends or when the configured test timeout expires. The first call cr

InterruptibleSleep is like time.Sleep but can be interrupted by a context. Returns context error if interrupted, otherwise nil.

MutableContext returns a new mutable CHASM context.

NewMockHistoryIterator creates a new mock instance.

Now return the current time.

Adds a subscription to all updates from this Client. `update` will be called on any change to the current value set. The caller should call `cancel` t

WorkflowService mocks base method.

set sets a bit, growing the slice if necessary. note: caller must assign the result, as with append.

CloseTransactionAsSnapshot closes the mutable state transaction (different from DB transaction) and prepares the current snapshot of the state to be p