SDKDeploymentVersion returns SDK worker deployment version

Update the fake current time. It returns the timeSource so that you can chain calls like this: timeSource := NewEventTimeSource().Update(time.Now())

test helpers

waitRecv blocks until ch yields a value, failing the test on timeout.

Child recursively gets a child for the given path.

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

FailNow does not forward to the underlying tests, since we do not know what test we are targetting or what goroutine we are calling FailNow from.

NewHistoryEventVertex initials a history event vertex

SetDataFunc sets the data generation function

UpdateVersionSets updates version sets given existing versioning data and an update request. The request is expected to have already been validated.

Value returns tag for Value

WithMaximumAttempts sets the maximum number of retry attempts

CancelAt indicates that the reservation holder will not perform the reserved action and reverses the effects of this Reservation on the rate limit as

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

FireCh return the channel which will be fired when time is up

options must include Namespace and should not include: HostPort, ConnectionOptions, MetricsHandler, or Logger (they will be overwritten)

NewMockHandler creates a new mock instance.

PutIfNotExist puts a value associated with a given key if it does not exist

Registers callback for namespace state changes. StateChangeCallbackFn will be invoked for a new/deleted namespace or namespace that has State, Replica

Stop stops the executor

AddOrUpdateVersionHistoryItem updates the VersionHistory with new VersionHistoryItem.

Jitter return random number from (1-coefficient)*input to (1+coefficient)*input, inclusive, exclusive

NewMockTask creates a new mock instance.

NewSQLiteFileConfig returns a new SQLite config for test

NewSQLiteMemoryConfig returns a new SQLite config for test

Returns a new service role tag.

history event ID related WorkflowEventID returns tag for WorkflowEventID

Returns taskQueuePartitionManager for a task queue. If not already cached, and create is true, tries to get new range from DB and create one. This blo

ArchivalArchiveFailReason returns tag for ArchivalArchiveFailReason

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

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

NewMockVisibilityManager creates a new mock instance.

Cancel marks the task as cancelled, usually by the task submitter

TODO: Return a iterator on node name instead of []string, so that we can get a node by encoded path without additional allocation for the decoded path

FindOrCreate finds an existing Update or creates a new one. The second return value (bool) indicates whether the Update returned already existed and w

Identity returns the unique identifier of the host. This may be the same as the address.

IsContextDeadlineExceededErr checks if the error is context.DeadlineExceeded or serviceerror.DeadlineExceeded error