Struct AdapterInstanceManager 

pub struct AdapterInstanceManager {
    pub adapters: HashMap<String, AdapterDef>,
    pub adapters_dir: String,
    /* private fields */
}

Adapter Instance Manager

Fields

adapters: HashMap<String, AdapterDef>

Discovered adapter definitions

adapters_dir: String

Adapters directory path

Implementations

impl AdapterInstanceManager

pub fn new( adapters_dir: String, port_range: (u16, u16), gateway_listen: &str, ) -> Result<Self, AppError>

pub fn has_adapter(&self, name: &str) -> bool

Check if an adapter exists

pub async fn spawn( &self, credential_id: &str, adapter_name: &str, token: &str, config: Option<&Value>, ) -> Result<(String, u16), AppError>

Spawn an adapter process for a credential

pub async fn stop(&self, credential_id: &str) -> Result<(), AppError>

Stop an adapter process

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

Get the port for a credential’s adapter

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

Get instance_id for a credential

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

Check if adapter process is running for a credential

pub async fn stop_all(&self)

Stop all adapter processes

pub async fn get_credential_id(&self, instance_id: &str) -> Option<String>

Find credential_id by instance_id

pub async fn check_health(&self, credential_id: &str) -> AdapterHealth

Check health of a specific adapter by credential_id

pub async fn update_health( &self, credential_id: &str, health: AdapterHealth, reset_failures: bool, )

Update health state for a credential

pub async fn get_health( &self, credential_id: &str, ) -> Option<(AdapterHealth, u32)>

Get health state for a credential

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

Check if adapter process has exited

pub async fn get_all_health( &self, ) -> HashMap<String, (String, AdapterHealth, u32)>

Get all credentials with their health status

pub async fn restart( &self, credential_id: &str, max_restarts: u32, ) -> Result<bool, AppError>

Restart an adapter process Returns Ok(true) if restart succeeded, Ok(false) if should wait (backoff), Err on failure

pub async fn reset_restart_count(&self, credential_id: &str)

Reset restart count for a credential (called when adapter is healthy for a while)

pub async fn get_restart_info( &self, credential_id: &str, ) -> Option<(u32, Option<Duration>)>

Get restart info for a credential