Struct TaskRegistry 

pub struct TaskRegistry { /* private fields */ }

Registry of running adapter instances

Implementations

impl TaskRegistry

pub fn new() -> Self

pub async fn get_all_status(&self) -> HashMap<String, (String, InstanceStatus)>

Get status of all instances

pub async fn get_status(&self, credential_id: &str) -> Option<InstanceStatus>

Get status of a specific instance

pub async fn is_running(&self, credential_id: &str) -> bool

Check if an instance is running

pub async fn get_instance(&self, credential_id: &str) -> Option<(String, u16)>

Get instance by credential_id

pub async fn register( &self, credential_id: String, instance_id: String, adapter: String, port: u16, )

Register a new instance

pub async fn update_status(&self, credential_id: &str, status: InstanceStatus)

Update instance status

pub async fn remove(&self, credential_id: &str) -> Option<InstanceInfo>

Remove an instance from registry

Trait Implementations

impl Default for TaskRegistry

fn default() -> Self

Returns the “default value” for a type.