Struct UserQuotaTracker

pub struct UserQuotaTracker { /* private fields */ }

Track the active tasks being run for a user in a queue with an age-out policy

Implementations

impl UserQuotaTracker

pub fn set_timeout(self, timeout: Duration) -> Self

Set the time before a task started by a user will age out if not ended normally.

pub async fn begin( &self, user: &str, max_quota: u32, ) -> Result<bool, ErrorTypes>

Start a task for the given user assuming the task queue would not rise above the given maximum

pub async fn end(&self, user: &str) -> Result<(), ErrorTypes>

End the longest running task owned by the given user

Trait Implementations

impl Clone for UserQuotaTracker

fn clone(&self) -> UserQuotaTracker

Returns a duplicate of the value.

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

Performs copy-assignment from source.