diff --git a/daqbufp2/src/test/binnedbinary.rs b/daqbufp2/src/test/binnedbinary.rs index aea86b2..37cf075 100644 --- a/daqbufp2/src/test/binnedbinary.rs +++ b/daqbufp2/src/test/binnedbinary.rs @@ -7,7 +7,7 @@ use err::Error; use futures_util::{StreamExt, TryStreamExt}; use http::StatusCode; use hyper::Body; -use items::minmaxavgbins::MinMaxAvgBins; +use items::binsdim0::MinMaxAvgDim0Bins; use items::{FrameType, RangeCompletableItem, Sitemty, StatsItem, StreamItem, SubFrId, WithLen}; use netpod::query::{BinnedQuery, CacheUsage}; use netpod::{log::*, AppendToUrl}; @@ -102,7 +102,7 @@ where let channel = Channel { backend: channel_backend.into(), name: channel_name.into(), - series:None, + series: None, }; let range = NanoRange::from_date_time(beg_date, end_date); let mut query = BinnedQuery::new(channel, range, bin_count, agg_kind); @@ -195,10 +195,10 @@ where None } StreamItem::DataItem(frame) => { - if frame.tyid() != > as FrameType>::FRAME_TYPE_ID { + if frame.tyid() != > as FrameType>::FRAME_TYPE_ID { error!("test receives unexpected tyid {:x}", frame.tyid()); } - match bincode::deserialize::>>(frame.buf()) { + match bincode::deserialize::>>(frame.buf()) { Ok(item) => match item { Ok(item) => match item { StreamItem::Log(item) => { diff --git a/items/src/minmaxavgbins.rs b/items/src/binsdim0.rs similarity index 91% rename from items/src/minmaxavgbins.rs rename to items/src/binsdim0.rs index 33a6786..996aafe 100644 --- a/items/src/minmaxavgbins.rs +++ b/items/src/binsdim0.rs @@ -17,7 +17,7 @@ use std::marker::PhantomData; use tokio::fs::File; #[derive(Clone, Serialize, Deserialize)] -pub struct MinMaxAvgBins { +pub struct MinMaxAvgDim0Bins { pub ts1s: Vec, pub ts2s: Vec, pub counts: Vec, @@ -27,14 +27,14 @@ pub struct MinMaxAvgBins { pub avgs: Vec>, } -impl SitemtyFrameType for MinMaxAvgBins +impl SitemtyFrameType for MinMaxAvgDim0Bins where NTY: SubFrId, { const FRAME_TYPE_ID: u32 = crate::MIN_MAX_AVG_BINS + NTY::SUB; } -impl fmt::Debug for MinMaxAvgBins +impl fmt::Debug for MinMaxAvgDim0Bins where NTY: fmt::Debug, { @@ -53,7 +53,7 @@ where } } -impl MinMaxAvgBins { +impl MinMaxAvgDim0Bins { pub fn empty() -> Self { Self { ts1s: vec![], @@ -66,7 +66,7 @@ impl MinMaxAvgBins { } } -impl FitsInside for MinMaxAvgBins { +impl FitsInside for MinMaxAvgDim0Bins { fn fits_inside(&self, range: NanoRange) -> Fits { if self.ts1s.is_empty() { Fits::Empty @@ -90,7 +90,7 @@ impl FitsInside for MinMaxAvgBins { } } -impl FilterFittingInside for MinMaxAvgBins { +impl FilterFittingInside for MinMaxAvgDim0Bins { fn filter_fitting_inside(self, fit_range: NanoRange) -> Option { match self.fits_inside(fit_range) { Fits::Inside | Fits::PartlyGreater | Fits::PartlyLower | Fits::PartlyLowerAndGreater => Some(self), @@ -99,7 +99,7 @@ impl FilterFittingInside for MinMaxAvgBins { } } -impl RangeOverlapInfo for MinMaxAvgBins { +impl RangeOverlapInfo for MinMaxAvgDim0Bins { fn ends_before(&self, range: NanoRange) -> bool { match self.ts2s.last() { Some(&ts) => ts <= range.beg, @@ -122,7 +122,7 @@ impl RangeOverlapInfo for MinMaxAvgBins { } } -impl TimeBins for MinMaxAvgBins +impl TimeBins for MinMaxAvgDim0Bins where NTY: NumOps, { @@ -135,13 +135,13 @@ where } } -impl WithLen for MinMaxAvgBins { +impl WithLen for MinMaxAvgDim0Bins { fn len(&self) -> usize { self.ts1s.len() } } -impl Appendable for MinMaxAvgBins +impl Appendable for MinMaxAvgDim0Bins where NTY: NumOps, { @@ -159,7 +159,7 @@ where } } -impl ReadableFromFile for MinMaxAvgBins +impl ReadableFromFile for MinMaxAvgDim0Bins where NTY: NumOps, { @@ -174,11 +174,11 @@ where } } -impl TimeBinnableType for MinMaxAvgBins +impl TimeBinnableType for MinMaxAvgDim0Bins where NTY: NumOps, { - type Output = MinMaxAvgBins; + type Output = MinMaxAvgDim0Bins; type Aggregator = MinMaxAvgBinsAggregator; fn aggregator(range: NanoRange, x_bin_count: usize, do_time_weight: bool) -> Self::Aggregator { @@ -190,7 +190,7 @@ where } } -impl ToJsonResult for Sitemty> +impl ToJsonResult for Sitemty> where NTY: NumOps, { @@ -236,7 +236,7 @@ pub struct MinMaxAvgBinsCollector { bin_count_exp: u32, timed_out: bool, range_complete: bool, - vals: MinMaxAvgBins, + vals: MinMaxAvgDim0Bins, _m1: PhantomData, } @@ -246,7 +246,7 @@ impl MinMaxAvgBinsCollector { bin_count_exp, timed_out: false, range_complete: false, - vals: MinMaxAvgBins::::empty(), + vals: MinMaxAvgDim0Bins::::empty(), _m1: PhantomData, } } @@ -265,7 +265,7 @@ impl Collector for MinMaxAvgBinsCollector where NTY: NumOps + Serialize, { - type Input = MinMaxAvgBins; + type Input = MinMaxAvgDim0Bins; type Output = MinMaxAvgBinsCollectedResult; fn ingest(&mut self, src: &Self::Input) { @@ -315,7 +315,7 @@ where } } -impl Collectable for MinMaxAvgBins +impl Collectable for MinMaxAvgDim0Bins where NTY: NumOps + Serialize, { @@ -352,8 +352,8 @@ impl TimeBinnableTypeAggregator for MinMaxAvgBinsAggregator where NTY: NumOps, { - type Input = MinMaxAvgBins; - type Output = MinMaxAvgBins; + type Input = MinMaxAvgDim0Bins; + type Output = MinMaxAvgDim0Bins; fn range(&self) -> &NanoRange { &self.range diff --git a/items/src/minmaxavgdim1bins.rs b/items/src/binsdim1.rs similarity index 100% rename from items/src/minmaxavgdim1bins.rs rename to items/src/binsdim1.rs diff --git a/items/src/items.rs b/items/src/items.rs index 8eb697c..bd495ef 100644 --- a/items/src/items.rs +++ b/items/src/items.rs @@ -1,9 +1,9 @@ pub mod binnedevents; +pub mod binsdim0; +pub mod binsdim1; pub mod eventsitem; pub mod frame; pub mod inmem; -pub mod minmaxavgbins; -pub mod minmaxavgdim1bins; pub mod numops; pub mod plainevents; pub mod scalarevents; diff --git a/items/src/scalarevents.rs b/items/src/scalarevents.rs index abdefaf..b34a7f5 100644 --- a/items/src/scalarevents.rs +++ b/items/src/scalarevents.rs @@ -1,4 +1,4 @@ -use crate::minmaxavgbins::MinMaxAvgBins; +use crate::binsdim0::MinMaxAvgDim0Bins; use crate::numops::NumOps; use crate::streams::{Collectable, Collector}; use crate::{ @@ -217,7 +217,7 @@ impl TimeBinnableType for ScalarEvents where NTY: NumOps, { - type Output = MinMaxAvgBins; + type Output = MinMaxAvgDim0Bins; type Aggregator = EventValuesAggregator; fn aggregator(range: NanoRange, x_bin_count: usize, do_time_weight: bool) -> Self::Aggregator { @@ -442,13 +442,13 @@ where } } - fn result_reset_unweight(&mut self, range: NanoRange, _expand: bool) -> MinMaxAvgBins { + fn result_reset_unweight(&mut self, range: NanoRange, _expand: bool) -> MinMaxAvgDim0Bins { let avg = if self.sumc == 0 { None } else { Some(self.sum / self.sumc as f32) }; - let ret = MinMaxAvgBins { + let ret = MinMaxAvgDim0Bins { ts1s: vec![self.range.beg], ts2s: vec![self.range.end], counts: vec![self.count], @@ -466,7 +466,7 @@ where ret } - fn result_reset_time_weight(&mut self, range: NanoRange, expand: bool) -> MinMaxAvgBins { + fn result_reset_time_weight(&mut self, range: NanoRange, expand: bool) -> MinMaxAvgDim0Bins { // TODO check callsite for correct expand status. if true || expand { debug!("result_reset_time_weight calls apply_event_time_weight"); @@ -478,7 +478,7 @@ where let sc = self.range.delta() as f32 * 1e-9; Some(self.sum / sc) }; - let ret = MinMaxAvgBins { + let ret = MinMaxAvgDim0Bins { ts1s: vec![self.range.beg], ts2s: vec![self.range.end], counts: vec![self.count], @@ -502,7 +502,7 @@ where NTY: NumOps, { type Input = ScalarEvents; - type Output = MinMaxAvgBins; + type Output = MinMaxAvgDim0Bins; fn range(&self) -> &NanoRange { &self.range diff --git a/items/src/waveevents.rs b/items/src/waveevents.rs index d0b83f3..ac5e532 100644 --- a/items/src/waveevents.rs +++ b/items/src/waveevents.rs @@ -1,4 +1,4 @@ -use crate::minmaxavgdim1bins::MinMaxAvgDim1Bins; +use crate::binsdim1::MinMaxAvgDim1Bins; use crate::numops::NumOps; use crate::xbinnedscalarevents::XBinnedScalarEvents; use crate::xbinnedwaveevents::XBinnedWaveEvents; diff --git a/items/src/xbinnedscalarevents.rs b/items/src/xbinnedscalarevents.rs index 709412b..da38439 100644 --- a/items/src/xbinnedscalarevents.rs +++ b/items/src/xbinnedscalarevents.rs @@ -1,4 +1,4 @@ -use crate::minmaxavgbins::MinMaxAvgBins; +use crate::binsdim0::MinMaxAvgDim0Bins; use crate::numops::NumOps; use crate::streams::{Collectable, Collector}; use crate::{ @@ -175,7 +175,7 @@ impl TimeBinnableType for XBinnedScalarEvents where NTY: NumOps, { - type Output = MinMaxAvgBins; + type Output = MinMaxAvgDim0Bins; type Aggregator = XBinnedScalarEventsAggregator; fn aggregator(range: NanoRange, x_bin_count: usize, do_time_weight: bool) -> Self::Aggregator { @@ -315,13 +315,13 @@ where } } - fn result_reset_unweight(&mut self, range: NanoRange, _expand: bool) -> MinMaxAvgBins { + fn result_reset_unweight(&mut self, range: NanoRange, _expand: bool) -> MinMaxAvgDim0Bins { let avg = if self.sumc == 0 { None } else { Some(self.sum / self.sumc as f32) }; - let ret = MinMaxAvgBins { + let ret = MinMaxAvgDim0Bins { ts1s: vec![self.range.beg], ts2s: vec![self.range.end], counts: vec![self.count], @@ -339,7 +339,7 @@ where ret } - fn result_reset_time_weight(&mut self, range: NanoRange, expand: bool) -> MinMaxAvgBins { + fn result_reset_time_weight(&mut self, range: NanoRange, expand: bool) -> MinMaxAvgDim0Bins { // TODO check callsite for correct expand status. if true || expand { self.apply_event_time_weight(self.range.end); @@ -348,7 +348,7 @@ where let sc = self.range.delta() as f32 * 1e-9; Some(self.sum / sc) }; - let ret = MinMaxAvgBins { + let ret = MinMaxAvgDim0Bins { ts1s: vec![self.range.beg], ts2s: vec![self.range.end], counts: vec![self.count], @@ -372,7 +372,7 @@ where NTY: NumOps, { type Input = XBinnedScalarEvents; - type Output = MinMaxAvgBins; + type Output = MinMaxAvgDim0Bins; fn range(&self) -> &NanoRange { &self.range diff --git a/items/src/xbinnedwaveevents.rs b/items/src/xbinnedwaveevents.rs index 933cd3e..6108269 100644 --- a/items/src/xbinnedwaveevents.rs +++ b/items/src/xbinnedwaveevents.rs @@ -1,4 +1,4 @@ -use crate::minmaxavgdim1bins::MinMaxAvgDim1Bins; +use crate::binsdim1::MinMaxAvgDim1Bins; use crate::numops::NumOps; use crate::streams::{Collectable, Collector}; use crate::{