Struct metrics::MetricsController

pub struct MetricsController {
    pub(crate) agents: Vec<RecvTube>,
    handler: RequestHandler,
    pub(crate) closed_tubes: usize,
}

Runs the metrics controller.

Fields

agents: Vec<RecvTube>

handler: RequestHandler

closed_tubes: usize

Implementations

impl MetricsController

pub fn new(agents: Vec<RecvTube>) -> Self

pub fn run(&mut self) -> Result<()>

Run the metrics controller until all clients exit & close their Tubes.

pub(crate) fn on_tube_readable(&self, client: &RecvTube)

Handles a tube that has indicated it has data ready to read.

pub(crate) fn on_connection_closed(&mut self) -> bool

Handles a closed connection, and returns a bool indicating whether the run loop itself should close.

impl MetricsController

pub(crate) fn run_internal(&mut self) -> Result<()>