diff --git a/netfetch/src/ca/conn.rs b/netfetch/src/ca/conn.rs index f4eae02..0517781 100644 --- a/netfetch/src/ca/conn.rs +++ b/netfetch/src/ca/conn.rs @@ -1,6 +1,4 @@ use super::proto; -use super::proto::CaDataValue; -use super::proto::CaEventValue; use super::proto::CaItem; use super::proto::CaMsg; use super::proto::CaMsgTy; @@ -11,7 +9,6 @@ use crate::batchquery::series_by_channel::ChannelInfoQuery; use crate::bsread::ChannelDescDecoded; use crate::ca::proto::CreateChan; use crate::ca::proto::EventAdd; -use crate::patchcollect::PatchCollect; use crate::series::ChannelStatusSeriesId; use crate::series::Existence; use crate::series::SeriesId; @@ -26,7 +23,6 @@ use crate::store::InsertItem; use crate::store::IvlItem; use crate::store::MuteItem; use crate::store::QueryItem; -use crate::store::TimeBinPatchSimpleF32; use crate::timebin::ConnTimeBin; use async_channel::Sender; use err::Error; @@ -35,28 +31,15 @@ use futures_util::Future; use futures_util::FutureExt; use futures_util::Stream; use futures_util::StreamExt; -use items_0::scalar_ops::ScalarOps; -use items_0::timebin::TimeBinner; -use items_0::Appendable; -use items_0::Empty; -use items_0::Events; -use items_0::Resettable; -use items_2::binsdim0::BinsDim0; -use items_2::eventsdim0::EventsDim0; -use items_2::eventsdim1::EventsDim1; use log::*; use netpod::timeunits::*; -use netpod::BinnedRange; -use netpod::BinnedRangeEnum; use netpod::ScalarType; use netpod::Shape; -use netpod::TsNano; use netpod::TS_MSP_GRID_SPACING; use netpod::TS_MSP_GRID_UNIT; use serde::Serialize; use stats::CaConnStats; use stats::IntervalEma; -use std::any::Any; use std::collections::BTreeMap; use std::collections::VecDeque; use std::net::SocketAddrV4; diff --git a/netfetch/src/scylla.rs b/netfetch/src/scylla.rs index 5717990..fc1aeff 100644 --- a/netfetch/src/scylla.rs +++ b/netfetch/src/scylla.rs @@ -1,5 +1,6 @@ use err::Error; use futures_util::StreamExt; +#[allow(unused)] use netpod::log::*; use netpod::ScyllaConfig; use scylla::execution_profile::ExecutionProfileBuilder; diff --git a/netfetch/src/store.rs b/netfetch/src/store.rs index 31f17ee..81c4953 100644 --- a/netfetch/src/store.rs +++ b/netfetch/src/store.rs @@ -1,10 +1,11 @@ -use crate::ca::proto::{CaDataArrayValue, CaDataScalarValue, CaDataValue}; +use crate::ca::proto::CaDataArrayValue; +use crate::ca::proto::CaDataScalarValue; +use crate::ca::proto::CaDataValue; use crate::ca::store::DataStore; use crate::errconv::ErrConv; use crate::series::SeriesId; use futures_util::Future; use futures_util::FutureExt; -use items_2::binsdim0::BinsDim0; use log::*; use netpod::ScalarType; use netpod::Shape; @@ -24,7 +25,6 @@ use std::time::Instant; use std::time::SystemTime; pub use netpod::CONNECTION_STATUS_DIV; -use std::collections::VecDeque; #[derive(Debug)] pub enum Error { diff --git a/netfetch/src/timebin.rs b/netfetch/src/timebin.rs index 4d0f704..1f13356 100644 --- a/netfetch/src/timebin.rs +++ b/netfetch/src/timebin.rs @@ -14,7 +14,6 @@ use items_0::Events; use items_0::Resettable; use items_2::binsdim0::BinsDim0; use items_2::eventsdim0::EventsDim0; -use items_2::eventsdim1::EventsDim1; use netpod::log::*; use netpod::timeunits::SEC; use netpod::BinnedRange;