ockam_api 0.93.0

Ockam's request-response API
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

use crate::nodes::models::workers::{WorkerList, WorkerStatus};
use crate::nodes::NodeManagerWorker;
use ockam_core::api::{Error, Response};
use ockam_core::Result;
use ockam_node::Context;

impl NodeManagerWorker {
    /// Return the current list of workers
    pub async fn list_workers(
        &self,
        ctx: &Context,
    ) -> Result<Response<WorkerList>, Response<Error>> {
        let list = ctx
            .list_workers()?
            .into_iter()
            .map(|addr| WorkerStatus::new(addr.address()))
            .collect();

        Ok(Response::ok().body(WorkerList::new(list)))
    }
}