Add names to DataRead variant's fields

Signed-off-by: Vladislav Volodkin <[email protected]>

mountpoint-s3/src/prefetch/backpressure_controller.rs

@@ -8,7 +8,7 @@ use super::PrefetchReadError;
 #[derive(Debug)]
 pub enum BackpressureFeedbackEvent {
     /// An event where data with a certain length has been read out of the stream
-    DataRead(u64, usize),
+    DataRead { offset: u64, length: usize },
     /// An event indicating part queue stall
     PartQueueStall,
 }
@@ -90,7 +90,7 @@ impl BackpressureController {
     pub async fn send_feedback<E>(&mut self, event: BackpressureFeedbackEvent) -> Result<(), PrefetchReadError<E>> {
         match event {
             // Note, that this may come from a backwards seek, so offsets observed by this method are not necessarily ascending
-            BackpressureFeedbackEvent::DataRead(offset, length) => {
+            BackpressureFeedbackEvent::DataRead { offset, length } => {
                 let next_read_offset = offset + length as u64;
                 let remaining_window = self.read_window_end_offset.saturating_sub(next_read_offset);
                 // Increment the read window only if the remaining window reaches some threshold i.e. half of it left.

mountpoint-s3/src/prefetch/task.rs

@@ -55,7 +55,10 @@ impl<E: std::error::Error + Send + Sync> RequestTask<E> {
 
         // We read some data out of the part queue so the read window should be moved
         self.backpressure_controller
-            .send_feedback(DataRead(part.offset(), part.len()))
+            .send_feedback(DataRead {
+                offset: part.offset(),
+                length: part.len(),
+            })
             .await?;
 
         let next_offset = part.offset() + part.len() as u64;