diff --git a/src/bin/oura/run_daemon.rs b/src/bin/oura/run_daemon.rs index d0c67b0c..e9378ef7 100644 --- 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 index 3634c115..57616749 100644 --- 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, @@ -118,4 +118,3 @@ pub fn run_daemon(config: ConfigRoot) -> Result { 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 index 037402f5..a4258c49 100644 --- 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 index b79dc020..7395fae2 100644 --- 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 index 23f77b3d..dae2a06a 100644 --- 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 index 20774e74..04caafb7 100644 --- 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 for Worker { async fn bootstrap(stage: &Stage) -> Result { - 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 index 799ed568..f1e8e26d 100644 --- 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 for Worker { async fn bootstrap(stage: &Stage) -> Result { - 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 index c923d18a..55cb4667 100644 --- 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 for Worker { async fn bootstrap(stage: &Stage) -> Result { - 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;