krata-daemon 0.0.21

Daemon for the krata isolation engine
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28

use anyhow::Result;

use krata::v1::{
    common::NetworkReservation,
    control::{ListNetworkReservationsReply, ListNetworkReservationsRequest},
};

use crate::network::assignment::NetworkAssignment;

pub struct ListNetworkReservationsRpc {
    network: NetworkAssignment,
}

impl ListNetworkReservationsRpc {
    pub fn new(network: NetworkAssignment) -> Self {
        Self { network }
    }

    pub async fn process(
        self,
        _request: ListNetworkReservationsRequest,
    ) -> Result<ListNetworkReservationsReply> {
        let state = self.network.read_reservations().await?;
        let reservations: Vec<NetworkReservation> =
            state.into_values().map(|x| x.into()).collect::<Vec<_>>();
        Ok(ListNetworkReservationsReply { reservations })
    }
}