bump edition to 2024 (#5750)

* upgrade rustc to 1.86

* upgrade to edition 2024

* rustfmt

Author: trinity-1686a

quickwit/Cargo.toml

@@ -71,7 +71,7 @@ default-members = [
 
 [workspace.package]
 version = "0.8.0"
-edition = "2021"
+edition = "2024"
 homepage = "https://quickwit.io/"
 documentation = "https://quickwit.io/docs/"
 repository = "https://github.com/quickwit-oss/quickwit"

quickwit/quickwit-actors/benches/bench.rs

@@ -13,7 +13,7 @@
 // limitations under the License.
 
 use async_trait::async_trait;
-use criterion::{criterion_group, criterion_main, BenchmarkId, Criterion};
+use criterion::{BenchmarkId, Criterion, criterion_group, criterion_main};
 use quickwit_actors::{Actor, ActorContext, ActorExitStatus, Handler, Universe};
 
 #[derive(Default)]

quickwit/quickwit-actors/src/actor_context.rs

@@ -16,20 +16,20 @@ use std::convert::Infallible;
 use std::fmt;
 use std::future::Future;
 use std::ops::Deref;
-use std::sync::atomic::{AtomicBool, Ordering};
 use std::sync::Arc;
+use std::sync::atomic::{AtomicBool, Ordering};
 use std::time::Duration;
 
 use quickwit_common::metrics::IntCounter;
 use quickwit_common::{KillSwitch, Progress, ProtectedZoneGuard};
 use tokio::sync::{oneshot, watch};
 use tracing::{debug, error};
 
+#[cfg(any(test, feature = "testsuite"))]
+use crate::Universe;
 use crate::actor_state::AtomicState;
 use crate::registry::ActorRegistry;
 use crate::spawn_builder::{SpawnBuilder, SpawnContext};
-#[cfg(any(test, feature = "testsuite"))]
-use crate::Universe;
 use crate::{
     Actor, ActorExitStatus, ActorState, AskError, Command, DeferableReplyHandler, Mailbox,
     SendError, TrySendError,

quickwit/quickwit-actors/src/channel_with_priority.rs

@@ -12,8 +12,8 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 
-use std::sync::atomic::{AtomicBool, Ordering};
 use std::sync::Mutex;
+use std::sync::atomic::{AtomicBool, Ordering};
 
 use flume::TryRecvError;
 use thiserror::Error;

quickwit/quickwit-actors/src/envelope.rs

@@ -29,7 +29,6 @@ use crate::{Actor, ActorContext, ActorExitStatus};
 /// queue with a single type.
 /// Before appending, we capture the right handler implementation
 /// in the form of a `Box<dyn Envelope>`, and append that to the queue.
-
 pub struct Envelope<A> {
     handler_envelope: Box<dyn EnvelopeT<A>>,
     _no_advance_time_guard: Option<NoAdvanceTimeGuard>,

quickwit/quickwit-actors/src/lib.rs

@@ -42,7 +42,7 @@ pub(crate) mod scheduler;
 mod spawn_builder;
 mod supervisor;
 
-pub use scheduler::{start_scheduler, SchedulerClient};
+pub use scheduler::{SchedulerClient, start_scheduler};
 
 #[cfg(test)]
 pub(crate) mod tests;

quickwit/quickwit-actors/src/mailbox.rs

@@ -23,7 +23,7 @@ use quickwit_common::metrics::{GaugeGuard, IntCounter, IntGauge};
 use tokio::sync::oneshot;
 
 use crate::channel_with_priority::{Receiver, Sender, TrySendError};
-use crate::envelope::{wrap_in_envelope, Envelope};
+use crate::envelope::{Envelope, wrap_in_envelope};
 use crate::scheduler::SchedulerClient;
 use crate::{Actor, AskError, Command, DeferableReplyHandler, QueueCapacity, RecvError, SendError};
 

quickwit/quickwit-actors/src/registry.rs

@@ -256,8 +256,8 @@ impl ActorJoinHandle {
 mod tests {
     use std::time::Duration;
 
-    use crate::tests::PingReceiverActor;
     use crate::Universe;
+    use crate::tests::PingReceiverActor;
 
     #[tokio::test]
     async fn test_registry() {

quickwit/quickwit-actors/src/scheduler.rs

@@ -13,8 +13,8 @@
 // limitations under the License.
 
 use std::cmp::Reverse;
-use std::collections::binary_heap::PeekMut;
 use std::collections::BinaryHeap;
+use std::collections::binary_heap::PeekMut;
 use std::future::Future;
 use std::sync::atomic::{AtomicBool, AtomicUsize, Ordering};
 use std::sync::{Arc, Weak};
@@ -361,8 +361,8 @@ impl Scheduler {
 
 #[cfg(test)]
 mod tests {
-    use std::sync::atomic::{AtomicUsize, Ordering};
     use std::sync::Arc;
+    use std::sync::atomic::{AtomicUsize, Ordering};
     use std::time::{Duration, Instant};
 
     use async_trait::async_trait;

quickwit/quickwit-actors/src/spawn_builder.rs

@@ -21,7 +21,7 @@ use tokio::sync::watch;
 use tracing::{debug, error, info};
 
 use crate::envelope::Envelope;
-use crate::mailbox::{create_mailbox, Inbox};
+use crate::mailbox::{Inbox, create_mailbox};
 use crate::registry::{ActorJoinHandle, ActorRegistry};
 use crate::scheduler::{NoAdvanceTimeGuard, SchedulerClient};
 use crate::supervisor::Supervisor;