services v2 controller without impl
parent
f504632c4d
commit
71acb4a32e
|
|
@ -5,6 +5,22 @@ use std::net::{TcpStream, ToSocketAddrs};
|
||||||
use std::sync::Arc;
|
use std::sync::Arc;
|
||||||
use tokio::sync::mpsc;
|
use tokio::sync::mpsc;
|
||||||
use tokio::time::{Duration, Instant};
|
use tokio::time::{Duration, Instant};
|
||||||
|
use tokio::sync::mpsc::Sender as MpscSender;
|
||||||
|
use crate::options::structs::Events;
|
||||||
|
|
||||||
|
pub mod v2 {
|
||||||
|
use crate::options::structs::Triggers;
|
||||||
|
|
||||||
|
use super::*;
|
||||||
|
use std::collections::HashMap;
|
||||||
|
|
||||||
|
struct ServicesController<'a> {
|
||||||
|
name: &'a str,
|
||||||
|
obj: Arc<Services>,
|
||||||
|
triggers: HashMap<&'a str, Triggers<'a>>,
|
||||||
|
event_registrator: Vec<MpscSender<Events<'a>>>,
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
/// # Fn `service_handler`
|
/// # Fn `service_handler`
|
||||||
/// ## function to realize mechanism of current process' dep services monitoring
|
/// ## function to realize mechanism of current process' dep services monitoring
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue