routingIDFromResourceID extracts the routing ID from a resource_id field value. The resource_id field has the format "prefix:<routingID>".

scheduleOperation is a helper that schedules a nexus operation via the command handler and returns the scheduled event and its scheduled event ID (use

timerCmd builds a StartTimerCommand with the given id and StartToFireTimeout.

DeserializeComponentRef deserializes a byte slice into a ComponentRef. Provides caller the access to information including ExecutionKey, Archetype, an

Dirty returns true if any of the tree's state machines have transitioned.

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

Returns a new failure type tag

FakeStruct generates random data for the given struct pointer. Example usage: var shardInfo persistencespb.ShardInfo _ = fakedata.FakeStruct(&shard

GenerateDeploymentWorkflowID is a helper that generates a system accepted workflowID which are used in our Worker Deployment workflows

Get returns the cached routing info. ok=false means there was no cached value.

GetAllNamespaces returns a snapshot of every namespace currently in the in-memory cache. May lag persistence by up to the configured refresh interval;

Deprecated: Marked as deprecated in temporal/server/api/deployment/v1/message.proto.

NewEventReappliedID returns EventReappliedID resource

NewHandle creates a *Handle that serves as a handle to a goroutine. The caller should call Go exactly once on the returned value. NewHandle and Go are

NewNameTypeMap creates a new NameTypeMap with the given custom search attributes.

NewRegistrableSideEffectTask creates a new registrable side-effect task. NOTE: C is not Component but any. The handler's Discard method is called on s

Shutdown broadcast shutdown signal

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

WithBackoffCoefficient sets the coefficient used by ExponentialRetryPolicy to compute next delay for each retry All retries are computed using the fol

defaultSchedule returns a protobuf definition for a schedule matching this package's other testing defaults.

getMetadataContext extracts metadata context from golang context.

invokeWithPartitionCounts wraps a partition-aware matchingservice RPC call: - attaches the client's cached counts to the outgoing request (as header)

tag maps the drop reason to its tasks_dropped `reason` metric tag.

Complete an async Nexus Operation using a CHASM reference. The completion state could be successful, failed, or canceled.

CompleteTasksLessThan completes tasks less than or equal to the given task id This API takes a limit parameter which specifies the count of maxRows th

CreateHistoryClientRetryPolicy creates a retry policy for calls to history service. When retryUnboundedOnSystemResourceExhausted returns true, system-

CustomMemo returns the stored custom memo fields. Nil is returned if there are none. Returned map is a shallow copy: callers may add, delete, or reas

CustomSearchAttributes returns the stored custom search attribute fields. Nil is returned if there are none. Returned map is a shallow copy: callers

Encode encodes map of search attribute values to search attributes. typeMap can be nil (then MetadataType field won't be set). In case of error, it wi

GetEffectiveDeployment returns the effective deployment in the following order: 1. DeploymentVersionTransition.Deployment: this is returned when the w

GetNamespaceReplicationMessages returns new namespace replication tasks since last retrieved task Id.