Take the shard lock and update queue metrics

Returns true if execution is forced terminated

Returns true if execution is forced terminated TODO: ideally this check should be after closing mutable state tx, but that would require a large refac

nolint:revive // cognitive complexity 26 (> max enabled 25)

evictByCapacity removes entries older than MinEvictAge until under capacity.

evictByTTL removes expired entries across all buckets.

evictLoop periodically triggers TTL and capacity-based eviction.

Returns true if any exclude spec matches the time.

executeAndTrackAsyncPropagation monitors propagation and signals completion

TODO: change this function to process all available tasks in the queue.

executeTimeSkippingTimerTask fires when the fast-forward is hit. It emits the disable transition directly so the fast-forward is honored even if the w

executeTimeSkippingTimerTask waits on the standby until the active cluster replicates the fast-forward transition. If the fast-forward this task was g

executeTimer invokes a [TimerExecutor].

executeUntilBufferEmpty execute tasks starting from the given task using the provided limiter. Continues as long as it has tasks to dequeue.