chore(deps): Update VRL to use KeyString type wrapper

Cargo.toml

@@ -119,13 +119,12 @@ members = [
 ]
 
 [workspace.dependencies]
-vrl = { version = "0.8.1", features = ["cli"] }
-
 pin-project = { version = "1.1.3", default-features = false }
+vrl = { git = "https://github.com/vectordotdev/vrl", rev = "37319dfca17dc5d7637b24455199029cc30eb128", features = ["arbitrary", "cli", "test", "test_framework"] }
 
 [dependencies]
-vrl.workspace = true
 pin-project.workspace = true
+vrl.workspace = true
 
 # Internal libs
 dnsmsg-parser = { path = "lib/dnsmsg-parser", optional = true }
@@ -362,7 +361,7 @@ tokio = { version = "1.33.0", features = ["test-util"] }
 tokio-test = "0.4.3"
 tower-test = "0.4.0"
 vector-lib = { path = "lib/vector-lib", default-features = false, features = ["vrl", "test"] }
-vrl = { version = "0.8.1", features = ["cli", "test", "test_framework", "arbitrary"] }
+vrl = {  git = "https://github.com/vectordotdev/vrl", rev = "37319dfca17dc5d7637b24455199029cc30eb128", features = ["cli", "test", "test_framework", "arbitrary"] }
 
 wiremock = "0.5.21"
 zstd = { version = "0.13.0", default-features = false }

lib/codecs/Cargo.toml

@@ -38,8 +38,8 @@ futures = { version = "0.3", default-features = false }
 indoc = { version = "2", default-features = false }
 tokio = { version = "1", features = ["test-util"] }
 similar-asserts = "1.5.0"
-vrl = { version = "0.8.1", features = ["cli", "test", "test_framework", "arbitrary"] }
 vector-core = { path = "../vector-core", default-features = false, features = ["test"] }
+vrl.workspace = true
 
 [features]
 syslog = ["dep:syslog_loose"]

lib/codecs/src/decoding/format/protobuf.rs

@@ -1,4 +1,3 @@
-use std::collections::BTreeMap;
 use std::path::PathBuf;
 
 use bytes::Bytes;
@@ -14,7 +13,7 @@ use vector_core::{
     event::Event,
     schema,
 };
-use vrl::value::Kind;
+use vrl::value::{Kind, ObjectMap};
 
 use crate::common::protobuf::get_message_descriptor;
 
@@ -171,11 +170,11 @@ fn to_vrl(
             }
         }
         prost_reflect::Value::Message(v) => {
-            let mut obj_map = BTreeMap::new();
+            let mut obj_map = ObjectMap::new();
             for field_desc in v.descriptor().fields() {
                 let field_value = v.get_field(&field_desc);
                 let out = to_vrl(field_value.as_ref(), Some(&field_desc))?;
-                obj_map.insert(field_desc.name().to_string(), out);
+                obj_map.insert(field_desc.name().into(), out);
             }
             vrl::value::Value::from(obj_map)
         }
@@ -206,11 +205,11 @@ fn to_vrl(
                                             field_descriptor
                                         )
                                     })?
-                                    .to_string(),
+                                    .into(),
                                 to_vrl(kv.1, Some(&message_desc.map_entry_value_field()))?,
                             ))
                         })
-                        .collect::<vector_common::Result<BTreeMap<String, _>>>()?,
+                        .collect::<vector_common::Result<ObjectMap>>()?,
                 )
             } else {
                 Err("Expected valid field descriptor")?

lib/codecs/src/decoding/format/syslog.rs

@@ -4,13 +4,12 @@ use derivative::Derivative;
 use lookup::{event_path, owned_value_path, OwnedTargetPath, OwnedValuePath};
 use smallvec::{smallvec, SmallVec};
 use std::borrow::Cow;
-use std::collections::BTreeMap;
 use syslog_loose::{IncompleteDate, Message, ProcId, Protocol, Variant};
 use vector_config::configurable_component;
 use vector_core::config::{LegacyKey, LogNamespace};
 use vector_core::{
     config::{log_schema, DataType},
-    event::{Event, LogEvent, Value},
+    event::{Event, LogEvent, ObjectMap, Value},
     schema,
 };
 use vrl::value::{kind::Collection, Kind};
@@ -292,7 +291,7 @@ impl Deserializer for SyslogDeserializer {
                 log
             }
             _ => {
-                let mut log = LogEvent::from(Value::Object(BTreeMap::new()));
+                let mut log = LogEvent::from(Value::Object(ObjectMap::new()));
                 insert_fields_from_syslog(&mut log, parsed, log_namespace);
                 log
             }
@@ -402,15 +401,15 @@ fn insert_metadata_fields_from_syslog(
         );
     }
 
