GetMySQLAddress return the cassandra address

GetMySQLPort return the MySQL port

Returns the earliest time that matches the schedule spec that is after the given time. Returns: Nominal is the time that matches, pre-jitter. Next is

GetShardIDForTask computes the shardID for a given task using the task's namespace, workflow ID and the number of history shards in the cluster.

GetTaskQueueTasks returns tasks from task queue.

HasRequestID checks whether the given requestID has already been recorded for this workflow execution. Used by AttachCallbacks to deduplicate callback

IsShutdown return true if already shutdown

TODO https://github.com/temporalio/temporal/issues/1021 there should be more validation logic here 1. if task has valid TTL -> TTL reached -> delet

MergeStats merges from into into. Mutates into.

MustGetNamespaceName returns request namespace name or EmptyName if there's error when retrieving namespace name, e.g. unable to find namespace

MustRegisterOperation registers a named operation and panics if registration fails.

Nack marks the task as unsuccessful completed

NewHistoryEventMatrixMatcher creates a gomock Matcher for [][]*historypb.HistoryEvent

NewMapCounter creates a mapCounter that also tracks the top K entries.

NewMockMetadataManager creates a new mock instance.

NewMockQueryParser creates a new mock instance.

NewSearchAttributeBool creates a new boolean search attribute given a predefined chasm field

NewSearchAttributeInt creates a new integer search attribute given a predefined chasm field

PartialOverrideValue is like OverrideValue but marks the override as mergeable.

PollWorkflowTask creates a workflow task poller that uses the given PollWorkflowTaskQueueRequest.

RegisterEventDefinition registers an [EventDefinition] for the given event type. Returns an [ErrDuplicateRegistration] if a definition for the type ha

ScheduleID returns tag for ScheduleID

SetEventsCacheForTesting sets s.eventsCache. Only used by tests.

SetVersion sets the event version

SuggestContinueAsNew returns true if the Registry is reaching its limit. Note that this does not apply to in-flight limits, as these are transient.

TemporalFailureToNexusFailure converts an API proto Failure to a Nexus SDK Failure setting the metadata "type" field to the proto fullname of the temp

TryResurrect tries to resurrect the Update from the protocol message, whose body contains an Acceptance or Rejection message. It returns an error if s

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

Unwrap returns the wrapped error to support errors.As() and errors.Is()

UpdatedTransitionHistory takes a slice of transition history and returns a new slice that includes the max state transition count for the given versio