make clippy happy

Author: Damion Werner

malstrom-core/Cargo.toml

@@ -2,6 +2,20 @@
 name = "malstrom"
 version = "0.1.0"
 edition = "2021"
+description = "Malstrom is a distributed, stateful stream processing framework written in Rust."
+license = "MIT OR Apache-2.0"
+repository = "https://github.com/MalstromDevelopers/malstrom"
+readme = "../README.md"
+categories = [
+    "concurrency",
+]
+keywords = [
+    "stream processing",
+    "data processing",
+    "framework",
+    "streaming",
+    "distributed",
+]
 
 [lints]
 workspace = true

malstrom-core/src/coordinator/watchmap.rs

@@ -75,9 +75,9 @@ where
     /// value and applies the function if the key is not already present.
     /// # Arguments
     ///
-    /// - `key` - The key associated with the value to be applied or defaulted.
-    /// - `func` - A function that is applied to the value if the key exists, or to the default
-    ///            value if the key does not exist. It takes a mutable reference to the value.
+    /// -`key` - The key associated with the value to be applied or defaulted.
+    /// -`func` - A function that is applied to the value if the key exists, or to the default
+    ///   value if the key does not exist. It takes a mutable reference to the value.
     ///
     /// After applying the function or inserting a default value, it triggers any pending
     /// notifications that depend on changes to the map.

malstrom-core/src/sources/stateful.rs

@@ -105,7 +105,7 @@ where
 
         let parts = parts.into_iter();
         let part_lister =
-            OperatorBuilder::built_by(&format!("{}-list-parts", name), move |build_context| {
+            OperatorBuilder::built_by(&format!("{name}-list-parts"), move |build_context| {
                 let mut inner = if build_context.worker_id == 0 {
                     Box::new(parts)
                 } else {

malstrom-k8s/runtime/Cargo.toml

@@ -1,7 +1,23 @@
 [package]
 name = "malstrom-k8s"
-version = "0.2.0"
-edition = "2021"
+version = "0.1.0"
+edition = "2024"
+description = "Kubernetes runtime for the Malstrom stream processing framework"
+license = "MIT OR Apache-2.0"
+repository = "https://github.com/MalstromDevelopers/malstrom"
+readme = "../README.md"
+categories = [
+    "concurrency",
+    "api-bindings"
+]
+keywords = [
+    "stream processing",
+    "data processing",
+    "streaming",
+    "distributed",
+    "kubernetes"
+]
+
 
 [dependencies]
 async-stream = "0.3.6"

malstrom-k8s/runtime/src/communication/util.rs

@@ -3,6 +3,7 @@ use tonic::Status;
 
 use crate::CONFIG;
 
+#[allow(clippy::result_large_err)]
 pub(super) fn decode_id(raw: &str) -> Result<u64, Status> {
     raw.parse::<u64>()
         .map_err(|e| Status::invalid_argument(format!("Invalid u64: {e:?}")))

malstrom-k8s/runtime/src/communication/worker_backend.rs

@@ -192,6 +192,7 @@ impl WorkerService for WorkerGrpcServer {
 
 /// Extract from_worker and operator from Metadata. Returning the appropriate status
 /// if they are not present or invalid
+#[allow(clippy::result_large_err)]
 fn extract_metadata(metadata: &MetadataMap) -> Result<(WorkerId, OperatorId), Status> {
     let operator = metadata
         .get("operator-id")

malstrom-kafka/Cargo.toml

@@ -1,7 +1,22 @@
 [package]
 name = "malstrom-kafka"
 version = "0.1.0"
-edition = "2021"
+edition = "2024"
+description = "Kafka protocol sources and sinks for the Malstrom stream processing framework"
+license = "MIT OR Apache-2.0"
+repository = "https://github.com/MalstromDevelopers/malstrom"
+readme = "../README.md"
+categories = [
+    "concurrency",
+    "api-bindings"
+]
+keywords = [
+    "stream processing",
+    "data processing",
+    "kafka",
+    "streaming",
+    "distributed",
+]
 
 [dependencies]
 bon = { version = "3.5.1", features = ["experimental-overwritable"] }