refactor: Organize use statements
parent
0b4fd01d04
commit
27e7a1f925
|
@ -1,19 +1,15 @@
|
||||||
use std::convert::TryFrom;
|
use crate::{consistent_hasher::ConsistentHasher, server_id::ServerId, DatabaseName};
|
||||||
use std::num::NonZeroU64;
|
|
||||||
use std::time::Duration;
|
|
||||||
use std::{
|
|
||||||
collections::HashMap,
|
|
||||||
hash::{Hash, Hasher},
|
|
||||||
num::{NonZeroU32, NonZeroUsize},
|
|
||||||
};
|
|
||||||
|
|
||||||
use chrono::{TimeZone, Utc};
|
use chrono::{TimeZone, Utc};
|
||||||
|
use influxdb_line_protocol::ParsedLine;
|
||||||
use regex::Regex;
|
use regex::Regex;
|
||||||
use snafu::{OptionExt, Snafu};
|
use snafu::{OptionExt, Snafu};
|
||||||
|
use std::{
|
||||||
use influxdb_line_protocol::ParsedLine;
|
collections::HashMap,
|
||||||
|
convert::TryFrom,
|
||||||
use crate::{consistent_hasher::ConsistentHasher, server_id::ServerId, DatabaseName};
|
hash::{Hash, Hasher},
|
||||||
|
num::{NonZeroU32, NonZeroU64, NonZeroUsize},
|
||||||
|
time::Duration,
|
||||||
|
};
|
||||||
|
|
||||||
#[derive(Debug, Snafu)]
|
#[derive(Debug, Snafu)]
|
||||||
pub enum Error {
|
pub enum Error {
|
||||||
|
|
|
@ -1,17 +1,20 @@
|
||||||
use std::convert::{TryFrom, TryInto};
|
use crate::{
|
||||||
use std::num::NonZeroU32;
|
google::{FieldViolation, FieldViolationExt, FromFieldOpt},
|
||||||
use std::time::Duration;
|
influxdata::iox::management::v1 as management,
|
||||||
|
|
||||||
use thiserror::Error;
|
|
||||||
|
|
||||||
use data_types::database_rules::{
|
|
||||||
DatabaseRules, RoutingConfig, RoutingRules, WriteBufferConnection, WriteBufferCreationConfig,
|
|
||||||
WriteBufferDirection, DEFAULT_N_SEQUENCERS,
|
|
||||||
};
|
};
|
||||||
use data_types::DatabaseName;
|
use data_types::{
|
||||||
|
database_rules::{
|
||||||
use crate::google::{FieldViolation, FieldViolationExt, FromFieldOpt};
|
DatabaseRules, RoutingConfig, RoutingRules, WriteBufferConnection,
|
||||||
use crate::influxdata::iox::management::v1 as management;
|
WriteBufferCreationConfig, WriteBufferDirection, DEFAULT_N_SEQUENCERS,
|
||||||
|
},
|
||||||
|
DatabaseName,
|
||||||
|
};
|
||||||
|
use std::{
|
||||||
|
convert::{TryFrom, TryInto},
|
||||||
|
num::NonZeroU32,
|
||||||
|
time::Duration,
|
||||||
|
};
|
||||||
|
use thiserror::Error;
|
||||||
|
|
||||||
mod lifecycle;
|
mod lifecycle;
|
||||||
mod partition;
|
mod partition;
|
||||||
|
|
|
@ -1,11 +1,10 @@
|
||||||
use std::{convert::TryInto, sync::Arc};
|
|
||||||
|
|
||||||
use data_types::{database_rules::DatabaseRules, DatabaseName};
|
use data_types::{database_rules::DatabaseRules, DatabaseName};
|
||||||
use generated_types::{
|
use generated_types::{
|
||||||
database_rules::encode_database_rules, google::FieldViolation, influxdata::iox::management,
|
database_rules::encode_database_rules, google::FieldViolation, influxdata::iox::management,
|
||||||
};
|
};
|
||||||
use iox_object_store::IoxObjectStore;
|
use iox_object_store::IoxObjectStore;
|
||||||
use snafu::{ResultExt, Snafu};
|
use snafu::{ResultExt, Snafu};
|
||||||
|
use std::{convert::TryInto, sync::Arc};
|
||||||
|
|
||||||
#[derive(Debug, Snafu)]
|
#[derive(Debug, Snafu)]
|
||||||
pub enum Error {
|
pub enum Error {
|
||||||
|
|
|
@ -383,12 +383,13 @@ mod tests {
|
||||||
use data_types::{database_rules::DatabaseRules, DatabaseName};
|
use data_types::{database_rules::DatabaseRules, DatabaseName};
|
||||||
use influxdb_iox_client::connection::Connection;
|
use influxdb_iox_client::connection::Connection;
|
||||||
use server::rules::ProvidedDatabaseRules;
|
use server::rules::ProvidedDatabaseRules;
|
||||||
use std::convert::TryInto;
|
use std::{convert::TryInto, num::NonZeroU64};
|
||||||
use std::num::NonZeroU64;
|
|
||||||
use structopt::StructOpt;
|
use structopt::StructOpt;
|
||||||
use tokio::task::JoinHandle;
|
use tokio::task::JoinHandle;
|
||||||
use trace::span::{Span, SpanStatus};
|
use trace::{
|
||||||
use trace::RingBufferTraceCollector;
|
span::{Span, SpanStatus},
|
||||||
|
RingBufferTraceCollector,
|
||||||
|
};
|
||||||
use trace_exporters::export::{AsyncExporter, TestAsyncExporter};
|
use trace_exporters::export::{AsyncExporter, TestAsyncExporter};
|
||||||
|
|
||||||
fn test_config(server_id: Option<u32>) -> Config {
|
fn test_config(server_id: Option<u32>) -> Config {
|
||||||
|
|
Loading…
Reference in New Issue