Browse Source

small refactorign

pull/100/head
Alexey Velikiy 2 years ago
parent
commit
cafb50cce3
  1. 2
      server/src/services/analytic_service/analytic_service.rs
  2. 4
      server/src/services/analytic_service/detection_runner.rs

2
server/src/services/analytic_service/analytic_service.rs

@ -137,7 +137,7 @@ impl AnalyticService {
};
let tx = self.tx.clone();
let au = self.analytic_unit.as_ref().unwrap().clone();
let dr = DetectionRunner::new(self.metric_service.clone(), tx, drcfg, au);
let dr = DetectionRunner::new(tx,self.metric_service.clone(), drcfg, au);
self.detection_runner = Some(dr);
self.detection_runner.as_mut().unwrap().run(from);

4
server/src/services/analytic_service/detection_runner.rs

@ -9,8 +9,8 @@ use tokio::time::{sleep, Duration};
pub struct DetectionRunner {
metric_service: MetricService,
tx: mpsc::Sender<AnalyticServiceMessage>,
metric_service: MetricService,
config: DetectionRunnerConfig,
analytic_unit: AnalyticUnitRF,
running_handler: Option<tokio::task::JoinHandle<()>>,
@ -18,8 +18,8 @@ pub struct DetectionRunner {
impl DetectionRunner {
pub fn new(
metric_service: MetricService,
tx: mpsc::Sender<AnalyticServiceMessage>,
metric_service: MetricService,
config: DetectionRunnerConfig,
analytic_unit: AnalyticUnitRF,
) -> DetectionRunner {

Loading…
Cancel
Save