DescribeVersionedTaskQueues returns details about the requested versioned task queues. It is an internal API; there is no direct user-facing equivalen

DescribeWorker retrieves a worker information in the specified namespace that match the provided instance key. Returns an error if the namespace or wo

DescribeWorkflowExecution returns information about the specified workflow execution.

NOTE: DO NOT MODIFY UNLESS ALSO APPLIED TO ./service/frontend/token_deprecated.go

NOTE: DO NOT MODIFY UNLESS ALSO APPLIED TO ./service/frontend/token_deprecated.go

DetailInfo returns tag for DetailInfo

DisableEagerActivityDispatchForBuggyClients compensates for SDK versions that have buggy implementations of eager activity dispatch

Request from frontend to synchronously dispatch a nexus task to a worker.

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

Encode HistoryEvent slice to bytes.

EngineContext returns a context with a mock engine. Requires withMockEngine().

EnqueueMessage adds a message to the back of the queue.

Ensures that the chasm workflow component is installed in the mutable state CHASM tree. Must be called before adding any components to the tree.

Helper function to create the matcher

Equal returns whether two Clocks are equal

EvictSelf evicts this member from the membership ring. After this method is called, other members will discover that this node is no longer part of th

ExecuteMultiOperation executes multiple operations within a single workflow.

ExecutionStateChanged returns true if execution state has advanced beyond the state encoded in refBytes. It may return ErrInvalidComponentRef or ErrMa

ExpectReadComponent sets up mock expectations for reading a component.

ExpectUpdateComponent sets up mock expectations for updating a component.

ExtractReplicationMessages extracts WorkflowReplicationMessages from a proto message. This is a helper for tests that need to inspect replication mess

FailOnError overrides the behavior of this logger. It returns the previous value so that it can be restored later.

FailureError returns failure or error which will be set on Update futures while aborting Update. Only one of the return values will be non-nil.

FindAutoResetPoint returns the auto reset point

FinishedDraining is called by a draining backlog manager when it has fully drained.

Force loading a task queue partition. Used by matching node owning root partition. When root partition is loaded this is called for all child partitio

TODO Shivam - remove this in 123. Present for backwards compatibility.

Force unloading a task queue partition.

FormatMessageForDebug formats the message for console output

ForwardPollWithTarget forwards a poll request to another partition

Gauge implements [metrics.Handler.Gauge].

GenerateLastHistoryReplicationTasks generate a replication task for last history event for requested workflow execution

GenerateNexusCallback builds a Nexus completion callback targeting the CHASM component identified by serializedRef (obtained from Context.Ref). When e

GenerateRecordActivityTaskStartedResponse generates the response for HandleStarted.

GenerateRequestID generates a deterministic request ID for a buffered action's time. The request ID is deterministic because the jittered actual time

GenerateStartedEventRefLink builds a Link pointing to the WORKFLOW_EXECUTION_STARTED event. Use this for backlinks to workflow start: the started even

GetActivityByActivityID gives details about an activity that is currently in progress.

GetAllClustersIter returns an iterator that can be used to iterate over all clusters in the metadata store.

GetAndDo returns the value corresponding to the key, and apply fn to key value before return value return (value, value exist or not, error when evalu

GetAndDo returns the value corresponding to the key, and apply fn to key value before return value return (value, value exist or not, error when evalu

GetAndResetSDKInfo gets all recorded name, version tuples and resets internal records

GetAudienceMapperFromConfig returns a JWTAudienceMapper based on the provided Authorization config. Currently, it returns a static audience mapper usi

GetBackoffForNextScheduleNonNegative calculates the backoff time and ensures a non-negative duration.