getModuleDependencies returns an fx.Option that provides all the dependencies needed for the queue module.

getMonitor returns a membership monitor

getMutableStateInfo gets the relevant mutable state information while getting the state for the given run from the workflow cache and managing the cac

getOrCreateLastHeartbeat retrieves the last heartbeat state, initializing it if not present. The heartbeat is lazily created to avoid unnecessary writ

getOrCreateNode traverses/creates path and returns the final node.

getOrCreateSchedulerForTask gets an existing scheduler for the given key or creates one if needed.

getQueueMutex returns a per-queue mutex, creating it if it doesn't exist. This provides process-level locking to serialize concurrent writes to the sa

getRateLimiterPermission returns a delay for which the caller should wait before proceeding. If an error is returned, execution should not proceed, an

Convert from api.Access to Role

Note: may modify workflowExecution.RunId

getSourcesForTarget gets the first-degree sources for any redirect rule targeting buildId

Check if remote cluster has caught up on all shards on replication tasks from target replica.

TODO(pri): old matcher cleanup: move here type getTasksBatchResponse struct { tasks []*persistencespb.AllocatedTaskInfo readLevel in

getTaskQueueDeploymentData gets the deployment data for a given TQ type. The data is always returned from the WF type root partition, so no need to wa

Get the reachability of a single build ID in a single task queue scope.

nolint:revive // can improve this later

nolint:revive // can simplify later

TODO (alex): remove this func.

getValidatedMutableState loads mutable state and validates it with the given function. validate must not mutate the state.