Struct TransactionToolCapacity 

pub struct TransactionToolCapacity { /* private fields */ }

Per-transaction tool capacity tracker (item queue + concurrency + per-tool).

Implementations

impl TransactionToolCapacity

pub fn new( shared: Arc<SharedToolCapacity>, max_concurrent: usize, max_queued: usize, ) -> Arc<Self>

Build for one transaction.

pub fn configure_tool(self: &Arc<Self>, tool_id: ToolId, max_concurrent: usize)

Register per-tool max concurrency from a resolved set.

pub fn try_enqueue(self: &Arc<Self>) -> bool

Reserve a queue slot before validation work (released on failure or after acquire).

pub fn dequeue(self: &Arc<Self>)

Drop a prior queue reservation without starting.

pub fn try_acquire(self: &Arc<Self>, tool_id: &ToolId) -> Option<ToolPermit>

Move from queued to running if capacity allows.

pub fn active(&self) -> usize

Active executions in this transaction.

pub fn queued(&self) -> usize

Queued starts waiting for concurrency.

Trait Implementations

impl Debug for TransactionToolCapacity

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.