[cleanup-wv-pre-release]

ProtoEqual compares two proto messages for equality using proto semantics. Options can be passed to customize comparison behavior, e.g. protorequire.I

Invoke executes the callback logic and returns the invocation result.

Fail marks the current attempt as failed without stopping it.

Error observes the error returned by the func passed to Go (if any). There is never any error (i.e. this function returns nil) while the goroutine is

CapturePanic is used to capture panic, it will log the panic and also return the error through pointer. If the panic value is not error then a default

namespace related WorkflowNamespaceID returns tag for WorkflowNamespaceID TODO: Rename to NamespaceID

Next returns the next item and error

RegisterWorkflowWithOptions mocks base method.

NamespaceTag returns a new namespace tag. For timers, this also ensures that we dual emit the metric with the all tag. If a blank namespace is provide

Apply a history event to the state machine. Triggered during replication and workflow reset.

Counter obtains a counter for the given name.

Close the factory

NewVersionHistoryItem create a new instance of VersionHistoryItem.

SdkWorker returns the SDK worker. It is lazily initialized on the first call.

Add request to bulk processor.

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

RegisterWorkflow registers Workflow types provided by this worker component. Local Activities should also be registered here because they are executed

Await calls fn repeatedly until all assertions pass or timeout is reached.

WorkerTaskQueue returns the task queue name used by the SDK Worker.

Unmarshal an object of type RoutingOptions from the protobuf v3 wire format

Wait waits till the deadline for a rate limit token to allow the request to go through.

Shorter helpers (aliases for the New* functions above)

ExecuteActivity mocks base method.

Add push a task to the task set

RegisterActivity mocks base method.

GetAllClusterInfo return the all cluster name -> corresponding info

Task type that must be unique per task definition.

CloneProto is a generic typed version of proto.Clone from proto.

StartCapture returns a started capture. StopCapture should be called on complete.

GetMetadata fetches the notification version for Temporal namespaces.

A deadline for firing this task. This represents a lower bound and actual execution may get delayed if the system is overloaded or for various other r

With returns Logger instance that prepend every log entry with tags. If logger implements WithLogger it is used, otherwise every log call will be inte

NewCaptureHandler creates a new [metrics.Handler] that captures.

Clone returns a deep copy of the resolver

GetCallerInfo retrieves caller information from the context if exists. Empty value is returned if any piece of caller information is not specified in

WorkflowNamespace returns tag for WorkflowNamespace

Len observes the number of incomplete (not completed or rejected) Updates in this Registry.

SignalWorkflow mocks base method.

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