chore: reduce OTEL verbosity

Signed-off-by: jeluard <jeluard@users.noreply.github.com>

Author: jeluard

crates/amaru-network/src/connection.rs

@@ -214,47 +214,40 @@ impl ConnectionProvider for TokioConnections {
 
     fn send(&self, conn: ConnectionId, data: NonEmptyBytes) -> BoxFuture<'static, std::io::Result<()>> {
         let resource = self.inner.clone();
-        let len = data.len();
-        Box::pin(
-            async move {
-                let connection = resource
-                    .connections
-                    .lock()
-                    .get(&conn)
-                    .ok_or_else(|| std::io::Error::other(format!("connection {conn} not found for send")))?
-                    .writer
-                    .clone();
-                tokio::time::timeout(Duration::from_secs(100), connection.lock().await.write_all(&data)).await??;
-                Ok(())
-            }
-            .instrument(tracing::trace_span!("send", %conn, len)),
-        )
+        Box::pin(async move {
+            let connection = resource
+                .connections
+                .lock()
+                .get(&conn)
+                .ok_or_else(|| std::io::Error::other(format!("connection {conn} not found for send")))?
+                .writer
+                .clone();
+            tokio::time::timeout(Duration::from_secs(100), connection.lock().await.write_all(&data)).await??;
+            Ok(())
+        })
     }
 
     fn recv(&self, conn: ConnectionId, bytes: NonZeroUsize) -> BoxFuture<'static, std::io::Result<NonEmptyBytes>> {
         let resource = self.inner.clone();
-        Box::pin(
-            async move {
-                let connection = resource
-                    .connections
-                    .lock()
-                    .get(&conn)
-                    .ok_or_else(|| std::io::Error::other(format!("connection {conn} not found for recv")))?
-                    .reader
-                    .clone();
-                let mut guard = connection.lock().await;
-                let (reader, buf) = &mut *guard;
-                buf.reserve(bytes.get() - buf.remaining().min(bytes.get()));
-                while buf.remaining() < bytes.get() {
-                    if reader.read_buf(buf).await? == 0 {
-                        return Err(std::io::ErrorKind::UnexpectedEof.into());
-                    };
-                }
-                #[expect(clippy::expect_used)]
-                Ok(buf.copy_to_bytes(bytes.get()).try_into().expect("guaranteed by NonZeroUsize"))
+        Box::pin(async move {
+            let connection = resource
+                .connections
+                .lock()
+                .get(&conn)
+                .ok_or_else(|| std::io::Error::other(format!("connection {conn} not found for recv")))?
+                .reader
+                .clone();
+            let mut guard = connection.lock().await;
+            let (reader, buf) = &mut *guard;
+            buf.reserve(bytes.get() - buf.remaining().min(bytes.get()));
+            while buf.remaining() < bytes.get() {
+                if reader.read_buf(buf).await? == 0 {
+                    return Err(std::io::ErrorKind::UnexpectedEof.into());
+                };
             }
-            .instrument(tracing::trace_span!("recv", %conn, bytes)),
-        )
+            #[expect(clippy::expect_used)]
+            Ok(buf.copy_to_bytes(bytes.get()).try_into().expect("guaranteed by NonZeroUsize"))
+        })
     }
 
     fn close(&self, conn: ConnectionId) -> BoxFuture<'static, std::io::Result<()>> {

crates/amaru-protocols/src/mux.rs

@@ -410,7 +410,6 @@ impl Muxer {
         }
     }
 
-    #[instrument(level = "trace", skip_all, fields(proto_id, bytes = bytes.len()))]
     pub fn outgoing(&mut self, proto_id: ProtocolId<Erased>, bytes: Bytes, sent: StageRef<Sent>) {
         tracing::trace!(%proto_id, bytes = bytes.len(), "enqueueing send");
         #[allow(clippy::expect_used)]
@@ -421,7 +420,6 @@ impl Muxer {
             .enqueue_send(bytes, sent);
     }
 
-    #[instrument(level = "trace", skip_all)]
     pub async fn next_segment<M>(&mut self, eff: &Effects<M>) -> Option<(ProtocolId<Erased>, Bytes)> {
         for idx in (self.next_out..self.outgoing.len()).chain(0..self.next_out) {
             let proto_id = self.outgoing[idx];
@@ -437,7 +435,6 @@ impl Muxer {
         None
     }
 
-    #[instrument(level = "trace", skip(self, bytes, eff, proto_id), fields(%proto_id, bytes = bytes.len()))]
     pub async fn received<M>(
         &mut self,
         timestamp: Timestamp,
@@ -452,7 +449,6 @@ impl Muxer {
         }
     }
 
-    #[instrument(level = "trace", skip(self, eff))]
     pub async fn want_next<M>(&mut self, proto_id: ProtocolId<Erased>, eff: &Effects<M>) -> anyhow::Result<()> {
         #[allow(clippy::expect_used)]
         self.protocols

crates/pure-stage/src/tokio.rs

@@ -413,10 +413,7 @@ fn interpreter(
         let tb = || inner.trace_buffer.lock();
         tb().push_resume(name, &StageResponse::Unit);
         loop {
-            let poll = {
-                let _span = tracing::trace_span!("stage.poll", stage = %name).entered();
-                stage.as_mut().poll(&mut Context::from_waker(Waker::noop()))
-            };
+            let poll = stage.as_mut().poll(&mut Context::from_waker(Waker::noop()));
             if let Poll::Ready(state) = poll {
                 return Some(state);
             }