Struct AgentServiceRepository 

pub struct AgentServiceRepository { /* private fields */ }

Implementations

impl AgentServiceRepository

pub const fn new(db_pool: DbPool) -> Self

pub async fn register_agent( &self, name: &str, pid: u32, port: u16, ) -> Result<String, RepositoryError>

pub async fn register_agent_starting( &self, name: &str, pid: u32, port: u16, ) -> Result<String, RepositoryError>

pub async fn mark_running( &self, agent_name: &str, ) -> Result<(), RepositoryError>

pub async fn get_agent_status( &self, agent_name: &str, ) -> Result<Option<AgentServiceRow>, RepositoryError>

pub async fn mark_crashed( &self, agent_name: &str, ) -> Result<(), RepositoryError>

pub async fn mark_stopped( &self, agent_name: &str, ) -> Result<(), RepositoryError>

pub async fn mark_error(&self, agent_name: &str) -> Result<(), RepositoryError>

pub async fn list_running_agents( &self, ) -> Result<Vec<AgentServerIdRow>, RepositoryError>

pub async fn list_running_agent_pids( &self, ) -> Result<Vec<AgentServerIdPidRow>, RepositoryError>

pub async fn remove_agent_service( &self, agent_name: &str, ) -> Result<(), RepositoryError>

pub async fn update_health_status( &self, agent_name: &str, health_status: &str, ) -> Result<(), RepositoryError>

Trait Implementations

impl Clone for AgentServiceRepository

fn clone(&self) -> AgentServiceRepository

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AgentServiceRepository

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Repository for AgentServiceRepository

type Pool = Arc<Database>

type Error = RepositoryError

fn pool(&self) -> &Self::Pool