Rust 1.71.1 update

Signed-off-by: Heinz N. Gies <heinz@licenser.net>

Dockerfile

@@ -1,4 +1,4 @@
-FROM rust:1.70-bullseye as builder
+FROM rust:1.71-bullseye as builder
 
 # Avoid warnings by switching to noninteractive
 ENV DEBIAN_FRONTEND=noninteractive

Dockerfile.learn

@@ -1,4 +1,4 @@
-FROM rust:1.70-bullseye as builder
+FROM rust:1.71-bullseye as builder
 
 RUN cargo install --features=ssl websocat
 

Dockerfile.native

@@ -1,4 +1,4 @@
-FROM rust:1.70-bullseye as builder
+FROM rust:1.71-bullseye as builder
 
 # Avoid warnings by switching to noninteractive
 ENV DEBIAN_FRONTEND=noninteractive

rust-toolchain

@@ -1 +1 @@
-1.70.0
+1.71.1

src/codec/json.rs

@@ -62,7 +62,7 @@ impl<S: Sorting> Clone for Json<S> {
 impl<S: Sorting> Default for Json<S> {
     fn default() -> Self {
         Self {
-            _phantom: PhantomData::default(),
+            _phantom: PhantomData,
             input_buffer: AlignedBuf::with_capacity(1024),
             string_buffer: vec![0u8; 1024],
             data_buf: Vec::new(),

src/connectors/impls/gpubsub/consumer.rs

@@ -108,7 +108,7 @@ impl ConnectorBuilder for Builder {
             config,
             url,
             client_id,
-            _phantom: PhantomData::default(),
+            _phantom: PhantomData,
         }))
     }
 }

src/connectors/impls/gpubsub/producer.rs

@@ -79,7 +79,7 @@ impl ConnectorBuilder for Builder {
 
         Ok(Box::new(GpubConnectorWithTokenProvider {
             config,
-            _phantom: PhantomData::default(),
+            _phantom: PhantomData,
         }))
     }
 }

src/connectors/sink/channel_sink.rs

@@ -168,7 +168,7 @@ where
             tx,
             rx,
             reply_tx,
-            _b: PhantomData::default(),
+            _b: PhantomData,
             sink_is_connected,
         }
     }

src/connectors/utils/url.rs

@@ -103,7 +103,7 @@ impl<D: Defaults> Clone for Url<D> {
     fn clone(&self) -> Self {
         Self {
             url: self.url.clone(),
-            _marker: PhantomData::default(),
+            _marker: PhantomData,
         }
     }
 }
@@ -126,7 +126,7 @@ impl<D: Defaults> Default for Url<D> {
             url: url::Url::parse(&format!("{}://{}:{}", D::SCHEME, D::HOST, D::PORT))
                 // ALLOW: this is a known safe url
                 .expect("DEFAULT URL INVALID"),
-            _marker: PhantomData::default(),
+            _marker: PhantomData,
         }
     }
 }

tremor-common/src/ids.rs

@@ -198,7 +198,7 @@ impl<T: Id> IdGen<T> {
     pub fn new() -> Self {
         Self {
             current: 0,
-            _marker: PhantomData::default(),
+            _marker: PhantomData,
         }
     }
     /// return the next id for this generator

tremor-script/src/ast/deploy/raw.rs

@@ -73,7 +73,7 @@ pub struct DeployRaw<'script> {
 impl<'script> DeployRaw<'script> {
     pub(crate) fn up_script<'registry>(
         self,
-        mut helper: &mut Helper<'script, 'registry>,
+        helper: &mut Helper<'script, 'registry>,
     ) -> Result<Deploy<'script>> {
         let mut stmts: Vec<DeployStmt<'script>> = vec![];
         for (_i, stmt) in self.stmts.into_iter().enumerate() {

tremor-script/src/ast/raw.rs

@@ -78,7 +78,7 @@ impl<'script> ScriptRaw<'script> {
     #[allow(clippy::too_many_lines)]
     pub(crate) fn up_script<'registry>(
         self,
-        mut helper: &mut Helper<'script, 'registry>,
+        helper: &mut Helper<'script, 'registry>,
     ) -> Result<Script<'script>> {
         helper.enter_scope();
         let mut exprs = vec![];