chore: use Rust 1.83.0

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<PathBuf>,

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),

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 <team@fluvio.io>"]
 description = "Metadata definition for Fluvio control plane"
 repository = "https://github.com/infinyon/fluvio"

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;

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)]

crates/fluvio-smartengine/src/engine/mod.rs

@@ -1,4 +1,4 @@
-/// SmartModule configuration
+//! SmartModule configuration
 
 mod config;
 mod error;

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;

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<u8> {
         &self.records
     }

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,

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,

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;
 

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 <team@fluvio.io>"]
 description = "Fluvio Event Stream access"
 repository = "https://github.com/infinyon/fluvio"

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"))

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"))

crates/fluvio/src/fluvio.rs

@@ -328,7 +328,6 @@ impl Fluvio {
     ///    Ok(())
     /// }
     /// ```
-
     pub async fn consumer_with_config(
         &self,
         config: ConsumerConfigExt,

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;

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 {

rust-toolchain.toml

@@ -1,2 +1,2 @@
 [toolchain]
-channel = "1.82.0"
+channel = "1.83.0"