-    let mut sdata: BTreeMap<String, Value> = BTreeMap::new();
+    let mut sdata = ObjectMap::new();
     for element in parsed.structured_data.into_iter() {
-        let mut data: BTreeMap<String, Value> = BTreeMap::new();
+        let mut data = ObjectMap::new();
 
         for (name, value) in element.params() {
-            data.insert(name.to_string(), value.into());
+            data.insert(name.to_string().into(), value.into());
         }
 
-        sdata.insert(element.id.to_string(), data.into());
+        sdata.insert(element.id.into(), data.into());
     }
 
     log_namespace.insert_source_metadata(
@@ -474,9 +473,9 @@ fn insert_fields_from_syslog(
     }
 
     for element in parsed.structured_data.into_iter() {
-        let mut sdata: BTreeMap<String, Value> = BTreeMap::new();
+        let mut sdata = ObjectMap::new();
         for (name, value) in element.params() {
-            sdata.insert(name.to_string(), value.into());
+            sdata.insert(name.to_string().into(), value.into());
         }
         log.insert(event_path!(element.id), sdata);
     }

lib/codecs/src/encoding/format/csv.rs

@@ -309,20 +309,20 @@ mod tests {
     use chrono::DateTime;
     use ordered_float::NotNan;
     use vector_common::btreemap;
-    use vector_core::event::{LogEvent, Value};
+    use vector_core::event::{LogEvent, ObjectMap, Value};
 
     use super::*;
 
     fn make_event_with_fields(field_data: Vec<(&str, &str)>) -> (Vec<ConfigTargetPath>, Event) {
         let mut fields: Vec<ConfigTargetPath> = std::vec::Vec::new();
-        let mut tree = std::collections::BTreeMap::new();
+        let mut tree = ObjectMap::new();
 
-        for (field_name, field_value) in field_data.iter() {
-            let field = ConfigTargetPath::try_from(field_name.to_string()).unwrap();
+        for (field_name, field_value) in field_data.into_iter() {
+            let field = ConfigTargetPath::try_from(field_name.clone()).unwrap();
             fields.push(field);
 
             let field_value = Value::from(field_value.to_string());
-            tree.insert(field_name.to_string().clone(), field_value);
+            tree.insert(field_name.into(), field_value);
         }
 
         let event = Event::Log(LogEvent::from(tree));

lib/codecs/src/encoding/format/gelf.rs

@@ -8,9 +8,7 @@ use snafu::Snafu;
 use tokio_util::codec::Encoder;
 use vector_core::{
     config::{log_schema, DataType},
-    event::Event,
-    event::LogEvent,
-    event::Value,
+    event::{Event, KeyString, LogEvent, Value},
     schema,
 };
 
@@ -26,7 +24,7 @@ use vector_core::{
 #[derive(Debug, Snafu)]
 pub enum GelfSerializerError {
     #[snafu(display(r#"LogEvent does not contain required field: "{}""#, field))]
-    MissingField { field: String },
+    MissingField { field: KeyString },
     #[snafu(display(
         r#"LogEvent contains a value with an invalid type. field = "{}" type = "{}" expected type = "{}""#,
         field,
@@ -158,7 +156,7 @@ fn coerce_field_names_and_values(
     let mut missing_prefix = vec![];
     if let Some(event_data) = log.as_map_mut() {
         for (field, value) in event_data.iter_mut() {
-            match field.as_str() {
+            match &field[..] {
                 VERSION | HOST | SHORT_MESSAGE | FULL_MESSAGE | FACILITY | FILE => {
                     if !value.is_bytes() {
                         err_invalid_type(field, "UTF-8 string", value.kind_str())?;
@@ -194,9 +192,11 @@ fn coerce_field_names_and_values(
                 _ => {
                     // additional fields must be only word chars, dashes and periods.
                     if !VALID_FIELD_REGEX.is_match(field) {
-                        return MissingFieldSnafu { field }
-                            .fail()
-                            .map_err(|e| e.to_string().into());
+                        return MissingFieldSnafu {
+                            field: field.clone(),
+                        }
+                        .fail()
+                        .map_err(|e| e.to_string().into());
                     }
 
                     // additional field values must be only strings or numbers
@@ -238,20 +238,15 @@ fn to_gelf_event(log: LogEvent) -> vector_common::Result<LogEvent> {
 
 #[cfg(test)]
 mod tests {
-    use std::collections::BTreeMap;
-
     use crate::encoding::SerializerConfig;
 
     use super::*;
     use chrono::NaiveDateTime;
     use vector_core::event::{Event, EventMetadata};
     use vrl::btreemap;
-    use vrl::value::Value;
+    use vrl::value::{ObjectMap, Value};
 
-    fn do_serialize(
-        expect_success: bool,
-        event_fields: BTreeMap<String, Value>,
-    ) -> Option<serde_json::Value> {
+    fn do_serialize(expect_success: bool, event_fields: ObjectMap) -> Option<serde_json::Value> {
         let config = GelfSerializerConfig::new();
         let mut serializer = config.build();
         let event: Event = LogEvent::from_map(event_fields, EventMetadata::default()).into();

lib/codecs/src/encoding/format/protobuf.rs

@@ -116,7 +116,7 @@ fn convert_value_raw(
                 for (key, val) in o.into_iter() {
                     match convert_value(&value_field, val) {
                         Ok(prost_val) => {
-                            map.insert(MapKey::String(key), prost_val);
+                            map.insert(MapKey::String(key.into()), prost_val);
                         }
                         Err(e) => return Err(e),
                     }

lib/enrichment/src/find_enrichment_table_records.rs

@@ -132,7 +132,7 @@ impl Function for FindEnrichmentTableRecords {
 #[derive(Debug, Clone)]
 pub struct FindEnrichmentTableRecordsFn {
     table: String,
-    condition: BTreeMap<String, expression::Expr>,
+    condition: BTreeMap<KeyString, expression::Expr>,
     index: Option<IndexHandle>,
     select: Option<Box<dyn Expression>>,
     case_sensitive: Case,
@@ -203,7 +203,7 @@ mod tests {
         };
 
         let tz = TimeZone::default();
-        let object: Value = BTreeMap::new().into();
+        let object: Value = ObjectMap::new().into();
         let mut target = TargetValue {
             value: object,
             metadata: value!({}),

lib/enrichment/src/get_enrichment_table_record.rs

@@ -124,7 +124,7 @@ impl Function for GetEnrichmentTableRecord {
 #[derive(Debug, Clone)]
 pub struct GetEnrichmentTableRecordFn {
     table: String,
-    condition: BTreeMap<String, expression::Expr>,
+    condition: BTreeMap<KeyString, expression::Expr>,
     index: Option<IndexHandle>,
     select: Option<Box<dyn Expression>>,
     case_sensitive: Case,

lib/enrichment/src/lib.rs

@@ -7,12 +7,11 @@ pub mod tables;
 #[cfg(test)]
 mod test_util;
 mod vrl_util;
-use std::collections::BTreeMap;
 
 use dyn_clone::DynClone;
 pub use tables::{TableRegistry, TableSearch};
 use vrl::compiler::Function;
-use vrl::value::Value;
+use vrl::value::{ObjectMap, Value};
 
 #[derive(Copy, Clone, Debug, PartialEq, Eq)]
 pub struct IndexHandle(pub usize);
@@ -49,7 +48,7 @@ pub trait Table: DynClone {
         condition: &'a [Condition<'a>],
         select: Option<&[String]>,
         index: Option<IndexHandle>,
-    ) -> Result<BTreeMap<String, Value>, String>;
+    ) -> Result<ObjectMap, String>;
 
     /// Search the enrichment table data with the given condition.
     /// All conditions must match (AND).
@@ -60,7 +59,7 @@ pub trait Table: DynClone {
         condition: &'a [Condition<'a>],
         select: Option<&[String]>,
         index: Option<IndexHandle>,
-    ) -> Result<Vec<BTreeMap<String, Value>>, String>;
+    ) -> Result<Vec<ObjectMap>, String>;
 
     /// Hints to the enrichment table what data is going to be searched to allow it to index the
     /// data in advance.

lib/enrichment/src/tables.rs

@@ -30,12 +30,12 @@
 //! can be searched.
 
 use std::{
-    collections::{BTreeMap, HashMap},
+    collections::HashMap,
     sync::{Arc, Mutex},
 };
 
 use arc_swap::ArcSwap;
-use vrl::value::Value;
+use vrl::value::ObjectMap;
 
 use super::{Condition, IndexHandle, Table};
 use crate::Case;
@@ -205,7 +205,7 @@ impl TableSearch {
         condition: &'a [Condition<'a>],
         select: Option<&[String]>,
         index: Option<IndexHandle>,
-    ) -> Result<BTreeMap<String, Value>, String> {
+    ) -> Result<ObjectMap, String> {
         let tables = self.0.load();
         if let Some(ref tables) = **tables {
             match tables.get(table) {
@@ -227,7 +227,7 @@ impl TableSearch {
         condition: &'a [Condition<'a>],
         select: Option<&[String]>,
         index: Option<IndexHandle>,
-    ) -> Result<Vec<BTreeMap<String, Value>>, String> {
+    ) -> Result<Vec<ObjectMap>, String> {
         let tables = self.0.load();
         if let Some(ref tables) = **tables {
             match tables.get(table) {
@@ -357,7 +357,7 @@ mod tests {
         registry.finish_load();
 
         assert_eq!(
-            Ok(BTreeMap::from([("field".into(), Value::from("result"))])),
+            Ok(ObjectMap::from([("field".into(), Value::from("result"))])),
             tables_search.find_table_row(
                 "dummy1",
                 Case::Sensitive,
@@ -410,8 +410,8 @@ mod tests {
         // After we finish load there are no tables in the list
         assert!(registry.table_ids().is_empty());
 
-        let mut new_data = BTreeMap::new();
-        new_data.insert("thing".to_string(), Value::Null);
+        let mut new_data = ObjectMap::new();
+        new_data.insert("thing".into(), Value::Null);
 
         let mut tables: TableMap = HashMap::new();
         tables.insert(