Struct ConcurrencyController 

pub struct ConcurrencyController { /* private fields */ }

Concurrency controller with fairness policies.

Implementations

impl ConcurrencyController

pub fn new( global_max: usize, quotas: ModeQuotas, fairness: FairnessPolicy, ) -> Self

Create a new concurrency controller with no per-project caps.

pub fn with_project_caps( global_max: usize, quotas: ModeQuotas, fairness: FairnessPolicy, project_caps: HashMap<String, ProjectCaps>, ) -> Self

Create a new concurrency controller with explicit per-project caps.

pub async fn acquire_time_driven(&self, project: &str) -> Option<AgentPermit>

Try to acquire a slot for a time-driven agent in the given project.

pub async fn acquire_issue_driven(&self, project: &str) -> Option<AgentPermit>

Try to acquire a slot for an issue-driven agent in the given project.

pub async fn acquire_mention_driven(&self, project: &str) -> Option<AgentPermit>

Try to acquire a slot for a mention-driven agent in the given project.

pub async fn acquire_any(&self, project: &str) -> Option<AgentPermit>

Try to acquire a generic slot without mode-specific quota checks.

Only enforces the global semaphore and per-project caps. Used when the caller does not know the agent mode (e.g. spawn_agent is shared across cron, mention, and issue-driven paths).

pub async fn running_counts(&self) -> (usize, usize)

Get current running counts (time_driven, issue_driven).

pub async fn project_running_count(&self, project: &str) -> usize

Get the running count for a specific project.

pub fn available_slots(&self) -> usize

Get available slots.

pub fn fairness_policy(&self) -> FairnessPolicy

Get the active fairness policy.

Trait Implementations

impl Clone for ConcurrencyController

fn clone(&self) -> ConcurrencyController

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.