// @generated impl serde::Serialize for Body { #[allow(deprecated)] fn serialize(&self, serializer: S) -> std::result::Result where S: serde::Serializer, { use serde::ser::SerializeStruct; let mut len = 0; if self.truncated { len += 1; } if self.body_type.is_some() { len += 1; } let mut struct_ser = serializer.serialize_struct("envoy.data.tap.v2alpha.Body", len)?; if self.truncated { struct_ser.serialize_field("truncated", &self.truncated)?; } if let Some(v) = self.body_type.as_ref() { match v { body::BodyType::AsBytes(v) => { struct_ser.serialize_field("asBytes", pbjson::private::base64::encode(&v).as_str())?; } body::BodyType::AsString(v) => { struct_ser.serialize_field("asString", v)?; } } } struct_ser.end() } } impl<'de> serde::Deserialize<'de> for Body { #[allow(deprecated)] fn deserialize(deserializer: D) -> std::result::Result where D: serde::Deserializer<'de>, { const FIELDS: &[&str] = &[ "truncated", "as_bytes", "asBytes", "as_string", "asString", ]; #[allow(clippy::enum_variant_names)] enum GeneratedField { Truncated, AsBytes, AsString, } impl<'de> serde::Deserialize<'de> for GeneratedField { fn deserialize(deserializer: D) -> std::result::Result where D: serde::Deserializer<'de>, { struct GeneratedVisitor; impl<'de> serde::de::Visitor<'de> for GeneratedVisitor { type Value = GeneratedField; fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result { write!(formatter, "expected one of: {:?}", &FIELDS) } #[allow(unused_variables)] fn visit_str(self, value: &str) -> std::result::Result where E: serde::de::Error, { match value { "truncated" => Ok(GeneratedField::Truncated), "asBytes" | "as_bytes" => Ok(GeneratedField::AsBytes), "asString" | "as_string" => Ok(GeneratedField::AsString), _ => Err(serde::de::Error::unknown_field(value, FIELDS)), } } } deserializer.deserialize_identifier(GeneratedVisitor) } } struct GeneratedVisitor; impl<'de> serde::de::Visitor<'de> for GeneratedVisitor { type Value = Body; fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result { formatter.write_str("struct envoy.data.tap.v2alpha.Body") } fn visit_map(self, mut map: V) -> std::result::Result where V: serde::de::MapAccess<'de>, { let mut truncated__ = None; let mut body_type__ = None; while let Some(k) = map.next_key()? { match k { GeneratedField::Truncated => { if truncated__.is_some() { return Err(serde::de::Error::duplicate_field("truncated")); } truncated__ = Some(map.next_value()?); } GeneratedField::AsBytes => { if body_type__.is_some() { return Err(serde::de::Error::duplicate_field("asBytes")); } body_type__ = map.next_value::<::std::option::Option<::pbjson::private::BytesDeserialize<_>>>()?.map(|x| body::BodyType::AsBytes(x.0)); } GeneratedField::AsString => { if body_type__.is_some() { return Err(serde::de::Error::duplicate_field("asString")); } body_type__ = map.next_value::<::std::option::Option<_>>()?.map(body::BodyType::AsString); } } } Ok(Body { truncated: truncated__.unwrap_or_default(), body_type: body_type__, }) } } deserializer.deserialize_struct("envoy.data.tap.v2alpha.Body", FIELDS, GeneratedVisitor) } } impl serde::Serialize for Connection { #[allow(deprecated)] fn serialize(&self, serializer: S) -> std::result::Result where S: serde::Serializer, { use serde::ser::SerializeStruct; let mut len = 0; if self.local_address.is_some() { len += 1; } if self.remote_address.is_some() { len += 1; } let mut struct_ser = serializer.serialize_struct("envoy.data.tap.v2alpha.Connection", len)?; if let Some(v) = self.local_address.as_ref() { struct_ser.serialize_field("localAddress", v)?; } if let Some(v) = self.remote_address.as_ref() { struct_ser.serialize_field("remoteAddress", v)?; } struct_ser.end() } } impl<'de> serde::Deserialize<'de> for Connection { #[allow(deprecated)] fn deserialize(deserializer: D) -> std::result::Result where D: serde::Deserializer<'de>, { const FIELDS: &[&str] = &[ "local_address", "localAddress", "remote_address", "remoteAddress", ]; #[allow(clippy::enum_variant_names)] enum GeneratedField { LocalAddress, RemoteAddress, } impl<'de> serde::Deserialize<'de> for GeneratedField { fn deserialize(deserializer: D) -> std::result::Result where D: serde::Deserializer<'de>, { struct GeneratedVisitor; impl<'de> serde::de::Visitor<'de> for GeneratedVisitor { type Value = GeneratedField; fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result { write!(formatter, "expected one of: {:?}", &FIELDS) } #[allow(unused_variables)] fn visit_str(self, value: &str) -> std::result::Result where E: serde::de::Error, { match value { "localAddress" | "local_address" => Ok(GeneratedField::LocalAddress), "remoteAddress" | "remote_address" => Ok(GeneratedField::RemoteAddress), _ => Err(serde::de::Error::unknown_field(value, FIELDS)), } } } deserializer.deserialize_identifier(GeneratedVisitor) } } struct GeneratedVisitor; impl<'de> serde::de::Visitor<'de> for GeneratedVisitor { type Value = Connection; fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result { formatter.write_str("struct envoy.data.tap.v2alpha.Connection") } fn visit_map(self, mut map: V) -> std::result::Result where V: serde::de::MapAccess<'de>, { let mut local_address__ = None; let mut remote_address__ = None; while let Some(k) = map.next_key()? { match k { GeneratedField::LocalAddress => { if local_address__.is_some() { return Err(serde::de::Error::duplicate_field("localAddress")); } local_address__ = map.next_value()?; } GeneratedField::RemoteAddress => { if remote_address__.is_some() { return Err(serde::de::Error::duplicate_field("remoteAddress")); } remote_address__ = map.next_value()?; } } } Ok(Connection { local_address: local_address__, remote_address: remote_address__, }) } } deserializer.deserialize_struct("envoy.data.tap.v2alpha.Connection", FIELDS, GeneratedVisitor) } } impl serde::Serialize for HttpBufferedTrace { #[allow(deprecated)] fn serialize(&self, serializer: S) -> std::result::Result where S: serde::Serializer, { use serde::ser::SerializeStruct; let mut len = 0; if self.request.is_some() { len += 1; } if self.response.is_some() { len += 1; } let mut struct_ser = serializer.serialize_struct("envoy.data.tap.v2alpha.HttpBufferedTrace", len)?; if let Some(v) = self.request.as_ref() { struct_ser.serialize_field("request", v)?; } if let Some(v) = self.response.as_ref() { struct_ser.serialize_field("response", v)?; } struct_ser.end() } } impl<'de> serde::Deserialize<'de> for HttpBufferedTrace { #[allow(deprecated)] fn deserialize(deserializer: D) -> std::result::Result where D: serde::Deserializer<'de>, { const FIELDS: &[&str] = &[ "request", "response", ]; #[allow(clippy::enum_variant_names)] enum GeneratedField { Request, Response, } impl<'de> serde::Deserialize<'de> for GeneratedField { fn deserialize(deserializer: D) -> std::result::Result where D: serde::Deserializer<'de>, { struct GeneratedVisitor; impl<'de> serde::de::Visitor<'de> for GeneratedVisitor { type Value = GeneratedField; fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result { write!(formatter, "expected one of: {:?}", &FIELDS) } #[allow(unused_variables)] fn visit_str(self, value: &str) -> std::result::Result where E: serde::de::Error, { match value { "request" => Ok(GeneratedField::Request), "response" => Ok(GeneratedField::Response), _ => Err(serde::de::Error::unknown_field(value, FIELDS)), } } } deserializer.deserialize_identifier(GeneratedVisitor) } } struct GeneratedVisitor; impl<'de> serde::de::Visitor<'de> for GeneratedVisitor { type Value = HttpBufferedTrace; fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result { formatter.write_str("struct envoy.data.tap.v2alpha.HttpBufferedTrace") } fn visit_map(self, mut map: V) -> std::result::Result where V: serde::de::MapAccess<'de>, { let mut request__ = None; let mut response__ = None; while let Some(k) = map.next_key()? { match k { GeneratedField::Request => { if request__.is_some() { return Err(serde::de::Error::duplicate_field("request")); } request__ = map.next_value()?; } GeneratedField::Response => { if response__.is_some() { return Err(serde::de::Error::duplicate_field("response")); } response__ = map.next_value()?; } } } Ok(HttpBufferedTrace { request: request__, response: response__, }) } } deserializer.deserialize_struct("envoy.data.tap.v2alpha.HttpBufferedTrace", FIELDS, GeneratedVisitor) } } impl serde::Serialize for http_buffered_trace::Message { #[allow(deprecated)] fn serialize(&self, serializer: S) -> std::result::Result where S: serde::Serializer, { use serde::ser::SerializeStruct; let mut len = 0; if !self.headers.is_empty() { len += 1; } if self.body.is_some() { len += 1; } if !self.trailers.is_empty() { len += 1; } let mut struct_ser = serializer.serialize_struct("envoy.data.tap.v2alpha.HttpBufferedTrace.Message", len)?; if !self.headers.is_empty() { struct_ser.serialize_field("headers", &self.headers)?; } if let Some(v) = self.body.as_ref() { struct_ser.serialize_field("body", v)?; } if !self.trailers.is_empty() { struct_ser.serialize_field("trailers", &self.trailers)?; } struct_ser.end() } } impl<'de> serde::Deserialize<'de> for http_buffered_trace::Message { #[allow(deprecated)] fn deserialize(deserializer: D) -> std::result::Result where D: serde::Deserializer<'de>, { const FIELDS: &[&str] = &[ "headers", "body", "trailers", ]; #[allow(clippy::enum_variant_names)] enum GeneratedField { Headers, Body, Trailers, } impl<'de> serde::Deserialize<'de> for GeneratedField { fn deserialize(deserializer: D) -> std::result::Result where D: serde::Deserializer<'de>, { struct GeneratedVisitor; impl<'de> serde::de::Visitor<'de> for GeneratedVisitor { type Value = GeneratedField; fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result { write!(formatter, "expected one of: {:?}", &FIELDS) } #[allow(unused_variables)] fn visit_str(self, value: &str) -> std::result::Result where E: serde::de::Error, { match value { "headers" => Ok(GeneratedField::Headers), "body" => Ok(GeneratedField::Body), "trailers" => Ok(GeneratedField::Trailers), _ => Err(serde::de::Error::unknown_field(value, FIELDS)), } } } deserializer.deserialize_identifier(GeneratedVisitor) } } struct GeneratedVisitor; impl<'de> serde::de::Visitor<'de> for GeneratedVisitor { type Value = http_buffered_trace::Message; fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result { formatter.write_str("struct envoy.data.tap.v2alpha.HttpBufferedTrace.Message") } fn visit_map(self, mut map: V) -> std::result::Result where V: serde::de::MapAccess<'de>, { let mut headers__ = None; let mut body__ = None; let mut trailers__ = None; while let Some(k) = map.next_key()? { match k { GeneratedField::Headers => { if headers__.is_some() { return Err(serde::de::Error::duplicate_field("headers")); } headers__ = Some(map.next_value()?); } GeneratedField::Body => { if body__.is_some() { return Err(serde::de::Error::duplicate_field("body")); } body__ = map.next_value()?; } GeneratedField::Trailers => { if trailers__.is_some() { return Err(serde::de::Error::duplicate_field("trailers")); } trailers__ = Some(map.next_value()?); } } } Ok(http_buffered_trace::Message { headers: headers__.unwrap_or_default(), body: body__, trailers: trailers__.unwrap_or_default(), }) } } deserializer.deserialize_struct("envoy.data.tap.v2alpha.HttpBufferedTrace.Message", FIELDS, GeneratedVisitor) } } impl serde::Serialize for HttpStreamedTraceSegment { #[allow(deprecated)] fn serialize(&self, serializer: S) -> std::result::Result where S: serde::Serializer, { use serde::ser::SerializeStruct; let mut len = 0; if self.trace_id != 0 { len += 1; } if self.message_piece.is_some() { len += 1; } let mut struct_ser = serializer.serialize_struct("envoy.data.tap.v2alpha.HttpStreamedTraceSegment", len)?; if self.trace_id != 0 { struct_ser.serialize_field("traceId", ToString::to_string(&self.trace_id).as_str())?; } if let Some(v) = self.message_piece.as_ref() { match v { http_streamed_trace_segment::MessagePiece::RequestHeaders(v) => { struct_ser.serialize_field("requestHeaders", v)?; } http_streamed_trace_segment::MessagePiece::RequestBodyChunk(v) => { struct_ser.serialize_field("requestBodyChunk", v)?; } http_streamed_trace_segment::MessagePiece::RequestTrailers(v) => { struct_ser.serialize_field("requestTrailers", v)?; } http_streamed_trace_segment::MessagePiece::ResponseHeaders(v) => { struct_ser.serialize_field("responseHeaders", v)?; } http_streamed_trace_segment::MessagePiece::ResponseBodyChunk(v) => { struct_ser.serialize_field("responseBodyChunk", v)?; } http_streamed_trace_segment::MessagePiece::ResponseTrailers(v) => { struct_ser.serialize_field("responseTrailers", v)?; } } } struct_ser.end() } } impl<'de> serde::Deserialize<'de> for HttpStreamedTraceSegment { #[allow(deprecated)] fn deserialize(deserializer: D) -> std::result::Result where D: serde::Deserializer<'de>, { const FIELDS: &[&str] = &[ "trace_id", "traceId", "request_headers", "requestHeaders", "request_body_chunk", "requestBodyChunk", "request_trailers", "requestTrailers", "response_headers", "responseHeaders", "response_body_chunk", "responseBodyChunk", "response_trailers", "responseTrailers", ]; #[allow(clippy::enum_variant_names)] enum GeneratedField { TraceId, RequestHeaders, RequestBodyChunk, RequestTrailers, ResponseHeaders, ResponseBodyChunk, ResponseTrailers, } impl<'de> serde::Deserialize<'de> for GeneratedField { fn deserialize(deserializer: D) -> std::result::Result where D: serde::Deserializer<'de>, { struct GeneratedVisitor; impl<'de> serde::de::Visitor<'de> for GeneratedVisitor { type Value = GeneratedField; fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result { write!(formatter, "expected one of: {:?}", &FIELDS) } #[allow(unused_variables)] fn visit_str(self, value: &str) -> std::result::Result where E: serde::de::Error, { match value { "traceId" | "trace_id" => Ok(GeneratedField::TraceId), "requestHeaders" | "request_headers" => Ok(GeneratedField::RequestHeaders), "requestBodyChunk" | "request_body_chunk" => Ok(GeneratedField::RequestBodyChunk), "requestTrailers" | "request_trailers" => Ok(GeneratedField::RequestTrailers), "responseHeaders" | "response_headers" => Ok(GeneratedField::ResponseHeaders), "responseBodyChunk" | "response_body_chunk" => Ok(GeneratedField::ResponseBodyChunk), "responseTrailers" | "response_trailers" => Ok(GeneratedField::ResponseTrailers), _ => Err(serde::de::Error::unknown_field(value, FIELDS)), } } } deserializer.deserialize_identifier(GeneratedVisitor) } } struct GeneratedVisitor; impl<'de> serde::de::Visitor<'de> for GeneratedVisitor { type Value = HttpStreamedTraceSegment; fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result { formatter.write_str("struct envoy.data.tap.v2alpha.HttpStreamedTraceSegment") } fn visit_map(self, mut map: V) -> std::result::Result where V: serde::de::MapAccess<'de>, { let mut trace_id__ = None; let mut message_piece__ = None; while let Some(k) = map.next_key()? { match k { GeneratedField::TraceId => { if trace_id__.is_some() { return Err(serde::de::Error::duplicate_field("traceId")); } trace_id__ = Some(map.next_value::<::pbjson::private::NumberDeserialize<_>>()?.0) ; } GeneratedField::RequestHeaders => { if message_piece__.is_some() { return Err(serde::de::Error::duplicate_field("requestHeaders")); } message_piece__ = map.next_value::<::std::option::Option<_>>()?.map(http_streamed_trace_segment::MessagePiece::RequestHeaders) ; } GeneratedField::RequestBodyChunk => { if message_piece__.is_some() { return Err(serde::de::Error::duplicate_field("requestBodyChunk")); } message_piece__ = map.next_value::<::std::option::Option<_>>()?.map(http_streamed_trace_segment::MessagePiece::RequestBodyChunk) ; } GeneratedField::RequestTrailers => { if message_piece__.is_some() { return Err(serde::de::Error::duplicate_field("requestTrailers")); } message_piece__ = map.next_value::<::std::option::Option<_>>()?.map(http_streamed_trace_segment::MessagePiece::RequestTrailers) ; } GeneratedField::ResponseHeaders => { if message_piece__.is_some() { return Err(serde::de::Error::duplicate_field("responseHeaders")); } message_piece__ = map.next_value::<::std::option::Option<_>>()?.map(http_streamed_trace_segment::MessagePiece::ResponseHeaders) ; } GeneratedField::ResponseBodyChunk => { if message_piece__.is_some() { return Err(serde::de::Error::duplicate_field("responseBodyChunk")); } message_piece__ = map.next_value::<::std::option::Option<_>>()?.map(http_streamed_trace_segment::MessagePiece::ResponseBodyChunk) ; } GeneratedField::ResponseTrailers => { if message_piece__.is_some() { return Err(serde::de::Error::duplicate_field("responseTrailers")); } message_piece__ = map.next_value::<::std::option::Option<_>>()?.map(http_streamed_trace_segment::MessagePiece::ResponseTrailers) ; } } } Ok(HttpStreamedTraceSegment { trace_id: trace_id__.unwrap_or_default(), message_piece: message_piece__, }) } } deserializer.deserialize_struct("envoy.data.tap.v2alpha.HttpStreamedTraceSegment", FIELDS, GeneratedVisitor) } } impl serde::Serialize for SocketBufferedTrace { #[allow(deprecated)] fn serialize(&self, serializer: S) -> std::result::Result where S: serde::Serializer, { use serde::ser::SerializeStruct; let mut len = 0; if self.trace_id != 0 { len += 1; } if self.connection.is_some() { len += 1; } if !self.events.is_empty() { len += 1; } if self.read_truncated { len += 1; } if self.write_truncated { len += 1; } let mut struct_ser = serializer.serialize_struct("envoy.data.tap.v2alpha.SocketBufferedTrace", len)?; if self.trace_id != 0 { struct_ser.serialize_field("traceId", ToString::to_string(&self.trace_id).as_str())?; } if let Some(v) = self.connection.as_ref() { struct_ser.serialize_field("connection", v)?; } if !self.events.is_empty() { struct_ser.serialize_field("events", &self.events)?; } if self.read_truncated { struct_ser.serialize_field("readTruncated", &self.read_truncated)?; } if self.write_truncated { struct_ser.serialize_field("writeTruncated", &self.write_truncated)?; } struct_ser.end() } } impl<'de> serde::Deserialize<'de> for SocketBufferedTrace { #[allow(deprecated)] fn deserialize(deserializer: D) -> std::result::Result where D: serde::Deserializer<'de>, { const FIELDS: &[&str] = &[ "trace_id", "traceId", "connection", "events", "read_truncated", "readTruncated", "write_truncated", "writeTruncated", ]; #[allow(clippy::enum_variant_names)] enum GeneratedField { TraceId, Connection, Events, ReadTruncated, WriteTruncated, } impl<'de> serde::Deserialize<'de> for GeneratedField { fn deserialize(deserializer: D) -> std::result::Result where D: serde::Deserializer<'de>, { struct GeneratedVisitor; impl<'de> serde::de::Visitor<'de> for GeneratedVisitor { type Value = GeneratedField; fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result { write!(formatter, "expected one of: {:?}", &FIELDS) } #[allow(unused_variables)] fn visit_str(self, value: &str) -> std::result::Result where E: serde::de::Error, { match value { "traceId" | "trace_id" => Ok(GeneratedField::TraceId), "connection" => Ok(GeneratedField::Connection), "events" => Ok(GeneratedField::Events), "readTruncated" | "read_truncated" => Ok(GeneratedField::ReadTruncated), "writeTruncated" | "write_truncated" => Ok(GeneratedField::WriteTruncated), _ => Err(serde::de::Error::unknown_field(value, FIELDS)), } } } deserializer.deserialize_identifier(GeneratedVisitor) } } struct GeneratedVisitor; impl<'de> serde::de::Visitor<'de> for GeneratedVisitor { type Value = SocketBufferedTrace; fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result { formatter.write_str("struct envoy.data.tap.v2alpha.SocketBufferedTrace") } fn visit_map(self, mut map: V) -> std::result::Result where V: serde::de::MapAccess<'de>, { let mut trace_id__ = None; let mut connection__ = None; let mut events__ = None; let mut read_truncated__ = None; let mut write_truncated__ = None; while let Some(k) = map.next_key()? { match k { GeneratedField::TraceId => { if trace_id__.is_some() { return Err(serde::de::Error::duplicate_field("traceId")); } trace_id__ = Some(map.next_value::<::pbjson::private::NumberDeserialize<_>>()?.0) ; } GeneratedField::Connection => { if connection__.is_some() { return Err(serde::de::Error::duplicate_field("connection")); } connection__ = map.next_value()?; } GeneratedField::Events => { if events__.is_some() { return Err(serde::de::Error::duplicate_field("events")); } events__ = Some(map.next_value()?); } GeneratedField::ReadTruncated => { if read_truncated__.is_some() { return Err(serde::de::Error::duplicate_field("readTruncated")); } read_truncated__ = Some(map.next_value()?); } GeneratedField::WriteTruncated => { if write_truncated__.is_some() { return Err(serde::de::Error::duplicate_field("writeTruncated")); } write_truncated__ = Some(map.next_value()?); } } } Ok(SocketBufferedTrace { trace_id: trace_id__.unwrap_or_default(), connection: connection__, events: events__.unwrap_or_default(), read_truncated: read_truncated__.unwrap_or_default(), write_truncated: write_truncated__.unwrap_or_default(), }) } } deserializer.deserialize_struct("envoy.data.tap.v2alpha.SocketBufferedTrace", FIELDS, GeneratedVisitor) } } impl serde::Serialize for SocketEvent { #[allow(deprecated)] fn serialize(&self, serializer: S) -> std::result::Result where S: serde::Serializer, { use serde::ser::SerializeStruct; let mut len = 0; if self.timestamp.is_some() { len += 1; } if self.event_selector.is_some() { len += 1; } let mut struct_ser = serializer.serialize_struct("envoy.data.tap.v2alpha.SocketEvent", len)?; if let Some(v) = self.timestamp.as_ref() { struct_ser.serialize_field("timestamp", v)?; } if let Some(v) = self.event_selector.as_ref() { match v { socket_event::EventSelector::Read(v) => { struct_ser.serialize_field("read", v)?; } socket_event::EventSelector::Write(v) => { struct_ser.serialize_field("write", v)?; } socket_event::EventSelector::Closed(v) => { struct_ser.serialize_field("closed", v)?; } } } struct_ser.end() } } impl<'de> serde::Deserialize<'de> for SocketEvent { #[allow(deprecated)] fn deserialize(deserializer: D) -> std::result::Result where D: serde::Deserializer<'de>, { const FIELDS: &[&str] = &[ "timestamp", "read", "write", "closed", ]; #[allow(clippy::enum_variant_names)] enum GeneratedField { Timestamp, Read, Write, Closed, } impl<'de> serde::Deserialize<'de> for GeneratedField { fn deserialize(deserializer: D) -> std::result::Result where D: serde::Deserializer<'de>, { struct GeneratedVisitor; impl<'de> serde::de::Visitor<'de> for GeneratedVisitor { type Value = GeneratedField; fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result { write!(formatter, "expected one of: {:?}", &FIELDS) } #[allow(unused_variables)] fn visit_str(self, value: &str) -> std::result::Result where E: serde::de::Error, { match value { "timestamp" => Ok(GeneratedField::Timestamp), "read" => Ok(GeneratedField::Read), "write" => Ok(GeneratedField::Write), "closed" => Ok(GeneratedField::Closed), _ => Err(serde::de::Error::unknown_field(value, FIELDS)), } } } deserializer.deserialize_identifier(GeneratedVisitor) } } struct GeneratedVisitor; impl<'de> serde::de::Visitor<'de> for GeneratedVisitor { type Value = SocketEvent; fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result { formatter.write_str("struct envoy.data.tap.v2alpha.SocketEvent") } fn visit_map(self, mut map: V) -> std::result::Result where V: serde::de::MapAccess<'de>, { let mut timestamp__ = None; let mut event_selector__ = None; while let Some(k) = map.next_key()? { match k { GeneratedField::Timestamp => { if timestamp__.is_some() { return Err(serde::de::Error::duplicate_field("timestamp")); } timestamp__ = map.next_value()?; } GeneratedField::Read => { if event_selector__.is_some() { return Err(serde::de::Error::duplicate_field("read")); } event_selector__ = map.next_value::<::std::option::Option<_>>()?.map(socket_event::EventSelector::Read) ; } GeneratedField::Write => { if event_selector__.is_some() { return Err(serde::de::Error::duplicate_field("write")); } event_selector__ = map.next_value::<::std::option::Option<_>>()?.map(socket_event::EventSelector::Write) ; } GeneratedField::Closed => { if event_selector__.is_some() { return Err(serde::de::Error::duplicate_field("closed")); } event_selector__ = map.next_value::<::std::option::Option<_>>()?.map(socket_event::EventSelector::Closed) ; } } } Ok(SocketEvent { timestamp: timestamp__, event_selector: event_selector__, }) } } deserializer.deserialize_struct("envoy.data.tap.v2alpha.SocketEvent", FIELDS, GeneratedVisitor) } } impl serde::Serialize for socket_event::Closed { #[allow(deprecated)] fn serialize(&self, serializer: S) -> std::result::Result where S: serde::Serializer, { use serde::ser::SerializeStruct; let len = 0; let struct_ser = serializer.serialize_struct("envoy.data.tap.v2alpha.SocketEvent.Closed", len)?; struct_ser.end() } } impl<'de> serde::Deserialize<'de> for socket_event::Closed { #[allow(deprecated)] fn deserialize(deserializer: D) -> std::result::Result where D: serde::Deserializer<'de>, { const FIELDS: &[&str] = &[ ]; #[allow(clippy::enum_variant_names)] enum GeneratedField { } impl<'de> serde::Deserialize<'de> for GeneratedField { fn deserialize(deserializer: D) -> std::result::Result where D: serde::Deserializer<'de>, { struct GeneratedVisitor; impl<'de> serde::de::Visitor<'de> for GeneratedVisitor { type Value = GeneratedField; fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result { write!(formatter, "expected one of: {:?}", &FIELDS) } #[allow(unused_variables)] fn visit_str(self, value: &str) -> std::result::Result where E: serde::de::Error, { Err(serde::de::Error::unknown_field(value, FIELDS)) } } deserializer.deserialize_identifier(GeneratedVisitor) } } struct GeneratedVisitor; impl<'de> serde::de::Visitor<'de> for GeneratedVisitor { type Value = socket_event::Closed; fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result { formatter.write_str("struct envoy.data.tap.v2alpha.SocketEvent.Closed") } fn visit_map(self, mut map: V) -> std::result::Result where V: serde::de::MapAccess<'de>, { while map.next_key::()?.is_some() { let _ = map.next_value::()?; } Ok(socket_event::Closed { }) } } deserializer.deserialize_struct("envoy.data.tap.v2alpha.SocketEvent.Closed", FIELDS, GeneratedVisitor) } } impl serde::Serialize for socket_event::Read { #[allow(deprecated)] fn serialize(&self, serializer: S) -> std::result::Result where S: serde::Serializer, { use serde::ser::SerializeStruct; let mut len = 0; if self.data.is_some() { len += 1; } let mut struct_ser = serializer.serialize_struct("envoy.data.tap.v2alpha.SocketEvent.Read", len)?; if let Some(v) = self.data.as_ref() { struct_ser.serialize_field("data", v)?; } struct_ser.end() } } impl<'de> serde::Deserialize<'de> for socket_event::Read { #[allow(deprecated)] fn deserialize(deserializer: D) -> std::result::Result where D: serde::Deserializer<'de>, { const FIELDS: &[&str] = &[ "data", ]; #[allow(clippy::enum_variant_names)] enum GeneratedField { Data, } impl<'de> serde::Deserialize<'de> for GeneratedField { fn deserialize(deserializer: D) -> std::result::Result where D: serde::Deserializer<'de>, { struct GeneratedVisitor; impl<'de> serde::de::Visitor<'de> for GeneratedVisitor { type Value = GeneratedField; fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result { write!(formatter, "expected one of: {:?}", &FIELDS) } #[allow(unused_variables)] fn visit_str(self, value: &str) -> std::result::Result where E: serde::de::Error, { match value { "data" => Ok(GeneratedField::Data), _ => Err(serde::de::Error::unknown_field(value, FIELDS)), } } } deserializer.deserialize_identifier(GeneratedVisitor) } } struct GeneratedVisitor; impl<'de> serde::de::Visitor<'de> for GeneratedVisitor { type Value = socket_event::Read; fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result { formatter.write_str("struct envoy.data.tap.v2alpha.SocketEvent.Read") } fn visit_map(self, mut map: V) -> std::result::Result where V: serde::de::MapAccess<'de>, { let mut data__ = None; while let Some(k) = map.next_key()? { match k { GeneratedField::Data => { if data__.is_some() { return Err(serde::de::Error::duplicate_field("data")); } data__ = map.next_value()?; } } } Ok(socket_event::Read { data: data__, }) } } deserializer.deserialize_struct("envoy.data.tap.v2alpha.SocketEvent.Read", FIELDS, GeneratedVisitor) } } impl serde::Serialize for socket_event::Write { #[allow(deprecated)] fn serialize(&self, serializer: S) -> std::result::Result where S: serde::Serializer, { use serde::ser::SerializeStruct; let mut len = 0; if self.data.is_some() { len += 1; } if self.end_stream { len += 1; } let mut struct_ser = serializer.serialize_struct("envoy.data.tap.v2alpha.SocketEvent.Write", len)?; if let Some(v) = self.data.as_ref() { struct_ser.serialize_field("data", v)?; } if self.end_stream { struct_ser.serialize_field("endStream", &self.end_stream)?; } struct_ser.end() } } impl<'de> serde::Deserialize<'de> for socket_event::Write { #[allow(deprecated)] fn deserialize(deserializer: D) -> std::result::Result where D: serde::Deserializer<'de>, { const FIELDS: &[&str] = &[ "data", "end_stream", "endStream", ]; #[allow(clippy::enum_variant_names)] enum GeneratedField { Data, EndStream, } impl<'de> serde::Deserialize<'de> for GeneratedField { fn deserialize(deserializer: D) -> std::result::Result where D: serde::Deserializer<'de>, { struct GeneratedVisitor; impl<'de> serde::de::Visitor<'de> for GeneratedVisitor { type Value = GeneratedField; fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result { write!(formatter, "expected one of: {:?}", &FIELDS) } #[allow(unused_variables)] fn visit_str(self, value: &str) -> std::result::Result where E: serde::de::Error, { match value { "data" => Ok(GeneratedField::Data), "endStream" | "end_stream" => Ok(GeneratedField::EndStream), _ => Err(serde::de::Error::unknown_field(value, FIELDS)), } } } deserializer.deserialize_identifier(GeneratedVisitor) } } struct GeneratedVisitor; impl<'de> serde::de::Visitor<'de> for GeneratedVisitor { type Value = socket_event::Write; fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result { formatter.write_str("struct envoy.data.tap.v2alpha.SocketEvent.Write") } fn visit_map(self, mut map: V) -> std::result::Result where V: serde::de::MapAccess<'de>, { let mut data__ = None; let mut end_stream__ = None; while let Some(k) = map.next_key()? { match k { GeneratedField::Data => { if data__.is_some() { return Err(serde::de::Error::duplicate_field("data")); } data__ = map.next_value()?; } GeneratedField::EndStream => { if end_stream__.is_some() { return Err(serde::de::Error::duplicate_field("endStream")); } end_stream__ = Some(map.next_value()?); } } } Ok(socket_event::Write { data: data__, end_stream: end_stream__.unwrap_or_default(), }) } } deserializer.deserialize_struct("envoy.data.tap.v2alpha.SocketEvent.Write", FIELDS, GeneratedVisitor) } } impl serde::Serialize for SocketStreamedTraceSegment { #[allow(deprecated)] fn serialize(&self, serializer: S) -> std::result::Result where S: serde::Serializer, { use serde::ser::SerializeStruct; let mut len = 0; if self.trace_id != 0 { len += 1; } if self.message_piece.is_some() { len += 1; } let mut struct_ser = serializer.serialize_struct("envoy.data.tap.v2alpha.SocketStreamedTraceSegment", len)?; if self.trace_id != 0 { struct_ser.serialize_field("traceId", ToString::to_string(&self.trace_id).as_str())?; } if let Some(v) = self.message_piece.as_ref() { match v { socket_streamed_trace_segment::MessagePiece::Connection(v) => { struct_ser.serialize_field("connection", v)?; } socket_streamed_trace_segment::MessagePiece::Event(v) => { struct_ser.serialize_field("event", v)?; } } } struct_ser.end() } } impl<'de> serde::Deserialize<'de> for SocketStreamedTraceSegment { #[allow(deprecated)] fn deserialize(deserializer: D) -> std::result::Result where D: serde::Deserializer<'de>, { const FIELDS: &[&str] = &[ "trace_id", "traceId", "connection", "event", ]; #[allow(clippy::enum_variant_names)] enum GeneratedField { TraceId, Connection, Event, } impl<'de> serde::Deserialize<'de> for GeneratedField { fn deserialize(deserializer: D) -> std::result::Result where D: serde::Deserializer<'de>, { struct GeneratedVisitor; impl<'de> serde::de::Visitor<'de> for GeneratedVisitor { type Value = GeneratedField; fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result { write!(formatter, "expected one of: {:?}", &FIELDS) } #[allow(unused_variables)] fn visit_str(self, value: &str) -> std::result::Result where E: serde::de::Error, { match value { "traceId" | "trace_id" => Ok(GeneratedField::TraceId), "connection" => Ok(GeneratedField::Connection), "event" => Ok(GeneratedField::Event), _ => Err(serde::de::Error::unknown_field(value, FIELDS)), } } } deserializer.deserialize_identifier(GeneratedVisitor) } } struct GeneratedVisitor; impl<'de> serde::de::Visitor<'de> for GeneratedVisitor { type Value = SocketStreamedTraceSegment; fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result { formatter.write_str("struct envoy.data.tap.v2alpha.SocketStreamedTraceSegment") } fn visit_map(self, mut map: V) -> std::result::Result where V: serde::de::MapAccess<'de>, { let mut trace_id__ = None; let mut message_piece__ = None; while let Some(k) = map.next_key()? { match k { GeneratedField::TraceId => { if trace_id__.is_some() { return Err(serde::de::Error::duplicate_field("traceId")); } trace_id__ = Some(map.next_value::<::pbjson::private::NumberDeserialize<_>>()?.0) ; } GeneratedField::Connection => { if message_piece__.is_some() { return Err(serde::de::Error::duplicate_field("connection")); } message_piece__ = map.next_value::<::std::option::Option<_>>()?.map(socket_streamed_trace_segment::MessagePiece::Connection) ; } GeneratedField::Event => { if message_piece__.is_some() { return Err(serde::de::Error::duplicate_field("event")); } message_piece__ = map.next_value::<::std::option::Option<_>>()?.map(socket_streamed_trace_segment::MessagePiece::Event) ; } } } Ok(SocketStreamedTraceSegment { trace_id: trace_id__.unwrap_or_default(), message_piece: message_piece__, }) } } deserializer.deserialize_struct("envoy.data.tap.v2alpha.SocketStreamedTraceSegment", FIELDS, GeneratedVisitor) } } impl serde::Serialize for TraceWrapper { #[allow(deprecated)] fn serialize(&self, serializer: S) -> std::result::Result where S: serde::Serializer, { use serde::ser::SerializeStruct; let mut len = 0; if self.trace.is_some() { len += 1; } let mut struct_ser = serializer.serialize_struct("envoy.data.tap.v2alpha.TraceWrapper", len)?; if let Some(v) = self.trace.as_ref() { match v { trace_wrapper::Trace::HttpBufferedTrace(v) => { struct_ser.serialize_field("httpBufferedTrace", v)?; } trace_wrapper::Trace::HttpStreamedTraceSegment(v) => { struct_ser.serialize_field("httpStreamedTraceSegment", v)?; } trace_wrapper::Trace::SocketBufferedTrace(v) => { struct_ser.serialize_field("socketBufferedTrace", v)?; } trace_wrapper::Trace::SocketStreamedTraceSegment(v) => { struct_ser.serialize_field("socketStreamedTraceSegment", v)?; } } } struct_ser.end() } } impl<'de> serde::Deserialize<'de> for TraceWrapper { #[allow(deprecated)] fn deserialize(deserializer: D) -> std::result::Result where D: serde::Deserializer<'de>, { const FIELDS: &[&str] = &[ "http_buffered_trace", "httpBufferedTrace", "http_streamed_trace_segment", "httpStreamedTraceSegment", "socket_buffered_trace", "socketBufferedTrace", "socket_streamed_trace_segment", "socketStreamedTraceSegment", ]; #[allow(clippy::enum_variant_names)] enum GeneratedField { HttpBufferedTrace, HttpStreamedTraceSegment, SocketBufferedTrace, SocketStreamedTraceSegment, } impl<'de> serde::Deserialize<'de> for GeneratedField { fn deserialize(deserializer: D) -> std::result::Result where D: serde::Deserializer<'de>, { struct GeneratedVisitor; impl<'de> serde::de::Visitor<'de> for GeneratedVisitor { type Value = GeneratedField; fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result { write!(formatter, "expected one of: {:?}", &FIELDS) } #[allow(unused_variables)] fn visit_str(self, value: &str) -> std::result::Result where E: serde::de::Error, { match value { "httpBufferedTrace" | "http_buffered_trace" => Ok(GeneratedField::HttpBufferedTrace), "httpStreamedTraceSegment" | "http_streamed_trace_segment" => Ok(GeneratedField::HttpStreamedTraceSegment), "socketBufferedTrace" | "socket_buffered_trace" => Ok(GeneratedField::SocketBufferedTrace), "socketStreamedTraceSegment" | "socket_streamed_trace_segment" => Ok(GeneratedField::SocketStreamedTraceSegment), _ => Err(serde::de::Error::unknown_field(value, FIELDS)), } } } deserializer.deserialize_identifier(GeneratedVisitor) } } struct GeneratedVisitor; impl<'de> serde::de::Visitor<'de> for GeneratedVisitor { type Value = TraceWrapper; fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result { formatter.write_str("struct envoy.data.tap.v2alpha.TraceWrapper") } fn visit_map(self, mut map: V) -> std::result::Result where V: serde::de::MapAccess<'de>, { let mut trace__ = None; while let Some(k) = map.next_key()? { match k { GeneratedField::HttpBufferedTrace => { if trace__.is_some() { return Err(serde::de::Error::duplicate_field("httpBufferedTrace")); } trace__ = map.next_value::<::std::option::Option<_>>()?.map(trace_wrapper::Trace::HttpBufferedTrace) ; } GeneratedField::HttpStreamedTraceSegment => { if trace__.is_some() { return Err(serde::de::Error::duplicate_field("httpStreamedTraceSegment")); } trace__ = map.next_value::<::std::option::Option<_>>()?.map(trace_wrapper::Trace::HttpStreamedTraceSegment) ; } GeneratedField::SocketBufferedTrace => { if trace__.is_some() { return Err(serde::de::Error::duplicate_field("socketBufferedTrace")); } trace__ = map.next_value::<::std::option::Option<_>>()?.map(trace_wrapper::Trace::SocketBufferedTrace) ; } GeneratedField::SocketStreamedTraceSegment => { if trace__.is_some() { return Err(serde::de::Error::duplicate_field("socketStreamedTraceSegment")); } trace__ = map.next_value::<::std::option::Option<_>>()?.map(trace_wrapper::Trace::SocketStreamedTraceSegment) ; } } } Ok(TraceWrapper { trace: trace__, }) } } deserializer.deserialize_struct("envoy.data.tap.v2alpha.TraceWrapper", FIELDS, GeneratedVisitor) } }