diff --git a/Cargo.lock b/Cargo.lock index 317b523bf9..a37774a87f 100644 --- a/Cargo.lock +++ b/Cargo.lock @@ -1,6 +1,6 @@ # This file is automatically @generated by Cargo. # It is not intended for manual editing. -version = 3 +version = 4 [[package]] name = "adaptive_backoff" @@ -3031,7 +3031,7 @@ dependencies = [ [[package]] name = "fluvio-smartengine" -version = "0.8.2" +version = "0.8.3" dependencies = [ "anyhow", "cfg-if", diff --git a/crates/fluvio-cluster/src/runtime/local/spu.rs b/crates/fluvio-cluster/src/runtime/local/spu.rs index 059699c408..62d770e94f 100644 --- a/crates/fluvio-cluster/src/runtime/local/spu.rs +++ b/crates/fluvio-cluster/src/runtime/local/spu.rs @@ -81,8 +81,8 @@ impl SpuTarget for LocalSpuProcess { const BASE_PORT: u16 = 9010; const BASE_SPU: u16 = 5001; -/// manage spu process cluster +/// Manage SPU Process Cluster pub struct LocalSpuProcessClusterManager { pub log_dir: PathBuf, pub launcher: Option, diff --git a/crates/fluvio-cluster/src/start/local.rs b/crates/fluvio-cluster/src/start/local.rs index 3f3c38358d..7a16e1a593 100644 --- a/crates/fluvio-cluster/src/start/local.rs +++ b/crates/fluvio-cluster/src/start/local.rs @@ -384,7 +384,6 @@ impl LocalInstaller { /// # Ok(()) /// # } /// ``` - pub fn from_config(config: LocalConfig) -> Self { Self { pb_factory: ProgressBarFactory::new(config.hide_spinner), diff --git a/crates/fluvio-controlplane-metadata/Cargo.toml b/crates/fluvio-controlplane-metadata/Cargo.toml index 4ec1e2903e..06639a5ee8 100644 --- a/crates/fluvio-controlplane-metadata/Cargo.toml +++ b/crates/fluvio-controlplane-metadata/Cargo.toml @@ -1,7 +1,7 @@ [package] name = "fluvio-controlplane-metadata" edition = "2021" -version = "0.30.0" +version = "0.30.1" authors = ["Fluvio Contributors "] description = "Metadata definition for Fluvio control plane" repository = "https://github.com/infinyon/fluvio" diff --git a/crates/fluvio-controlplane-metadata/src/smartmodule/package.rs b/crates/fluvio-controlplane-metadata/src/smartmodule/package.rs index df9d061872..e0e439611d 100644 --- a/crates/fluvio-controlplane-metadata/src/smartmodule/package.rs +++ b/crates/fluvio-controlplane-metadata/src/smartmodule/package.rs @@ -300,7 +300,6 @@ impl std::convert::TryFrom<&str> for SmartModuleVisibility { /// Convert from name into something that can be used as key in the store /// For now, we respect - #[cfg(test)] mod package_test { use crate::smartmodule::SmartModulePackageKey; diff --git a/crates/fluvio-controlplane/src/sc_api/api.rs b/crates/fluvio-controlplane/src/sc_api/api.rs index 477e56714a..ea5e142823 100644 --- a/crates/fluvio-controlplane/src/sc_api/api.rs +++ b/crates/fluvio-controlplane/src/sc_api/api.rs @@ -1,3 +1,5 @@ +//! API call from Spu to SC + use std::io::Error as IoError; use std::convert::TryInto; @@ -15,8 +17,6 @@ use super::register_spu::RegisterSpuRequest; use super::update_lrs::UpdateLrsRequest; use super::remove::ReplicaRemovedRequest; -/// API call from Spu to SC - #[repr(u16)] #[derive(Eq, PartialEq, Debug, Encoder, Decoder, Clone, Copy)] #[fluvio(encode_discriminant)] diff --git a/crates/fluvio-smartengine/src/engine/mod.rs b/crates/fluvio-smartengine/src/engine/mod.rs index 45e5eccfb1..eca9f9acbb 100644 --- a/crates/fluvio-smartengine/src/engine/mod.rs +++ b/crates/fluvio-smartengine/src/engine/mod.rs @@ -1,4 +1,4 @@ -/// SmartModule configuration +//! SmartModule configuration mod config; mod error; diff --git a/crates/fluvio-spu/src/control_plane/mod.rs b/crates/fluvio-spu/src/control_plane/mod.rs index 38dcdc791e..809af82804 100644 --- a/crates/fluvio-spu/src/control_plane/mod.rs +++ b/crates/fluvio-spu/src/control_plane/mod.rs @@ -1,4 +1,4 @@ -/// Responsible for communication with SC +//! Responsible for communication with SC mod dispatcher; mod action; diff --git a/crates/fluvio-spu/src/smartengine/produce_batch.rs b/crates/fluvio-spu/src/smartengine/produce_batch.rs index 558e7ac68b..12e8e28df2 100644 --- a/crates/fluvio-spu/src/smartengine/produce_batch.rs +++ b/crates/fluvio-spu/src/smartengine/produce_batch.rs @@ -17,7 +17,7 @@ pub struct ProduceBatchIterator<'a> { len: usize, } -impl<'a> SmartModuleInputBatch for ProduceBatch<'a> { +impl SmartModuleInputBatch for ProduceBatch<'_> { fn records(&self) -> &Vec { &self.records } diff --git a/crates/fluvio-storage/src/index.rs b/crates/fluvio-storage/src/index.rs index cb3f2180b3..341b595856 100644 --- a/crates/fluvio-storage/src/index.rs +++ b/crates/fluvio-storage/src/index.rs @@ -87,8 +87,6 @@ impl OffsetPosition for Entry { /// /// For active segment, index can grow /// For non active, it is fixed - -// implement index file pub struct LogIndex { #[allow(dead_code)] mmap: MemoryMappedFile, diff --git a/crates/fluvio-storage/src/mut_index.rs b/crates/fluvio-storage/src/mut_index.rs index 3734539fe0..559054991e 100644 --- a/crates/fluvio-storage/src/mut_index.rs +++ b/crates/fluvio-storage/src/mut_index.rs @@ -25,8 +25,6 @@ pub const EXTENSION: &str = "index"; /// Index file for offset /// Each entry in index consist of pair of (relative_offset, file_position) - -// implement index file pub struct MutLogIndex { mmap: MemoryMappedMutFile, file: File, diff --git a/crates/fluvio-storage/src/validator.rs b/crates/fluvio-storage/src/validator.rs index 2a3fee4de4..0a973ba049 100644 --- a/crates/fluvio-storage/src/validator.rs +++ b/crates/fluvio-storage/src/validator.rs @@ -260,12 +260,11 @@ impl LogValidator { } } -/// validate the file and find last offset -/// if file is not valid then return error - #[cfg(test)] #[cfg(feature = "fixture")] mod tests { + //! validate the file and find last offset + //! if file is not valid then return error use std::env::temp_dir; diff --git a/crates/fluvio-stream-dispatcher/Cargo.toml b/crates/fluvio-stream-dispatcher/Cargo.toml index 3f4d11ffd8..80336d9672 100644 --- a/crates/fluvio-stream-dispatcher/Cargo.toml +++ b/crates/fluvio-stream-dispatcher/Cargo.toml @@ -1,7 +1,7 @@ [package] name = "fluvio-stream-dispatcher" edition = "2021" -version = "0.13.6" +version = "0.13.7" authors = ["Fluvio Contributors "] description = "Fluvio Event Stream access" repository = "https://github.com/infinyon/fluvio" diff --git a/crates/fluvio-stream-dispatcher/src/metadata/k8.rs b/crates/fluvio-stream-dispatcher/src/metadata/k8.rs index 4bb9fa11e1..e27520285f 100644 --- a/crates/fluvio-stream-dispatcher/src/metadata/k8.rs +++ b/crates/fluvio-stream-dispatcher/src/metadata/k8.rs @@ -493,7 +493,7 @@ mod tests { assert_eq!(updates.len(), 3); assert!( - matches!(updates.first(), Some(LSUpdate::Mod(obj)) if obj.status.to_string().eq("")) + matches!(updates.first(), Some(LSUpdate::Mod(obj)) if obj.status.to_string().is_empty()) ); assert!( matches!(updates.get(1), Some(LSUpdate::Mod(obj)) if obj.status.to_string().eq("new status")) diff --git a/crates/fluvio-stream-dispatcher/src/metadata/local.rs b/crates/fluvio-stream-dispatcher/src/metadata/local.rs index d14ac07da3..00208d00ad 100644 --- a/crates/fluvio-stream-dispatcher/src/metadata/local.rs +++ b/crates/fluvio-stream-dispatcher/src/metadata/local.rs @@ -997,7 +997,7 @@ spec: assert_eq!(updates.len(), 3); assert!( - matches!(updates.first(), Some(LSUpdate::Mod(obj)) if obj.status.to_string().eq("")) + matches!(updates.first(), Some(LSUpdate::Mod(obj)) if obj.status.to_string().is_empty()) ); assert!( matches!(updates.get(1), Some(LSUpdate::Mod(obj)) if obj.status.to_string().eq("new status")) @@ -1214,7 +1214,7 @@ spec: assert_eq!(updates1.len(), 3); assert!( - matches!(updates1.first(), Some(LSUpdate::Mod(obj)) if obj.status.to_string().eq("")) + matches!(updates1.first(), Some(LSUpdate::Mod(obj)) if obj.status.to_string().is_empty()) ); assert!( matches!(updates1.get(1), Some(LSUpdate::Mod(obj)) if obj.status.to_string().eq("new status")) diff --git a/crates/fluvio/src/fluvio.rs b/crates/fluvio/src/fluvio.rs index eba10d03ab..a2c1f9694b 100644 --- a/crates/fluvio/src/fluvio.rs +++ b/crates/fluvio/src/fluvio.rs @@ -328,7 +328,6 @@ impl Fluvio { /// Ok(()) /// } /// ``` - pub async fn consumer_with_config( &self, config: ConsumerConfigExt, diff --git a/crates/fluvio/src/lib.rs b/crates/fluvio/src/lib.rs index 02a1c0110c..be77bb9d34 100644 --- a/crates/fluvio/src/lib.rs +++ b/crates/fluvio/src/lib.rs @@ -2,8 +2,7 @@ feature = "nightly", doc = include_str!("../../../DEVELOPER.md") )] - -#[doc = include_str!("../README.md")] +#![doc = include_str!("../README.md")] mod admin; mod error; diff --git a/release-tools/check-crate-version/toml-diff/src/display.rs b/release-tools/check-crate-version/toml-diff/src/display.rs index d698095bd6..839aed6e05 100644 --- a/release-tools/check-crate-version/toml-diff/src/display.rs +++ b/release-tools/check-crate-version/toml-diff/src/display.rs @@ -4,7 +4,7 @@ use toml::{map::Map, Value as TomlValue}; use crate::{TomlChange, TomlDiff}; -impl<'a> fmt::Display for TomlDiff<'a> { +impl fmt::Display for TomlDiff<'_> { fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result { for change in &self.changes { match change { diff --git a/rust-toolchain.toml b/rust-toolchain.toml index 2e2b8c8521..0193dee360 100644 --- a/rust-toolchain.toml +++ b/rust-toolchain.toml @@ -1,2 +1,2 @@ [toolchain] -channel = "1.82.0" +channel = "1.83.0"