Skip to content

Commit

Permalink
update use
Browse files Browse the repository at this point in the history
  • Loading branch information
kazuk committed Jun 15, 2022
1 parent 82b1a40 commit 19ed89a
Show file tree
Hide file tree
Showing 18 changed files with 18 additions and 18 deletions.
2 changes: 1 addition & 1 deletion springql/examples/doc_app1.rs
Expand Up @@ -12,7 +12,7 @@
//! echo '{"ts": "2022-01-01 13:00:00.000000000", "temperature": 5.3}' |nc localhost 54300
//! ```

use springql_core::api::{SpringConfig, SpringPipeline};
use springql::{SpringConfig, SpringPipeline};

fn main() {
const SOURCE_PORT: u16 = 54300;
Expand Down
2 changes: 1 addition & 1 deletion springql/examples/doc_app2.rs
Expand Up @@ -19,7 +19,7 @@

use std::{sync::Arc, thread, time::Duration};

use springql_core::api::{SpringConfig, SpringPipeline};
use springql::{SpringConfig, SpringPipeline};

fn main() {
const SOURCE_PORT: u16 = 54300;
Expand Down
2 changes: 1 addition & 1 deletion springql/examples/in_vehicle_pipeline.rs
Expand Up @@ -7,7 +7,7 @@ use std::{
time::Duration,
};

use springql_core::api::{SpringConfig, SpringPipeline};
use springql::{SpringConfig, SpringPipeline};
use springql_foreign_service::sink::ForeignSink;

use tempfile::NamedTempFile;
Expand Down
2 changes: 1 addition & 1 deletion springql/tests/e2e_high_level_rs.rs
Expand Up @@ -5,7 +5,7 @@ mod test_support;
use pretty_assertions::assert_eq;
use serde_json::json;

use springql_core::api::{error::Result, SpringConfig};
use springql::{Result, SpringConfig};
use springql_foreign_service::{
sink::ForeignSink,
source::{ForeignSource, ForeignSourceInput},
Expand Down
2 changes: 1 addition & 1 deletion springql/tests/e2e_sampling.rs
Expand Up @@ -4,7 +4,7 @@ mod test_support;

use pretty_assertions::assert_eq;
use serde_json::json;
use springql_core::api::{error::Result, *};
use springql::*;
use springql_foreign_service::{
sink::ForeignSink,
source::{ForeignSource, ForeignSourceInput},
Expand Down
2 changes: 1 addition & 1 deletion springql/tests/feat_aggregation.rs
Expand Up @@ -4,7 +4,7 @@ mod test_support;

use pretty_assertions::assert_eq;
use serde_json::json;
use springql_core::api::{error::Result, *};
use springql::*;
use springql_foreign_service::{
sink::ForeignSink,
source::{ForeignSource, ForeignSourceInput},
Expand Down
2 changes: 1 addition & 1 deletion springql/tests/feat_error.rs
@@ -1,6 +1,6 @@
// This file is part of https://github.com/SpringQL/SpringQL which is licensed under MIT OR Apache-2.0. See file LICENSE-MIT or LICENSE-APACHE for full license details.

use springql_core::api::error::SpringError;
use springql::SpringError;

// https://rust-lang.github.io/api-guidelines/interoperability.html#error-types-are-meaningful-and-well-behaved-c-good-err
#[test]
Expand Down
2 changes: 1 addition & 1 deletion springql/tests/feat_join.rs
Expand Up @@ -4,7 +4,7 @@ mod test_support;

use pretty_assertions::assert_eq;
use serde_json::json;
use springql_core::api::*;
use springql::*;
use springql_foreign_service::{
sink::ForeignSink,
source::{ForeignSource, ForeignSourceInput},
Expand Down
2 changes: 1 addition & 1 deletion springql/tests/feat_logical_ops.rs
Expand Up @@ -4,7 +4,7 @@ mod test_support;

use pretty_assertions::assert_eq;
use serde_json::json;
use springql_core::api::*;
use springql::*;
use springql_foreign_service::{
sink::ForeignSink,
source::{ForeignSource, ForeignSourceInput},
Expand Down
2 changes: 1 addition & 1 deletion springql/tests/feat_numerical_ops.rs
Expand Up @@ -5,7 +5,7 @@ mod test_support;
use float_cmp::approx_eq;
use pretty_assertions::assert_eq;
use serde_json::json;
use springql_core::api::*;
use springql::*;
use springql_foreign_service::{
sink::ForeignSink,
source::{ForeignSource, ForeignSourceInput},
Expand Down
2 changes: 1 addition & 1 deletion springql/tests/feat_performance_metrics_report.rs
Expand Up @@ -9,7 +9,7 @@ use float_cmp::approx_eq;
use pretty_assertions::assert_eq;
use rand::prelude::{IteratorRandom, SliceRandom};
use serde_json::json;
use springql_core::api::*;
use springql::*;
use springql_foreign_service::{
sink::ForeignSink,
source::{ForeignSource, ForeignSourceInput},
Expand Down
2 changes: 1 addition & 1 deletion springql/tests/feat_pipeline.rs
Expand Up @@ -4,7 +4,7 @@ mod test_support;

use pretty_assertions::assert_eq;
use serde_json::json;
use springql_core::api::*;
use springql::*;
use springql_foreign_service::source::{ForeignSource, ForeignSourceInput};
use springql_test_logger::setup_test_logger;

Expand Down
2 changes: 1 addition & 1 deletion springql/tests/feat_projection.rs
Expand Up @@ -4,7 +4,7 @@ mod test_support;

use pretty_assertions::assert_eq;
use serde_json::json;
use springql_core::api::*;
use springql::*;
use springql_foreign_service::source::{ForeignSource, ForeignSourceInput};
use springql_test_logger::setup_test_logger;

Expand Down
2 changes: 1 addition & 1 deletion springql/tests/feat_purger.rs
Expand Up @@ -7,7 +7,7 @@ use std::time::Duration;

use log::LevelFilter;
use serde_json::json;
use springql_core::api::*;
use springql::*;
use springql_foreign_service::{
sink::ForeignSink,
source::{ForeignSource, ForeignSourceInput},
Expand Down
2 changes: 1 addition & 1 deletion springql/tests/feat_spring_open_twice.rs
@@ -1,6 +1,6 @@
// This file is part of https://github.com/SpringQL/SpringQL which is licensed under MIT OR Apache-2.0. See file LICENSE-MIT or LICENSE-APACHE for full license details.

use springql_core::api::{SpringConfig, SpringPipeline};
use springql::{SpringConfig, SpringPipeline};

#[test]
fn test_spring_open_twice() {
Expand Down
2 changes: 1 addition & 1 deletion springql/tests/feat_timestamp_ops.rs
Expand Up @@ -4,7 +4,7 @@ mod test_support;

use pretty_assertions::assert_eq;
use serde_json::json;
use springql_core::api::*;
use springql::*;
use springql_foreign_service::{
sink::ForeignSink,
source::{ForeignSource, ForeignSourceInput},
Expand Down
2 changes: 1 addition & 1 deletion springql/tests/feat_worker_config.rs
Expand Up @@ -4,7 +4,7 @@ mod test_support;

use crate::test_support::{apply_ddls, drain_from_sink};
use serde_json::json;
use springql_core::api::*;
use springql::*;
use springql_foreign_service::{
sink::ForeignSink,
source::{ForeignSource, ForeignSourceInput},
Expand Down
2 changes: 1 addition & 1 deletion springql/tests/test_support/mod.rs
Expand Up @@ -2,7 +2,7 @@

use std::time::Duration;

use springql_core::{api::SpringConfig, api::SpringPipeline};
use springql::{SpringConfig, SpringPipeline};
use springql_foreign_service::sink::ForeignSink;

#[allow(dead_code)]
Expand Down

0 comments on commit 19ed89a

Please sign in to comment.