NoError asserts that err is nil. Deprecated: use require.NoError with the parent test or suite instead. TODO: remove once all tests are migrated to T

----------- Generic methods ------------

New will be called for a new root partition. It should return a new PartitionScaler (or nil to disable).

EXPECT returns a MetadataMockRecorder which can be used to set expectations on the mock.

T returns the *testing.T. Deprecated: use the suite's T() method instead.

Run and handle errors, abort on context error.

Errorf records an error message for reporting on timeout.

Record updates the gauge value. Tags provided are merged with the source MetricsHandler

Len return the size of the queue

Wall clock. Backed by a the shard's time source.

Error returns tag for Error

Add task executable to the rescheduler.

SdkClient returns the SDK client. It is lazily initialized on the first call.

Size returns current size of the Cache, the size definition is implementation of SizeGetter interface for the entry size, if the entry does not implem

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

Contains returns true if the key exist and false otherwise

Deprecated: Require bypasses the guard mechanism. Use s.NoError, s.Equal, etc. directly.

Get retrieves an element based on a key, returning nil if the element does not exist

TODO (alex): move this to functional_test_base.go as methods.

Now returns the current time in the context of the given component. In a context of a transaction, this time must be used to allow for framework suppo

Add push an item to the queue

NewTestLogger returns a logger for tests Deprecated: Use testlogger.TestLogger instead.

WorkflowID returns the Workflow ID given as part of the request spec. During start generation, nominal time is suffixed to this ID.

NewEnv creates a new test environment with access to a Temporal cluster.

WorkflowRunID returns tag for WorkflowRunID TODO: Rename to RunID

Done exposes a channel that allows outside goroutines to block on this goroutine's completion. Whatever time passes between a call to Cancel() and the

Key represents the key

ThrottleRetryContext is a context and resource aware version of Retry. Context timeout/cancellation errors are never retried, regardless of IsRetryabl

NewWorkflowKey create a new WorkflowKey

WithDynamicConfig overrides a dynamic config setting for the test. For settings that can be namespace-scoped, a namespace constraint is applied. For a

Len returns the total number of task executables waiting to be rescheduled.

Sleep is a convenience function for waiting on a new timer.

WithTags creates a new Handler with provided Tag list. Tags are merged with registered Tags from the source Handler.

ID return the ID of the queue, as well as the tasks inside (same)

WorkflowID returns tag for WorkflowID TODO: Rename to BusinessID.

NewContext creates a context with default timeout and RPC headers. NOTE: If you're using testcore.NewEnv, you can use env.Context() directly - it alr

NewUUID generates a new random UUID

Unlock unlocks

Lock locks

DeploymentVersionString returns v31 string

NewNoopLogger return a noopLogger

GetCurrentClusterName return the current cluster name

convertError is a helper method to convert ShardOwnershipLostError from persistence layer returned by various HistoryEngine API calls to ShardOwnershi