Struct RunRegistry 

pub struct RunRegistry { /* private fields */ }

Implementations

impl RunRegistry

pub fn new() -> Self

pub async fn get(&self, session_id: &str) -> Option<ActiveRun>

pub async fn acquire( &self, session_id: &str, run_id: String, client_id: Option<String>, agent_id: Option<String>, agent_profile: Option<String>, ) -> Result<ActiveRun, ActiveRun>

pub async fn touch(&self, session_id: &str, run_id: &str)

pub async fn finish_if_match( &self, session_id: &str, run_id: &str, ) -> Option<ActiveRun>

pub async fn finish_active(&self, session_id: &str) -> Option<ActiveRun>

pub async fn reap_stale(&self, stale_ms: u64) -> Vec<(String, ActiveRun)>

Trait Implementations

impl Clone for RunRegistry

fn clone(&self) -> RunRegistry

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for RunRegistry

fn default() -> RunRegistry

Returns the “default value” for a type.