This is an automated email from the ASF dual-hosted git repository.
mgrigorov pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/avro.git
The following commit(s) were added to refs/heads/main by this push:
new 5f0776b35 AVRO-3631: [Rust] Efficient (de)serialization for optional
bytes (#3029)
5f0776b35 is described below
commit 5f0776b358fd10fa6062d042e513219d158b525e
Author: Romain Leroux <[email protected]>
AuthorDate: Fri Jul 19 13:25:31 2024 +0200
AVRO-3631: [Rust] Efficient (de)serialization for optional bytes (#3029)
---
lang/rust/avro/src/bytes.rs | 462 +++++++++++++++++++++++++++++++++++++++-----
lang/rust/avro/src/lib.rs | 5 +-
2 files changed, 417 insertions(+), 50 deletions(-)
diff --git a/lang/rust/avro/src/bytes.rs b/lang/rust/avro/src/bytes.rs
index c301fc003..5c10df27b 100644
--- a/lang/rust/avro/src/bytes.rs
+++ b/lang/rust/avro/src/bytes.rs
@@ -39,9 +39,10 @@ pub(crate) enum BytesType {
/// Efficient (de)serialization of Avro bytes values.
///
-/// This module is intended to be used through the Serde `with` attribute. See
below
-/// example:
+/// This module is intended to be used through the Serde `with` attribute. Use
+/// [`serde_avro_bytes_opt`](crate::serde_avro_bytes_opt) for optional bytes.
///
+/// See usage with below example:
/// ```rust
/// use apache_avro::{serde_avro_bytes, serde_avro_fixed};
/// use serde::{Deserialize, Serialize};
@@ -58,20 +59,66 @@ pub(crate) enum BytesType {
pub mod serde_avro_bytes {
use serde::{Deserializer, Serializer};
- pub fn serialize<S: Serializer>(bytes: &[u8], serializer: S) ->
Result<S::Ok, S::Error> {
+ pub fn serialize<S>(bytes: &[u8], serializer: S) -> Result<S::Ok, S::Error>
+ where
+ S: Serializer,
+ {
serde_bytes::serialize(bytes, serializer)
}
- pub fn deserialize<'de, D: Deserializer<'de>>(deserializer: D) ->
Result<Vec<u8>, D::Error> {
+ pub fn deserialize<'de, D>(deserializer: D) -> Result<Vec<u8>, D::Error>
+ where
+ D: Deserializer<'de>,
+ {
+ serde_bytes::deserialize(deserializer)
+ }
+}
+
+/// Efficient (de)serialization of optional Avro bytes values.
+///
+/// This module is intended to be used through the Serde `with` attribute. Use
+/// [`serde_avro_bytes`](crate::serde_avro_bytes) for non optional bytes.
+///
+/// See usage with below example:
+/// ```rust
+/// use apache_avro::{serde_avro_bytes_opt, serde_avro_fixed_opt};
+/// use serde::{Deserialize, Serialize};
+///
+/// #[derive(Serialize, Deserialize)]
+/// struct StructWithBytes {
+/// #[serde(with = "serde_avro_bytes_opt")]
+/// vec_field: Option<Vec<u8>>,
+///
+/// #[serde(with = "serde_avro_fixed_opt")]
+/// fixed_field: Option<[u8; 6]>,
+/// }
+/// ```
+pub mod serde_avro_bytes_opt {
+ use serde::{Deserializer, Serializer};
+ use std::borrow::Borrow;
+
+ pub fn serialize<S, B>(bytes: &Option<B>, serializer: S) -> Result<S::Ok,
S::Error>
+ where
+ S: Serializer,
+ B: Borrow<[u8]> + serde_bytes::Serialize,
+ {
+ serde_bytes::serialize(bytes, serializer)
+ }
+
+ pub fn deserialize<'de, D>(deserializer: D) -> Result<Option<Vec<u8>>,
D::Error>
+ where
+ D: Deserializer<'de>,
+ {
serde_bytes::deserialize(deserializer)
}
}
/// Efficient (de)serialization of Avro fixed values.
///
-/// This module is intended to be used through the Serde `with` attribute. See
below
-/// example:
+/// This module is intended to be used through the Serde `with` attribute. Use
+/// [`serde_avro_fixed_opt`](crate::serde_avro_fixed_opt) for optional fixed
values.
///
+/// See usage with below example:
/// ```rust
/// use apache_avro::{serde_avro_bytes, serde_avro_fixed};
/// use serde::{Deserialize, Serialize};
@@ -89,16 +136,63 @@ pub mod serde_avro_fixed {
use super::{BytesType, SER_BYTES_TYPE};
use serde::{Deserializer, Serializer};
- pub fn serialize<S: Serializer>(bytes: &[u8], serializer: S) ->
Result<S::Ok, S::Error> {
+ pub fn serialize<S>(bytes: &[u8], serializer: S) -> Result<S::Ok, S::Error>
+ where
+ S: Serializer,
+ {
+ SER_BYTES_TYPE.set(BytesType::Fixed);
+ let res = serde_bytes::serialize(bytes, serializer);
+ SER_BYTES_TYPE.set(BytesType::Bytes);
+ res
+ }
+
+ pub fn deserialize<'de, D, const N: usize>(deserializer: D) -> Result<[u8;
N], D::Error>
+ where
+ D: Deserializer<'de>,
+ {
+ serde_bytes::deserialize(deserializer)
+ }
+}
+
+/// Efficient (de)serialization of optional Avro fixed values.
+///
+/// This module is intended to be used through the Serde `with` attribute. Use
+/// [`serde_avro_fixed`](crate::serde_avro_fixed) for non optional fixed
values.
+///
+/// See usage with below example:
+/// ```rust
+/// use apache_avro::{serde_avro_bytes_opt, serde_avro_fixed_opt};
+/// use serde::{Deserialize, Serialize};
+///
+/// #[derive(Serialize, Deserialize)]
+/// struct StructWithBytes {
+/// #[serde(with = "serde_avro_bytes_opt")]
+/// vec_field: Option<Vec<u8>>,
+///
+/// #[serde(with = "serde_avro_fixed_opt")]
+/// fixed_field: Option<[u8; 6]>,
+/// }
+/// ```
+pub mod serde_avro_fixed_opt {
+ use super::{BytesType, SER_BYTES_TYPE};
+ use serde::{Deserializer, Serializer};
+ use std::borrow::Borrow;
+
+ pub fn serialize<S, B>(bytes: &Option<B>, serializer: S) -> Result<S::Ok,
S::Error>
+ where
+ S: Serializer,
+ B: Borrow<[u8]> + serde_bytes::Serialize,
+ {
SER_BYTES_TYPE.set(BytesType::Fixed);
let res = serde_bytes::serialize(bytes, serializer);
SER_BYTES_TYPE.set(BytesType::Bytes);
res
}
- pub fn deserialize<'de, D: Deserializer<'de>, const N: usize>(
- deserializer: D,
- ) -> Result<[u8; N], D::Error> {
+ pub fn deserialize<'de, D, const N: usize>(deserializer: D) ->
Result<Option<[u8; N]>, D::Error>
+ where
+ D: Deserializer<'de>,
+ {
serde_bytes::deserialize(deserializer)
}
}
@@ -110,8 +204,10 @@ pub mod serde_avro_fixed {
/// [`Value::Bytes`](crate::types::Value::Bytes). However, both
/// [`Value::Bytes`](crate::types::Value::Bytes) and
/// [`Value::Fixed`](crate::types::Value::Fixed) can be deserialized as `bytes:
-/// &[u8]`. See below example:
+/// &[u8]`. Use [`serde_avro_slice_opt`](crate::serde_avro_slice_opt) for
optional
+/// bytes/fixed borrowed values.
///
+/// See usage with below example:
/// ```rust
/// use apache_avro::serde_avro_slice;
/// use serde::{Deserialize, Serialize};
@@ -126,11 +222,62 @@ pub mod serde_avro_slice {
use super::DE_BYTES_BORROWED;
use serde::{Deserializer, Serializer};
- pub fn serialize<S: Serializer>(bytes: &[u8], serializer: S) ->
Result<S::Ok, S::Error> {
+ pub fn serialize<S>(bytes: &[u8], serializer: S) -> Result<S::Ok, S::Error>
+ where
+ S: Serializer,
+ {
serde_bytes::serialize(bytes, serializer)
}
- pub fn deserialize<'de, D: Deserializer<'de>>(deserializer: D) ->
Result<&'de [u8], D::Error> {
+ pub fn deserialize<'de, D>(deserializer: D) -> Result<&'de [u8], D::Error>
+ where
+ D: Deserializer<'de>,
+ {
+ DE_BYTES_BORROWED.set(true);
+ let res = serde_bytes::deserialize(deserializer);
+ DE_BYTES_BORROWED.set(false);
+ res
+ }
+}
+
+/// Efficient (de)serialization of optional Avro bytes/fixed borrowed values.
+///
+/// This module is intended to be used through the Serde `with` attribute.
Note that
+/// `bytes: &[u8]` are always serialized as
+/// [`Value::Bytes`](crate::types::Value::Bytes). However, both
+/// [`Value::Bytes`](crate::types::Value::Bytes) and
+/// [`Value::Fixed`](crate::types::Value::Fixed) can be deserialized as `bytes:
+/// &[u8]`. Use [`serde_avro_slice`](crate::serde_avro_slice) for non optional
+/// bytes/fixed borrowed values.
+///
+/// See usage with below example:
+/// ```rust
+/// use apache_avro::serde_avro_slice_opt;
+/// use serde::{Deserialize, Serialize};
+///
+/// #[derive(Serialize, Deserialize)]
+/// struct StructWithBytes<'a> {
+/// #[serde(with = "serde_avro_slice_opt")]
+/// slice_field: Option<&'a [u8]>,
+/// }
+/// ```
+pub mod serde_avro_slice_opt {
+ use super::DE_BYTES_BORROWED;
+ use serde::{Deserializer, Serializer};
+ use std::borrow::Borrow;
+
+ pub fn serialize<S, B>(bytes: &Option<B>, serializer: S) -> Result<S::Ok,
S::Error>
+ where
+ S: Serializer,
+ B: Borrow<[u8]> + serde_bytes::Serialize,
+ {
+ serde_bytes::serialize(&bytes, serializer)
+ }
+
+ pub fn deserialize<'de, D>(deserializer: D) -> Result<Option<&'de [u8]>,
D::Error>
+ where
+ D: Deserializer<'de>,
+ {
DE_BYTES_BORROWED.set(true);
let res = serde_bytes::deserialize(deserializer);
DE_BYTES_BORROWED.set(false);
@@ -150,45 +297,62 @@ mod tests {
struct TestStructWithBytes<'a> {
#[serde(with = "serde_avro_bytes")]
vec_field: Vec<u8>,
+ #[serde(with = "serde_avro_bytes_opt")]
+ vec_field_opt: Option<Vec<u8>>,
#[serde(with = "serde_avro_fixed")]
fixed_field: [u8; 6],
+ #[serde(with = "serde_avro_fixed_opt")]
+ fixed_field_opt: Option<[u8; 7]>,
#[serde(with = "serde_avro_slice")]
slice_field: &'a [u8],
+ #[serde(with = "serde_avro_slice_opt")]
+ slice_field_opt: Option<&'a [u8]>,
}
let test = TestStructWithBytes {
vec_field: vec![2, 3, 4],
+ vec_field_opt: Some(vec![2, 3, 4]),
fixed_field: [1; 6],
+ fixed_field_opt: Some([1; 7]),
slice_field: &[1, 2, 3],
+ slice_field_opt: Some(&[1, 2, 3]),
};
let value: Value = to_value(test).unwrap();
let schema = Schema::parse_str(
r#"
{
- "type": "record",
- "name": "TestStructFixedField",
- "fields": [
- {
- "name": "vec_field",
- "type": "bytes"
- },
- {
- "name": "fixed_field",
- "type": {
- "name": "fixed_field",
- "type": "fixed",
- "size": 6
- }
- },
- {
- "name": "slice_field",
- "type": "bytes"
- }
- ]
- }
- "#,
+ "type": "record",
+ "name": "TestStructWithBytes",
+ "fields": [ {
+ "name": "vec_field",
+ "type": "bytes"
+ }, {
+ "name": "vec_field_opt",
+ "type": ["null", "bytes"]
+ }, {
+ "name": "fixed_field",
+ "type": {
+ "name": "ByteData",
+ "type": "fixed",
+ "size": 6
+ }
+ }, {
+ "name": "fixed_field_opt",
+ "type": ["null", {
+ "name": "ByteData2",
+ "type": "fixed",
+ "size": 7
+ } ]
+ }, {
+ "name": "slice_field",
+ "type": "bytes"
+ }, {
+ "name": "slice_field_opt",
+ "type": ["null", "bytes"]
+ } ]
+ }"#,
)
.unwrap();
assert!(value.validate(&schema));
@@ -200,21 +364,46 @@ mod tests {
struct TestStructWithBytes<'a> {
#[serde(with = "serde_avro_bytes")]
vec_field: Vec<u8>,
+ #[serde(with = "serde_avro_bytes_opt")]
+ vec_field_opt: Option<Vec<u8>>,
+ #[serde(with = "serde_avro_bytes_opt")]
+ vec_field_opt2: Option<Vec<u8>>,
#[serde(with = "serde_avro_fixed")]
fixed_field: [u8; 6],
+ #[serde(with = "serde_avro_fixed_opt")]
+ fixed_field_opt: Option<[u8; 7]>,
+ #[serde(with = "serde_avro_fixed_opt")]
+ fixed_field_opt2: Option<[u8; 8]>,
#[serde(with = "serde_avro_slice")]
- slice_field: &'a [u8],
+ slice_bytes_field: &'a [u8],
+ #[serde(with = "serde_avro_slice_opt")]
+ slice_bytes_field_opt: Option<&'a [u8]>,
+ #[serde(with = "serde_avro_slice_opt")]
+ slice_bytes_field_opt2: Option<&'a [u8]>,
+
#[serde(with = "serde_avro_slice")]
- slice_field2: &'a [u8],
+ slice_fixed_field: &'a [u8],
+ #[serde(with = "serde_avro_slice_opt")]
+ slice_fixed_field_opt: Option<&'a [u8]>,
+ #[serde(with = "serde_avro_slice_opt")]
+ slice_fixed_field_opt2: Option<&'a [u8]>,
}
let expected = TestStructWithBytes {
vec_field: vec![3, 33],
+ vec_field_opt: Some(vec![4, 44]),
+ vec_field_opt2: None,
fixed_field: [1; 6],
- slice_field: &[1, 11, 111],
- slice_field2: &[2, 22, 222],
+ fixed_field_opt: Some([7; 7]),
+ fixed_field_opt2: None,
+ slice_bytes_field: &[1, 11, 111],
+ slice_bytes_field_opt: Some(&[5, 5, 5, 5, 5]),
+ slice_bytes_field_opt2: None,
+ slice_fixed_field: &[2, 22, 222],
+ slice_fixed_field_opt: Some(&[3, 3, 3]),
+ slice_fixed_field_opt2: None,
};
let value = Value::Record(vec![
@@ -222,17 +411,74 @@ mod tests {
"vec_field".to_owned(),
Value::Bytes(expected.vec_field.clone()),
),
+ (
+ "vec_field_opt".to_owned(),
+ Value::Union(
+ 1,
+ Box::new(Value::Bytes(
+ expected.vec_field_opt.as_ref().unwrap().clone(),
+ )),
+ ),
+ ),
+ (
+ "vec_field_opt2".to_owned(),
+ Value::Union(0, Box::new(Value::Null)),
+ ),
(
"fixed_field".to_owned(),
Value::Fixed(expected.fixed_field.len(),
expected.fixed_field.to_vec()),
),
(
- "slice_field".to_owned(),
- Value::Bytes(expected.slice_field.to_vec()),
+ "fixed_field_opt".to_owned(),
+ Value::Union(
+ 1,
+ Box::new(Value::Fixed(
+ expected.fixed_field_opt.as_ref().unwrap().len(),
+ expected.fixed_field_opt.as_ref().unwrap().to_vec(),
+ )),
+ ),
+ ),
+ (
+ "fixed_field_opt2".to_owned(),
+ Value::Union(0, Box::new(Value::Null)),
+ ),
+ (
+ "slice_bytes_field".to_owned(),
+ Value::Bytes(expected.slice_bytes_field.to_vec()),
),
(
- "slice_field2".to_owned(),
- Value::Fixed(expected.slice_field2.len(),
expected.slice_field2.to_vec()),
+ "slice_bytes_field_opt".to_owned(),
+ Value::Union(
+ 1,
+ Box::new(Value::Bytes(
+
expected.slice_bytes_field_opt.as_ref().unwrap().to_vec(),
+ )),
+ ),
+ ),
+ (
+ "slice_bytes_field_opt2".to_owned(),
+ Value::Union(0, Box::new(Value::Null)),
+ ),
+ (
+ "slice_fixed_field".to_owned(),
+ Value::Fixed(
+ expected.slice_fixed_field.len(),
+ expected.slice_fixed_field.to_vec(),
+ ),
+ ),
+ (
+ "slice_fixed_field_opt".to_owned(),
+ Value::Union(
+ 1,
+ Box::new(Value::Fixed(
+ expected.slice_fixed_field_opt.as_ref().unwrap().len(),
+
expected.slice_fixed_field_opt.as_ref().unwrap().to_vec(),
+ )),
+ ),
+ ),
+ (
+ "slice_fixed_field_opt2".to_owned(),
+ Value::Union(1, Box::new(Value::Null)),
),
]);
assert_eq!(expected, from_value(&value).unwrap());
@@ -241,35 +487,74 @@ mod tests {
#[test]
fn avro_3631_serialize_struct_to_value_with_byte_types() {
#[derive(Debug, Serialize)]
- struct TestStructFixedField<'a> {
+ struct TestStructWithBytes<'a> {
array_field: &'a [u8],
-
vec_field: Vec<u8>,
+
#[serde(with = "serde_avro_fixed")]
vec_field2: Vec<u8>,
+ #[serde(with = "serde_avro_fixed_opt")]
+ vec_field2_opt: Option<Vec<u8>>,
+ #[serde(with = "serde_avro_fixed_opt")]
+ vec_field2_opt2: Option<Vec<u8>>,
+
#[serde(with = "serde_avro_bytes")]
vec_field3: Vec<u8>,
+ #[serde(with = "serde_avro_bytes_opt")]
+ vec_field3_opt: Option<Vec<u8>>,
+ #[serde(with = "serde_avro_bytes_opt")]
+ vec_field3_opt2: Option<Vec<u8>>,
#[serde(with = "serde_avro_fixed")]
fixed_field: [u8; 6],
+ #[serde(with = "serde_avro_fixed_opt")]
+ fixed_field_opt: Option<[u8; 5]>,
+ #[serde(with = "serde_avro_fixed_opt")]
+ fixed_field_opt2: Option<[u8; 4]>,
+
#[serde(with = "serde_avro_fixed")]
fixed_field2: &'a [u8],
+ #[serde(with = "serde_avro_fixed_opt")]
+ fixed_field2_opt: Option<&'a [u8]>,
+ #[serde(with = "serde_avro_fixed_opt")]
+ fixed_field2_opt2: Option<&'a [u8]>,
#[serde(with = "serde_avro_bytes")]
bytes_field: &'a [u8],
+ #[serde(with = "serde_avro_bytes_opt")]
+ bytes_field_opt: Option<&'a [u8]>,
+ #[serde(with = "serde_avro_bytes_opt")]
+ bytes_field_opt2: Option<&'a [u8]>,
+
#[serde(with = "serde_avro_bytes")]
bytes_field2: [u8; 6],
+ #[serde(with = "serde_avro_bytes_opt")]
+ bytes_field2_opt: Option<[u8; 7]>,
+ #[serde(with = "serde_avro_bytes_opt")]
+ bytes_field2_opt2: Option<[u8; 8]>,
}
- let test = TestStructFixedField {
+ let test = TestStructWithBytes {
array_field: &[1, 11, 111],
vec_field: vec![3, 33],
vec_field2: vec![4, 44],
+ vec_field2_opt: Some(vec![14, 144]),
+ vec_field2_opt2: None,
vec_field3: vec![5, 55],
+ vec_field3_opt: Some(vec![15, 155]),
+ vec_field3_opt2: None,
fixed_field: [1; 6],
+ fixed_field_opt: Some([6; 5]),
+ fixed_field_opt2: None,
fixed_field2: &[6, 66],
+ fixed_field2_opt: Some(&[7, 77]),
+ fixed_field2_opt2: None,
bytes_field: &[2, 22, 222],
+ bytes_field_opt: Some(&[3, 33, 233]),
+ bytes_field_opt2: None,
bytes_field2: [2; 6],
+ bytes_field2_opt: Some([2; 7]),
+ bytes_field2_opt2: None,
};
let expected = Value::Record(vec![
(
@@ -292,28 +577,107 @@ mod tests {
),
(
"vec_field2".to_owned(),
- Value::Fixed(2, test.vec_field2.clone()),
+ Value::Fixed(test.vec_field2.len(), test.vec_field2.clone()),
+ ),
+ (
+ "vec_field2_opt".to_owned(),
+ Value::Union(
+ 1,
+ Box::new(Value::Fixed(
+ test.vec_field2_opt.as_ref().unwrap().len(),
+ test.vec_field2_opt.as_ref().unwrap().to_vec(),
+ )),
+ ),
+ ),
+ (
+ "vec_field2_opt2".to_owned(),
+ Value::Union(0, Box::new(Value::Null)),
),
(
"vec_field3".to_owned(),
Value::Bytes(test.vec_field3.clone()),
),
+ (
+ "vec_field3_opt".to_owned(),
+ Value::Union(
+ 1,
+
Box::new(Value::Bytes(test.vec_field3_opt.as_ref().unwrap().clone())),
+ ),
+ ),
+ (
+ "vec_field3_opt2".to_owned(),
+ Value::Union(0, Box::new(Value::Null)),
+ ),
(
"fixed_field".to_owned(),
- Value::Fixed(6, test.fixed_field.to_vec()),
+ Value::Fixed(test.fixed_field.len(),
test.fixed_field.to_vec()),
+ ),
+ (
+ "fixed_field_opt".to_owned(),
+ Value::Union(
+ 1,
+ Box::new(Value::Fixed(
+ test.fixed_field_opt.as_ref().unwrap().len(),
+ test.fixed_field_opt.as_ref().unwrap().to_vec(),
+ )),
+ ),
+ ),
+ (
+ "fixed_field_opt2".to_owned(),
+ Value::Union(0, Box::new(Value::Null)),
),
(
"fixed_field2".to_owned(),
- Value::Fixed(2, test.fixed_field2.to_vec()),
+ Value::Fixed(test.fixed_field2.len(),
test.fixed_field2.to_vec()),
+ ),
+ (
+ "fixed_field2_opt".to_owned(),
+ Value::Union(
+ 1,
+ Box::new(Value::Fixed(
+ test.fixed_field2_opt.as_ref().unwrap().len(),
+ test.fixed_field2_opt.as_ref().unwrap().to_vec(),
+ )),
+ ),
+ ),
+ (
+ "fixed_field2_opt2".to_owned(),
+ Value::Union(0, Box::new(Value::Null)),
),
(
"bytes_field".to_owned(),
Value::Bytes(test.bytes_field.to_vec()),
),
+ (
+ "bytes_field_opt".to_owned(),
+ Value::Union(
+ 1,
+ Box::new(Value::Bytes(
+ test.bytes_field_opt.as_ref().unwrap().to_vec(),
+ )),
+ ),
+ ),
+ (
+ "bytes_field_opt2".to_owned(),
+ Value::Union(0, Box::new(Value::Null)),
+ ),
(
"bytes_field2".to_owned(),
Value::Bytes(test.bytes_field2.to_vec()),
),
+ (
+ "bytes_field2_opt".to_owned(),
+ Value::Union(
+ 1,
+ Box::new(Value::Bytes(
+ test.bytes_field2_opt.as_ref().unwrap().to_vec(),
+ )),
+ ),
+ ),
+ (
+ "bytes_field2_opt2".to_owned(),
+ Value::Union(0, Box::new(Value::Null)),
+ ),
]);
assert_eq!(expected, to_value(test).unwrap());
}
diff --git a/lang/rust/avro/src/lib.rs b/lang/rust/avro/src/lib.rs
index a14c8db13..fa9ed5dd1 100644
--- a/lang/rust/avro/src/lib.rs
+++ b/lang/rust/avro/src/lib.rs
@@ -863,7 +863,10 @@ pub mod validator;
pub use crate::{
bigdecimal::BigDecimal,
- bytes::{serde_avro_bytes, serde_avro_fixed, serde_avro_slice},
+ bytes::{
+ serde_avro_bytes, serde_avro_bytes_opt, serde_avro_fixed,
serde_avro_fixed_opt,
+ serde_avro_slice, serde_avro_slice_opt,
+ },
};
pub use codec::Codec;
pub use de::from_value;
