ReadHistoryBranch returns history node data for a branch

Require polls condition until it returns without assertion failures, or until ctx is canceled or timeout expires (whichever is earliest). Pass the *a

InternalRepr returns the internal persistence representation of this node. Meant to be used by the framework, **not** by components.

Release decrements the ref count of a pinned element. If the ref count drops to 0, the element can be evicted from the cache.

newTestEnv creates a new test environment with the given options.

ListNamespaces fetches a paged set of namespace persistent state instances.

========== Common tags defined here ========== Operation returns tag for Operation

ParseUUID returns a UUID parsed from the given string representation returns: - nil if the input is empty string - error if input is malformed - UUID

BuildHistoryGarbageCleanupInfo combine the workflow identity information into a string

Compare compares two VersionedTransition structs. Returns -1 if a < b, 0 if a == b, 1 if a > b. A VersionedTransition is considered less than another

GetVersion gets the event version

GetWorkflow mocks base method.

GetWorkflowHistory mocks base method.

Reset changes the expiration time of the timer. It returns true if the timer had been active, false if the timer had expired or been stopped.

WaitLifecycleStage waits until the Update has reached waitStage or a timeout. If the Update reaches waitStage with no timeout, the outcome (if any) is

AddOrUpdateRemoteCluster adds or updates remote cluster.

AddTask adds a task to be emitted as part of the current transaction. The task is associated with the given component and will be invoked via the regi

Archive is used to archive a Workflow's history. When the context expires the method should stop trying to archive. Implementors are free to archive h

CommandTypeTag returns a new command type tag.

NewTaskQueueFamily takes a user-provided task queue name (aka family name) and returns a TaskQueueFamily. Returns an error if name looks like a mangle

Start starts the executor

WorkflowTaskQueueName returns tag for WorkflowTaskQueueName

Signal to trigger a normal WFT

DelayFrom returns the duration for which the reservation holder must wait before taking the reserved action. Zero duration means act immediately.

DescribeCluster returns information about Temporal cluster.

GetAddress returns the socket address of the host (i.e. <ip>:<port>). This must be a valid gRPC address.

Key returns the group key for a given task.

NewMockBatchableTask creates a new mock instance.

StopForTest calls FinishStop(). In general only the controller should call that, but integration tests need to do it also to clean up any background a

Ack marks the task as successful completed

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

GetEffectiveVersioningBehavior returns the effective versioning behavior in the following order: 1. DeploymentVersionTransition: if there is a transit