diff --git a/nats/src/jetstream/types.rs b/nats/src/jetstream/types.rs index 368182d83..56af145b4 100644 --- a/nats/src/jetstream/types.rs +++ b/nats/src/jetstream/types.rs @@ -224,12 +224,7 @@ pub struct ConsumerConfig { #[serde(default, skip_serializing_if = "is_default")] pub rate_limit: u64, /// What percentage of acknowledgments should be samples for observability, 0-100 - #[serde( - rename = "sample_freq", - with = "from_str", - default, - skip_serializing_if = "is_default" - )] + #[serde(default, skip_serializing_if = "is_default")] pub sample_frequency: u8, /// The maximum number of waiting consumers. #[serde(default, skip_serializing_if = "is_default")] @@ -259,26 +254,6 @@ pub struct ConsumerConfig { pub inactive_threshold: Duration, } -mod from_str { - pub fn deserialize<'de, T, D>(deserializer: D) -> Result - where - T: std::str::FromStr, - T::Err: std::fmt::Display, - D: serde::Deserializer<'de>, - { - let s = ::deserialize(deserializer)?; - T::from_str(&s).map_err(serde::de::Error::custom) - } - - pub fn serialize(value: &T, serializer: S) -> Result - where - T: std::fmt::Display, - S: serde::Serializer, - { - serializer.serialize_str(&value.to_string()) - } -} - pub(crate) enum ConsumerKind { Pull, }