CountTasksForWorkflow returns the count of tasks in a category for a specific workflow If namespaceID is empty, it matches any namespace If runID is e

DatabaseName from PersistenceTestCluster interface

Delay returns the duration for which the reservation holder must wait before taking the reserved action. Zero duration means act immediately.

DeleteActivity deletes details about an activity.

DeleteFromActivityInfoMaps deletes one or more row from activity_info_maps table

DeleteFromChildExecutionInfoMaps deletes one or more rows from child_execution_info_maps table

DeleteFromMap deletes k2 from the nested map m[k]. If the inner map becomes empty after deletion, k is also removed from m to prevent memory leaks.

DeleteNamespace deletes a single row. One of ID or Name MUST be specified

DeleteFromRequestCancelInfoMaps deletes one or more rows from request_cancel_info_maps table

DeleteFromSignalInfoMaps deletes one or more rows from signal_info_maps table

DeleteFromSignalsRequestedSets deletes one or more rows from signals_requested_sets table

DeleteFromTimerInfoMaps deletes one or more rows from timer_info_maps table

Deregister removes a callback from the finalizer. Returns an error if the ID is not found, or when the finalizer is/was already running.

Discard implements custom discard behavior on standby clusters. When a side-effect task has been pending on standby past the discard delay, the framew

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.

EmitDataLossMetric emits a data loss metric for DataLoss errors

Encode protobuf struct to bytes.

EnsureDefaults ensures the policy subfields, if not explicitly set, are set to the specified defaults

Exec executes a sql statement

FindAssignmentBuildId finds a build ID for the given runId based on the given rules. Non-empty runId is deterministically mapped to a ramp threshold,

FindLCAVersionHistoryItemAndIndex finds the lowest common ancestor VersionHistory index and corresponding item.

FindTargetDeploymentVersionAndRevisionNumberForWorkflowID returns the deployment version and revision number (if applicable) for the particular workfl

This should only be used in unit tests. For normal code, use the *GRPCResolver provided by fx. Monitor may be nil if it's not needed, but then note th

Generate tasks for any updated state machines on mutable state. Looks up machine definition in the provided registry. Must be called **after** updatin

GetExecutionInfo mocks base method.

GetMessagesFromNamespaceDLQ is a utility method to get messages from the namespace DLQ

GetNonRetryableErrorOption returns an ArchiveOption so that archiver knows what should be returned when an non-retryable error is encountered.

GetOrSetMap looks up k in m, a two-level map, and returns the result. If it's not present, it uses `make` to allocate new second-level map and sets th

GetPerTaskQueueScope returns GetPerTaskQueueFamilyScope plus the "task_type" tag.

GetPersistenceTestDefaults returns the default persistence options based on CLI flags. Use this when creating TestClusterConfig to ensure proper datab

GetPrincipal retrieves the principal from the context headers. Returns nil if principal is not set.