Helper functions

startWorker creates a worker on the given task queue, registers wfs, starts it, and schedules cleanup.

Apply invokes the buffered effect functions in the order that they were added to this Buffer. It returns true if any effects were applied.

CheckEventBlobSizeLimit checks if a blob data exceeds limits. It logs a warning if it exceeds warnLimit, and return ErrBlobSizeExceedsLimit if it exce

CopyVersionHistory copies VersionHistory.

DestinationTag is a tag for metrics emitted by outbound task executors for the task's destination.

GetVersionHistoryEventVersion return the corresponding event version of an event ID.

NewContext creates a new Context from an existing Context and root Node. NOTE: Library authors should not invoke this constructor directly, and inste

NewMockBean creates a new mock instance.

NextTransitionCount returns the next state transition count from the state transition history. If state transition history is empty (e.g. when disable

NotificationVersion return the global notification version of when namespace changed

PollAndProcessActivityTask for activity tasks

SetStateMachineRegistry sets the state machine registry on this shard.

UnsafeTaskQueueFamily returns a TaskQueueFamily object without validating the task queue name. This method should only be used in logs/metrics, not in

ValidateURI is used to define what a valid URI for an implementation is.

Wait atomically unlocks user provided lock and suspends execution of the calling goroutine. After later resuming execution, Wait locks c.L before retu

WorkflowScheduledEventID returns tag for WorkflowScheduledEventID

Returns true if the given time matches this calendar spec.

updateTaskQueueDeploymentDataWithRoutingConfig updates the deployment data for the requested TQ types and also waits for the data to propagate to all

AddWorkflowExecutionOptionsUpdatedEvent writes a workflow execution options updated event. This is used to attach completion callbacks, request IDs, l

AwaitTrue calls fn repeatedly until it returns true or timeout is reached. Use it for simple local predicates only. Do not use assertions or side eff

ClusterName returns tag for ClusterName

GetAllHistoryTreeBranches returns all branches of all trees

New creates a new Update instance with the provided ID and set of options.

NewDLQWriter returns a DLQ which will write to the given QueueWriter.

NewDefaultTaskCategoryRegistry creates a new MutableTaskCategoryRegistry with the default categories. The "default" categories here are really the unc

NewMockQueue creates a new mock instance.

PersistenceName returns the unique name for this DB queue to be used in persistence. Unversioned DB use the RPC name of the partition, i.e.: sticky

ReplicationReaderIDFromClusterShardID convert from cluster ID & shard ID to reader ID NOTE: cluster metadata guarantee 1. initial failover version <=

Serve serves the HTTP API and does not return until there is a serve error or GracefulStop completes. Upon graceful stop, this will return nil. If an

SetCallerName set caller name in the context. Existing caller name will be overwritten if exists and new caller name is not empty.

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

WriteFailure writes the given error to the response, converting it to a Failure if possible. It also sets the HTTP status code based on the type of er

pollFromDeployment calls PollWorkflowTaskQueue to start deployment related workflows

AttachCallbacks attaches completion callbacks from a second caller to an update that has already progressed past admission. If the update is accepted,