perf: add a resrve method to Injector to avoid repeated resizing

Author: bantonsson

opentelemetry-http/src/lib.rs

@@ -22,6 +22,11 @@ impl Injector for HeaderInjector<'_> {
             }
         }
     }
+
+    /// Reserves capacity for at least `additional` more entries to be inserted.
+    fn reserve(&mut self, additional: usize) {
+        self.0.reserve(additional);
+    }
 }
 
 /// Helper for extracting headers from HTTP Requests. This is used for OpenTelemetry context
@@ -305,4 +310,52 @@ mod tests {
         assert!(got.contains(&"headername1"));
         assert!(got.contains(&"headername2"));
     }
+
+    #[test]
+    fn http_headers_reserve() {
+        let mut carrier = http::HeaderMap::new();
+
+        // Test that reserve doesn't panic and works correctly
+        {
+            let mut injector = HeaderInjector(&mut carrier);
+            injector.reserve(10);
+
+            // Verify the HeaderMap still works after reserve
+            injector.set("test-header", "test-value".to_string());
+        }
+        assert_eq!(
+            HeaderExtractor(&carrier).get("test-header"),
+            Some("test-value")
+        );
+
+        // Test reserve with zero capacity
+        {
+            let mut injector = HeaderInjector(&mut carrier);
+            injector.reserve(0);
+            injector.set("another-header", "another-value".to_string());
+        }
+        assert_eq!(
+            HeaderExtractor(&carrier).get("another-header"),
+            Some("another-value")
+        );
+
+        // Test that capacity is actually reserved (at least the requested amount)
+        let mut new_carrier = http::HeaderMap::new();
+        {
+            let mut new_injector = HeaderInjector(&mut new_carrier);
+            new_injector.reserve(5);
+        }
+        let initial_capacity = new_carrier.capacity();
+
+        // Add some headers and verify capacity doesn't decrease
+        {
+            let mut new_injector = HeaderInjector(&mut new_carrier);
+            for i in 0..3 {
+                new_injector.set(&format!("header-{}", i), format!("value-{}", i));
+            }
+        }
+
+        assert!(new_carrier.capacity() >= initial_capacity);
+        assert!(new_carrier.capacity() >= 5);
+    }
 }

opentelemetry/CHANGELOG.md

@@ -2,6 +2,7 @@
 
 ## vNext
 
+- Add `reserve` method to `opentelemetry::propagation::Injector` to hint at the number of elements that will be added to avoid multiple resize operations of the underlying data structure. Has an empty default implementation.
 - *Breaking* Change return type of `opentelemetry::global::set_tracer_provider` to Unit to align with metrics counterpart
 - Add `get_all` method to `opentelemetry::propagation::Extractor` to return all values of the given propagation key and provide a default implementation.
 

opentelemetry/src/propagation/mod.rs

@@ -31,6 +31,10 @@ pub use text_map_propagator::TextMapPropagator;
 pub trait Injector {
     /// Add a key and value to the underlying data.
     fn set(&mut self, key: &str, value: String);
+
+    #[allow(unused_variables)]
+    /// Hint to reserves capacity for at least `additional` more entries to be inserted.
+    fn reserve(&mut self, additional: usize) {}
 }
 
 /// Extractor provides an interface for removing fields from an underlying struct like `HashMap`
@@ -52,6 +56,11 @@ impl<S: std::hash::BuildHasher> Injector for HashMap<String, String, S> {
     fn set(&mut self, key: &str, value: String) {
         self.insert(key.to_lowercase(), value);
     }
+
+    /// Reserves capacity for at least `additional` more entries to be inserted.
+    fn reserve(&mut self, additional: usize) {
+        self.reserve(additional);
+    }
 }
 
 impl<S: std::hash::BuildHasher> Extractor for HashMap<String, String, S> {
@@ -117,4 +126,37 @@ mod tests {
         assert!(got.contains(&"headername1"));
         assert!(got.contains(&"headername2"));
     }
+
+    #[test]
+    fn hash_map_reserve() {
+        let mut carrier = HashMap::new();
+
+        // Test that reserve doesn't panic and works correctly
+        carrier.reserve(10);
+
+        // Verify the HashMap still works after reserve
+        carrier.set("test_key", "test_value".to_string());
+        assert_eq!(Extractor::get(&carrier, "test_key"), Some("test_value"));
+
+        // Test reserve with zero capacity
+        carrier.reserve(0);
+        carrier.set("another_key", "another_value".to_string());
+        assert_eq!(
+            Extractor::get(&carrier, "another_key"),
+            Some("another_value")
+        );
+
+        // Test that capacity is actually reserved (at least the requested amount)
+        let mut new_carrier = HashMap::new();
+        new_carrier.reserve(5);
+        let initial_capacity = new_carrier.capacity();
+
+        // Add some elements and verify capacity doesn't decrease
+        for i in 0..3 {
+            new_carrier.set(&format!("key{}", i), format!("value{}", i));
+        }
+
+        assert!(new_carrier.capacity() >= initial_capacity);
+        assert!(new_carrier.capacity() >= 5);
+    }
 }