feat(codecs): Implement chunked GELF decoding

.github/actions/spelling/allow.txt

@@ -458,6 +458,7 @@ timestamped
 typesense
 tzdata
 ubuntu
+unchunked
 upstreaminfo
 useragents
 usergroups

Cargo.toml

@@ -149,8 +149,10 @@ prost = { version = "0.12", default-features = false, features = ["std"] }
 prost-build = { version = "0.12", default-features = false }
 prost-reflect = { version = "0.14", features = ["serde"], default-features = false }
 prost-types = { version = "0.12", default-features = false }
+rand = { version = "0.8.5", default-features = false, features = ["small_rng"] }
 serde_json = { version = "1.0.132", default-features = false, features = ["raw_value", "std"] }
 serde = { version = "1.0.214", default-features = false, features = ["alloc", "derive", "rc"] }
+tokio = { version = "1.39.2", default-features = false, features = ["full"] }
 toml = { version = "0.8.19", default-features = false, features = ["display", "parse"] }
 tonic = { version = "0.11", default-features = false, features = ["transport", "codegen", "prost", "tls", "tls-roots", "gzip"] }
 tonic-build = { version = "0.11", default-features = false, features = ["transport", "prost"] }
@@ -336,7 +338,7 @@ paste = "1.0.15"
 percent-encoding = { version = "2.3.1", default-features = false }
 postgres-openssl = { version = "0.5.0", default-features = false, features = ["runtime"], optional = true }
 pulsar = { version = "6.3.0", default-features = false, features = ["tokio-runtime", "auth-oauth2", "flate2", "lz4", "snap", "zstd"], optional = true }
-rand = { version = "0.8.5", default-features = false, features = ["small_rng"] }
+rand.workspace = true
 rand_distr = { version = "0.4.3", default-features = false }
 rdkafka = { version = "0.35.0", default-features = false, features = ["curl-static", "tokio", "libz", "ssl", "zstd"], optional = true }
 redis = { version = "0.24.0", default-features = false, features = ["connection-manager", "tokio-comp", "tokio-native-tls-comp"], optional = true }

changelog.d/20769-chunked_gelf_decoding.feature.md

@@ -0,0 +1,5 @@
+Allows for chunked gelf decoding in message-based sources, such as UDP sockets or unix datagram sockets. Implementation is based on [Graylog's documentation](https://go2docs.graylog.org/5-0/getting_in_log_data/gelf.html#GELFviaUDP).
+
+This framing method can be configured via the `framing.method = "chunked_gelf"` option in the source configuration.
+
+authors: jorgehermo9

lib/codecs/Cargo.toml

@@ -22,6 +22,7 @@ memchr = { version = "2", default-features = false }
 ordered-float = { version = "4.4.0", default-features = false }
 prost.workspace = true
 prost-reflect.workspace = true
+rand.workspace = true
 regex = { version = "1.11.1", default-features = false, features = ["std", "perf"] }
 serde.workspace = true
 serde_with = { version = "3.11.0", default-features = false, features = ["std", "macros", "chrono_0_4"] }
@@ -30,6 +31,7 @@ smallvec = { version = "1", default-features = false, features = ["union"] }
 snafu = { version = "0.7.5", default-features = false, features = ["futures"] }
 syslog_loose = { version = "0.21", default-features = false, optional = true }
 tokio-util = { version = "0.7", default-features = false, features = ["codec"] }
+tokio.workspace = true
 tracing = { version = "0.1", default-features = false }
 vrl.workspace = true
 vector-common = { path = "../vector-common", default-features = false }
@@ -44,8 +46,9 @@ indoc = { version = "2", default-features = false }
 tokio = { version = "1", features = ["test-util"] }
 similar-asserts = "1.6.0"
 vector-core = { path = "../vector-core", default-features = false, features = ["vrl", "test"] }
-uuid.workspace = true
 rstest = "0.23.0"
+tracing-test = "0.2.5"
+uuid.workspace = true
 vrl.workspace = true
 
 [features]