chore: fix lint warnings (#847)

txpipe · Feb 28, 2025 · 781e5aa · 781e5aa
1 parent 8624681
commit 781e5aa
Show file tree

Hide file tree

Showing 8 changed files with 9 additions and 10 deletions.
diff --git a/src/bin/oura/run_daemon.rs b/src/bin/oura/run_daemon.rs
@@ -1,9 +1,9 @@
 use gasket::daemon::Daemon;
+use oura::daemon::{run_daemon, ConfigRoot, MetricsConfig};
 use oura::framework::*;
 use std::net::SocketAddr;
 use std::sync::Arc;
 use tracing::info;
-use oura::daemon::{run_daemon, ConfigRoot, MetricsConfig};
 
 use crate::console;
 

diff --git a/src/daemon/mod.rs b/src/daemon/mod.rs
@@ -1,9 +1,9 @@
-
 use gasket::daemon::Daemon;
-use crate::{cursor, filters, framework::*, sinks, sources};
 use serde::{Deserialize, Serialize};
 use std::time::Duration;
 
+use crate::{cursor, filters, framework::*, sinks, sources};
+
 #[derive(Debug, Clone, Serialize, Deserialize)]
 pub struct MetricsConfig {
     pub address: Option<String>,
@@ -118,4 +118,3 @@ pub fn run_daemon(config: ConfigRoot) -> Result<Daemon, Error> {
     let daemon = connect_stages(source, filters, sink, cursor, retries)?;
     Ok(daemon)
 }
-
diff --git a/src/filters/select/eval/bytes.rs b/src/filters/select/eval/bytes.rs
@@ -57,7 +57,7 @@ impl Serialize for FlexBytes {
 
 struct FlexBytesVisitor;
 
-impl<'de> Visitor<'de> for FlexBytesVisitor {
+impl Visitor<'_> for FlexBytesVisitor {
     type Value = FlexBytes;
 
     fn expecting(&self, formatter: &mut fmt::Formatter) -> fmt::Result {

diff --git a/src/framework/legacy_v1.rs b/src/framework/legacy_v1.rs
@@ -400,7 +400,7 @@ where
 
 #[derive(Debug)]
 struct IntScalarVisitor;
-impl<'de> Visitor<'de> for IntScalarVisitor {
+impl Visitor<'_> for IntScalarVisitor {
     type Value = i128;
 
     fn expecting(&self, formatter: &mut std::fmt::Formatter) -> std::fmt::Result {

diff --git a/src/lib.rs b/src/lib.rs
@@ -1,6 +1,6 @@
 pub mod cursor;
+pub mod daemon;
 pub mod filters;
 pub mod framework;
 pub mod sinks;
 pub mod sources;
-pub mod daemon;
diff --git a/src/sinks/aws_lambda.rs b/src/sinks/aws_lambda.rs
@@ -13,7 +13,7 @@ pub struct Worker {
 #[async_trait::async_trait(?Send)]
 impl gasket::framework::Worker<Stage> for Worker {
     async fn bootstrap(stage: &Stage) -> Result<Self, WorkerError> {
-        let aws_config = aws_config::defaults(BehaviorVersion::v2023_11_09())
+        let aws_config = aws_config::defaults(BehaviorVersion::v2024_03_28())
             .region(Region::new(stage.config.region.clone()))
             .load()
             .await;

diff --git a/src/sinks/aws_s3.rs b/src/sinks/aws_s3.rs
@@ -14,7 +14,7 @@ pub struct Worker {
 #[async_trait::async_trait(?Send)]
 impl gasket::framework::Worker<Stage> for Worker {
     async fn bootstrap(stage: &Stage) -> Result<Self, WorkerError> {
-        let aws_config = aws_config::defaults(BehaviorVersion::v2023_11_09())
+        let aws_config = aws_config::defaults(BehaviorVersion::v2024_03_28())
             .region(Region::new(stage.config.region.clone()))
             .load()
             .await;

diff --git a/src/sinks/aws_sqs.rs b/src/sinks/aws_sqs.rs
@@ -14,7 +14,7 @@ pub struct Worker {
 #[async_trait::async_trait(?Send)]
 impl gasket::framework::Worker<Stage> for Worker {
     async fn bootstrap(stage: &Stage) -> Result<Self, WorkerError> {
-        let aws_config = aws_config::defaults(BehaviorVersion::v2023_11_09())
+        let aws_config = aws_config::defaults(BehaviorVersion::v2024_03_28())
             .region(Region::new(stage.config.region.clone()))
             .load()
             .await;