fmt with group_imports = "StdExternalCrate"

xxchan · xxchan · Feb 26, 2023 · Feb 26, 2023 · Apr 9, 2023 · Feb 26, 2023
commit f5650e35dccf0d857c3d973873fccd6f73858585
diff --git a/crates/fluvio-smartengine/src/engine/common/init.rs b/crates/fluvio-smartengine/src/engine/common/init.rs
@@ -1,9 +1,10 @@
-use super::{WasmFn, WasmInstance};
 use anyhow::Result;
 use fluvio_smartmodule::dataplane::smartmodule::{
-    SmartModuleInitInput, SmartModuleInitErrorStatus, SmartModuleInitOutput,
+    SmartModuleInitErrorStatus, SmartModuleInitInput, SmartModuleInitOutput,
 };
 
+use super::{WasmFn, WasmInstance};
+
 pub(crate) const INIT_FN_NAME: &str = "init";
 
 pub(crate) struct SmartModuleInit<F: WasmFn>(F);

diff --git a/crates/fluvio-smartengine/src/engine/common/mod.rs b/crates/fluvio-smartengine/src/engine/common/mod.rs
@@ -2,7 +2,6 @@ mod init;
 mod transforms;
 pub(crate) use init::*;
 pub(crate) use transforms::*;
-
 use anyhow::Result;
 use fluvio_protocol::{Decoder, Encoder};
 use fluvio_smartmodule::dataplane::smartmodule::{

diff --git a/crates/fluvio-smartengine/src/engine/common/transforms/aggregate.rs b/crates/fluvio-smartengine/src/engine/common/transforms/aggregate.rs
@@ -2,10 +2,11 @@
 mod test {
 
     use std::convert::TryFrom;
+
     use fluvio_smartmodule::{dataplane::smartmodule::SmartModuleInput, Record};
 
     use crate::SmartModuleInitialData;
-    use crate::engine::common::{AGGREGATE_FN_NAME};
+    use crate::engine::common::AGGREGATE_FN_NAME;
     use crate::engine::metrics::SmartModuleChainMetrics;
     use crate::engine::{SmartEngine, SmartModuleChainBuilder};
     use crate::engine::config::SmartModuleConfig;

diff --git a/crates/fluvio-smartengine/src/engine/common/transforms/array_map.rs b/crates/fluvio-smartengine/src/engine/common/transforms/array_map.rs
@@ -2,6 +2,7 @@
 mod test {
 
     use std::convert::TryFrom;
+
     use fluvio_smartmodule::{dataplane::smartmodule::SmartModuleInput, Record};
 
     use crate::engine::common::ARRAY_MAP_FN_NAME;

diff --git a/crates/fluvio-smartengine/src/engine/common/transforms/filter.rs b/crates/fluvio-smartengine/src/engine/common/transforms/filter.rs
@@ -2,6 +2,7 @@
 mod test {
 
     use std::convert::TryFrom;
+
     use fluvio_smartmodule::{dataplane::smartmodule::SmartModuleInput, Record};
 
     use crate::engine::common::FILTER_FN_NAME;

diff --git a/crates/fluvio-smartengine/src/engine/common/transforms/filter_map.rs b/crates/fluvio-smartengine/src/engine/common/transforms/filter_map.rs
@@ -2,6 +2,7 @@
 mod test {
 
     use std::convert::TryFrom;
+
     use fluvio_smartmodule::{dataplane::smartmodule::SmartModuleInput, Record};
 
     use crate::engine::common::FILTER_MAP_FN_NAME;

diff --git a/crates/fluvio-smartengine/src/engine/common/transforms/map.rs b/crates/fluvio-smartengine/src/engine/common/transforms/map.rs
@@ -2,6 +2,7 @@
 mod test {
 
     use std::convert::TryFrom;
+
     use fluvio_smartmodule::{dataplane::smartmodule::SmartModuleInput, Record};
 
     use crate::engine::common::MAP_FN_NAME;

diff --git a/crates/fluvio-smartengine/src/engine/common/transforms/mod.rs b/crates/fluvio-smartengine/src/engine/common/transforms/mod.rs
@@ -1,14 +1,14 @@
 use std::any::Any;
+
 use anyhow::Result;
 use fluvio_smartmodule::dataplane::smartmodule::{
-    SmartModuleInput, SmartModuleOutput, SmartModuleTransformErrorStatus,
-    SmartModuleAggregateInput, SmartModuleAggregateOutput,
+    SmartModuleAggregateInput, SmartModuleAggregateOutput, SmartModuleInput, SmartModuleOutput,
+    SmartModuleTransformErrorStatus,
 };
 use tracing::debug;
 
-use crate::{SmartModuleInitialData, engine::error::EngineError};
-
-use super::{WasmInstance, WasmFn};
+use crate::{engine::error::EngineError, SmartModuleInitialData};
+use super::{WasmFn, WasmInstance};
 
 mod filter;
 mod map;

diff --git a/crates/fluvio-smartengine/src/engine/fixture.rs b/crates/fluvio-smartengine/src/engine/fixture.rs
@@ -1,6 +1,4 @@
-use std::{
-    path::{PathBuf, Path},
-};
+use std::path::{Path, PathBuf};
 
 pub(crate) fn read_wasm_module(module_name: &str) -> Vec<u8> {
     let spu_dir = std::env::var("CARGO_MANIFEST_DIR").expect("target");

diff --git a/crates/fluvio-smartengine/src/engine/mod.rs b/crates/fluvio-smartengine/src/engine/mod.rs
@@ -88,6 +88,6 @@ impl SmartModuleChainInstance {
 }
 
 pub(crate) mod wasmtime;
-use self::wasmtime::{SmartEngineImp, initialize_imp, SmartModuleChainInstanceImp};
+use self::wasmtime::{initialize_imp, SmartEngineImp, SmartModuleChainInstanceImp};
 #[cfg(test)]
 use self::wasmtime::WasmFnImp;
diff --git a/crates/fluvio-smartengine/src/engine/wasmtime/imp.rs b/crates/fluvio-smartengine/src/engine/wasmtime/imp.rs
@@ -6,8 +6,7 @@ use fluvio_smartmodule::dataplane::smartmodule::{SmartModuleInput, SmartModuleOu
 use crate::metrics::SmartModuleChainMetrics;
 use crate::engine::SmartModuleChainBuilder;
 use crate::engine::common::create_transform;
-
-use super::instance::{WasmtimeFn, WasmtimeInstance, WasmtimeContext};
+use super::instance::{WasmtimeContext, WasmtimeFn, WasmtimeInstance};
 use super::state::WasmState;
 
 type SmartModuleInit = crate::engine::common::SmartModuleInit<WasmtimeFn>;
@@ -141,8 +140,8 @@ mod chaining_test {
     use fluvio_smartmodule::{dataplane::smartmodule::SmartModuleInput, Record};
 
     use crate::engine::{
-        SmartEngine, SmartModuleChainBuilder, SmartModuleConfig, SmartModuleInitialData,
-        metrics::SmartModuleChainMetrics,
+        metrics::SmartModuleChainMetrics, SmartEngine, SmartModuleChainBuilder, SmartModuleConfig,
+        SmartModuleInitialData,
     };
 
     const SM_FILTER_INIT: &str = "fluvio_smartmodule_filter_init";

diff --git a/crates/fluvio-smartengine/src/engine/wasmtime/instance.rs b/crates/fluvio-smartengine/src/engine/wasmtime/instance.rs
@@ -1,18 +1,16 @@
-use anyhow::Result;
-use fluvio_protocol::{Encoder, Decoder};
-use tracing::debug;
-
 use std::sync::Arc;
 
+use anyhow::Result;
+use fluvio_protocol::{Decoder, Encoder};
+use tracing::debug;
 use fluvio_smartmodule::dataplane::smartmodule::SmartModuleExtraParams;
-use wasmtime::{Instance, Module, Caller, AsContext, Extern};
+use wasmtime::{AsContext, Caller, Extern, Instance, Module};
 
 use crate::engine::{
     common::{WasmFn, WasmInstance},
     error::EngineError,
     wasmtime::memory::RecordsMemory,
 };
-
 use super::{memory::RecordsCallBack, state::WasmState};
 
 pub struct WasmtimeInstance {

diff --git a/crates/fluvio-smartengine/src/engine/wasmtime/memory.rs b/crates/fluvio-smartengine/src/engine/wasmtime/memory.rs
@@ -1,8 +1,7 @@
 use std::sync::Mutex;
 
 use wasmtime::*;
-
-use anyhow::{Result, Error, anyhow};
+use anyhow::{anyhow, Error, Result};
 
 const ALLOC_FN: &str = "alloc";
 const MEMORY: &str = "memory";

diff --git a/crates/fluvio-smartengine/src/engine/wasmtime/mod.rs b/crates/fluvio-smartengine/src/engine/wasmtime/mod.rs
@@ -1,6 +1,6 @@
 /// Implementations of the public API
 mod imp;
-pub use imp::{SmartEngineImp, initialize_imp, SmartModuleChainInstanceImp};
+pub use imp::{initialize_imp, SmartEngineImp, SmartModuleChainInstanceImp};
 /// Implementations of the traits in `common` for the Wasmtime engine
 mod instance;
 #[cfg(test)]

diff --git a/crates/fluvio-smartengine/src/transformation.rs b/crates/fluvio-smartengine/src/transformation.rs
@@ -1,14 +1,15 @@
 use std::{
     collections::BTreeMap,
     fmt::{self, Display},
-    path::PathBuf,
     fs::File,
     io::Read,
     ops::Deref,
+    path::PathBuf,
 };
+
 use serde::{
-    Deserialize, Serialize, Deserializer,
-    de::{Visitor, self, SeqAccess, MapAccess},
+    de::{self, MapAccess, SeqAccess, Visitor},
+    Deserialize, Deserializer, Serialize,
 };
 
 #[derive(Debug, Default, Serialize, Deserialize, Clone, PartialEq, Eq)]