Struct StatsServer

pub struct StatsServer<Req, Res>
where
    Req: Send + 'static,
    Res: Send + 'static,
{
    base_path: PathBuf,
    sched_path: PathBuf,
    stats_path: PathBuf,
    path: Option<PathBuf>,
    data: Arc<Mutex<StatsServerData<Req, Res>>>,
    outer_ch: ChannelPair<Res, Req>,
    inner_ch: Option<ChannelPair<Req, Res>>,
    exit: Arc<AtomicBool>,
}

Fields

base_path: PathBuf

sched_path: PathBuf

stats_path: PathBuf

path: Option<PathBuf>

data: Arc<Mutex<StatsServerData<Req, Res>>>

outer_ch: ChannelPair<Res, Req>

inner_ch: Option<ChannelPair<Req, Res>>

exit: Arc<AtomicBool>

Implementations

impl<Req, Res> StatsServer<Req, Res>

where Req: Send + 'static, Res: Send + 'static,

pub fn new(data: StatsServerData<Req, Res>) -> Self

pub fn set_base_path<P: AsRef<Path>>(self, path: P) -> Self

pub fn set_sched_path<P: AsRef<Path>>(self, path: P) -> Self

pub fn set_stats_path<P: AsRef<Path>>(self, path: P) -> Self

pub fn set_path<P: AsRef<Path>>(self, path: P) -> Self

pub fn launch(self) -> Result<Self>

pub fn channels(&self) -> (Sender<Res>, Receiver<Req>)

Trait Implementations

impl<Req, Res> Drop for StatsServer<Req, Res>

where Req: Send + 'static, Res: Send + 'static,

fn drop(&mut self)

Executes the destructor for this type.