List returns all nodes in this collection.

ListClusters returns information about Temporal clusters.

ListWorkflow mocks base method.

MarkUnbatchable will mark current task not batchable, so CanBatch() will return false

Markdown renders the GitHub step summary HTML and enforces both the total summary budget and per-row detail truncation.

Marshal an object of type ChasmComponentRef to the protobuf v3 wire format

MatchingDispatchResponseToError converts a DispatchNexusTaskResponse proto into a Go error. Returns nil if the response indicates success. For failur

MergeNameTypeMaps merges two NameTypeMap. The first NameTypeMap is used as base, and the second NameTypeMap is added to the first map, ie., in case of

MustRegisterServiceProcessor registers the service processor and panics if registration fails.

Name returns tag for Name

NamespaceEntry returns the namespace entry for the execution.

NamespaceStateTag returns a new namespace state tag.

NewListener returns a net.Listener which uses the given Pipe to simulate a network connection.

NewMetadataMock returns a new MetadataMock which uses the provided controller to create a MockArchivalMetadata instance.

NewMockCache creates a new mock instance.

NewMockDeleteManager creates a new mock instance.

NewMockExecutableTask creates a new mock instance.

NewMockQueryParser creates a new mock instance.

NewPriorityRateLimiter returns a new rate limiter that can handle dynamic configuration updates

NewRoutingKeyInterceptor creates a new RoutingKeyInterceptor with the given extractor functions. Extractors are called in order until one returns a no

Notify notifies all subscribers subscribed to key by closing the channel.

NumTimers returns the number of outstanding timers.

OperatorService mocks base method.

RangeSelectFromReplicationTasks returns one or more rows from replication_tasks table

RangeSelectFromTimerTasks returns one or more rows from timer_tasks table

RangeSelectFromTransferTasks returns rows that match filter criteria from transfer_tasks table.

RangeSelectFromVisibilityTasks returns rows that match filter criteria from visibility_tasks table.

ReadHistoryBranchReverse returns history node data for a branch

RegisterNexusService mocks base method.

RegisterTimerExecutor registers a [TimerExecutor] for the given task type. Returns an [ErrDuplicateRegistration] if an executor for the type has alrea

RenewLease renews the lease on a taskqueue. If there is no previous lease, this method will attempt to steal taskqueue from current owner

RepeatSlice given slice and a number (n) produces a new slice containing original slice n times if n is non-positive will produce nil

Reschedule triggers an immediate reschedule for provided namespace ignoring executable's reschedule time. Used by namespace failover logic

SelectFromTaskQueues returns one or more rows from task_queues table Required Filter params: to read a single row: {shardID, namespaceID, name, taskTy

Sends a greeting

ServerName returns tag for ServerName

SetOrigin set call origin in the context. Existing call origin will be overwritten if exists and new call origin is not empty.

SetRateBurst sets the rps & burst of the rate limiter

SetUserMetadata replaces the user metadata attached to the given component.

SetVersionHistoryBranchToken sets the branch token.

Stringify converts search attributes to map of strings using (in order): 1. type from MetadataType field, 2. type from typeMap (can be nil). In case o

Subscribe returns a channel that will be closed when there is a notification relating to the execution, along with an unsubscribe function. No data wi

TaskCreationTime mocks base method.

TaskVisibilityTimestamp returns tag for task visibilityTimestamp

UTC returns a Time from a Clock in millisecond resolution. The Time's Location is set to UTC.

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

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

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