polyester/gen/buffa/

tradews.v1.rs

// @generated by buffa-codegen. DO NOT EDIT.

/// ClientFrame is the protobuf write-websocket envelope. Its payloads reuse the
/// public Orders API request contracts so every transport shares one order model.
#[derive(Clone, PartialEq, Default)]
#[derive(::serde::Serialize)]
#[serde(default)]
pub struct ClientFrame {
    /// Monotonic per-connection client sequence number, starting at 1.
    ///
    /// Field 1: `seq`
    #[serde(
        rename = "seq",
        with = "::buffa::json_helpers::uint64",
        skip_serializing_if = "::buffa::json_helpers::skip_if::is_zero_u64"
    )]
    pub seq: u64,
    /// Client correlation token echoed in every server response.
    ///
    /// Field 2: `correlation_id`
    #[serde(
        rename = "correlationId",
        alias = "correlation_id",
        with = "::buffa::json_helpers::proto_string",
        skip_serializing_if = "::buffa::json_helpers::skip_if::is_empty_str"
    )]
    pub correlation_id: ::buffa::alloc::string::String,
    #[serde(flatten)]
    pub payload: ::core::option::Option<__buffa::oneof::client_frame::Payload>,
    #[serde(skip)]
    #[doc(hidden)]
    pub __buffa_unknown_fields: ::buffa::UnknownFields,
}
impl ::core::fmt::Debug for ClientFrame {
    fn fmt(&self, f: &mut ::core::fmt::Formatter<'_>) -> ::core::fmt::Result {
        f.debug_struct("ClientFrame")
            .field("seq", &self.seq)
            .field("correlation_id", &self.correlation_id)
            .field("payload", &self.payload)
            .finish()
    }
}
impl ClientFrame {
    /// Protobuf type URL for this message, for use with `Any::pack` and
    /// `Any::unpack_if`.
    ///
    /// Format: `type.googleapis.com/<fully.qualified.TypeName>`
    pub const TYPE_URL: &'static str = "type.googleapis.com/tradews.v1.ClientFrame";
}
::buffa::impl_default_instance!(ClientFrame);
impl ::buffa::MessageName for ClientFrame {
    const PACKAGE: &'static str = "tradews.v1";
    const NAME: &'static str = "ClientFrame";
    const FULL_NAME: &'static str = "tradews.v1.ClientFrame";
    const TYPE_URL: &'static str = "type.googleapis.com/tradews.v1.ClientFrame";
}
impl ::buffa::Message for ClientFrame {
    /// Returns the total encoded size in bytes.
    ///
    /// The result is a `u32`; the protobuf specification requires all
    /// messages to fit within 2 GiB (2,147,483,647 bytes), so a
    /// compliant message will never overflow this type.
    #[allow(clippy::let_and_return)]
    fn compute_size(&self, __cache: &mut ::buffa::SizeCache) -> u32 {
        #[allow(unused_imports)]
        use ::buffa::Enumeration as _;
        let mut size = 0u32;
        if self.seq != 0u64 {
            size += 1u32 + ::buffa::types::uint64_encoded_len(self.seq) as u32;
        }
        if !self.correlation_id.is_empty() {
            size
                += 1u32
                    + ::buffa::types::string_encoded_len(&self.correlation_id) as u32;
        }
        if let ::core::option::Option::Some(ref v) = self.payload {
            match v {
                __buffa::oneof::client_frame::Payload::Ping(x) => {
                    let __slot = __cache.reserve();
                    let inner = x.compute_size(__cache);
                    __cache.set(__slot, inner);
                    size
                        += 1u32 + ::buffa::encoding::varint_len(inner as u64) as u32
                            + inner;
                }
                __buffa::oneof::client_frame::Payload::CreateOrder(x) => {
                    let __slot = __cache.reserve();
                    let inner = x.compute_size(__cache);
                    __cache.set(__slot, inner);
                    size
                        += 1u32 + ::buffa::encoding::varint_len(inner as u64) as u32
                            + inner;
                }
                __buffa::oneof::client_frame::Payload::CancelOrder(x) => {
                    let __slot = __cache.reserve();
                    let inner = x.compute_size(__cache);
                    __cache.set(__slot, inner);
                    size
                        += 1u32 + ::buffa::encoding::varint_len(inner as u64) as u32
                            + inner;
                }
                __buffa::oneof::client_frame::Payload::ModifyOrder(x) => {
                    let __slot = __cache.reserve();
                    let inner = x.compute_size(__cache);
                    __cache.set(__slot, inner);
                    size
                        += 1u32 + ::buffa::encoding::varint_len(inner as u64) as u32
                            + inner;
                }
                __buffa::oneof::client_frame::Payload::CancelAllOrders(x) => {
                    let __slot = __cache.reserve();
                    let inner = x.compute_size(__cache);
                    __cache.set(__slot, inner);
                    size
                        += 1u32 + ::buffa::encoding::varint_len(inner as u64) as u32
                            + inner;
                }
            }
        }
        size += self.__buffa_unknown_fields.encoded_len() as u32;
        size
    }
    fn write_to(
        &self,
        __cache: &mut ::buffa::SizeCache,
        buf: &mut impl ::buffa::bytes::BufMut,
    ) {
        #[allow(unused_imports)]
        use ::buffa::Enumeration as _;
        if self.seq != 0u64 {
            ::buffa::types::put_uint64_field(1u32, self.seq, buf);
        }
        if !self.correlation_id.is_empty() {
            ::buffa::types::put_string_field(2u32, &self.correlation_id, buf);
        }
        if let ::core::option::Option::Some(ref v) = self.payload {
            match v {
                __buffa::oneof::client_frame::Payload::Ping(x) => {
                    ::buffa::types::put_len_delimited_header(
                        10u32,
                        __cache.consume_next(),
                        buf,
                    );
                    x.write_to(__cache, buf);
                }
                __buffa::oneof::client_frame::Payload::CreateOrder(x) => {
                    ::buffa::types::put_len_delimited_header(
                        11u32,
                        __cache.consume_next(),
                        buf,
                    );
                    x.write_to(__cache, buf);
                }
                __buffa::oneof::client_frame::Payload::CancelOrder(x) => {
                    ::buffa::types::put_len_delimited_header(
                        12u32,
                        __cache.consume_next(),
                        buf,
                    );
                    x.write_to(__cache, buf);
                }
                __buffa::oneof::client_frame::Payload::ModifyOrder(x) => {
                    ::buffa::types::put_len_delimited_header(
                        13u32,
                        __cache.consume_next(),
                        buf,
                    );
                    x.write_to(__cache, buf);
                }
                __buffa::oneof::client_frame::Payload::CancelAllOrders(x) => {
                    ::buffa::types::put_len_delimited_header(
                        14u32,
                        __cache.consume_next(),
                        buf,
                    );
                    x.write_to(__cache, buf);
                }
            }
        }
        self.__buffa_unknown_fields.write_to(buf);
    }
    fn merge_field(
        &mut self,
        tag: ::buffa::encoding::Tag,
        buf: &mut impl ::buffa::bytes::Buf,
        ctx: ::buffa::DecodeContext<'_>,
    ) -> ::core::result::Result<(), ::buffa::DecodeError> {
        #[allow(unused_imports)]
        use ::buffa::bytes::Buf as _;
        #[allow(unused_imports)]
        use ::buffa::Enumeration as _;
        match tag.field_number() {
            1u32 => {
                ::buffa::encoding::check_wire_type(
                    tag,
                    ::buffa::encoding::WireType::Varint,
                )?;
                self.seq = ::buffa::types::decode_uint64(buf)?;
            }
            2u32 => {
                ::buffa::encoding::check_wire_type(
                    tag,
                    ::buffa::encoding::WireType::LengthDelimited,
                )?;
                ::buffa::types::merge_string(&mut self.correlation_id, buf)?;
            }
            10u32 => {
                ::buffa::encoding::check_wire_type(
                    tag,
                    ::buffa::encoding::WireType::LengthDelimited,
                )?;
                if let ::core::option::Option::Some(
                    __buffa::oneof::client_frame::Payload::Ping(ref mut existing),
                ) = self.payload
                {
                    ::buffa::Message::merge_length_delimited(&mut **existing, buf, ctx)?;
                } else {
                    let mut val = ::core::default::Default::default();
                    ::buffa::Message::merge_length_delimited(&mut val, buf, ctx)?;
                    self.payload = ::core::option::Option::Some(
                        __buffa::oneof::client_frame::Payload::Ping(
                            ::buffa::alloc::boxed::Box::new(val),
                        ),
                    );
                }
            }
            11u32 => {
                ::buffa::encoding::check_wire_type(
                    tag,
                    ::buffa::encoding::WireType::LengthDelimited,
                )?;
                if let ::core::option::Option::Some(
                    __buffa::oneof::client_frame::Payload::CreateOrder(ref mut existing),
                ) = self.payload
                {
                    ::buffa::Message::merge_length_delimited(&mut **existing, buf, ctx)?;
                } else {
                    let mut val = ::core::default::Default::default();
                    ::buffa::Message::merge_length_delimited(&mut val, buf, ctx)?;
                    self.payload = ::core::option::Option::Some(
                        __buffa::oneof::client_frame::Payload::CreateOrder(
                            ::buffa::alloc::boxed::Box::new(val),
                        ),
                    );
                }
            }
            12u32 => {
                ::buffa::encoding::check_wire_type(
                    tag,
                    ::buffa::encoding::WireType::LengthDelimited,
                )?;
                if let ::core::option::Option::Some(
                    __buffa::oneof::client_frame::Payload::CancelOrder(ref mut existing),
                ) = self.payload
                {
                    ::buffa::Message::merge_length_delimited(&mut **existing, buf, ctx)?;
                } else {
                    let mut val = ::core::default::Default::default();
                    ::buffa::Message::merge_length_delimited(&mut val, buf, ctx)?;
                    self.payload = ::core::option::Option::Some(
                        __buffa::oneof::client_frame::Payload::CancelOrder(
                            ::buffa::alloc::boxed::Box::new(val),
                        ),
                    );
                }
            }
            13u32 => {
                ::buffa::encoding::check_wire_type(
                    tag,
                    ::buffa::encoding::WireType::LengthDelimited,
                )?;
                if let ::core::option::Option::Some(
                    __buffa::oneof::client_frame::Payload::ModifyOrder(ref mut existing),
                ) = self.payload
                {
                    ::buffa::Message::merge_length_delimited(&mut **existing, buf, ctx)?;
                } else {
                    let mut val = ::core::default::Default::default();
                    ::buffa::Message::merge_length_delimited(&mut val, buf, ctx)?;
                    self.payload = ::core::option::Option::Some(
                        __buffa::oneof::client_frame::Payload::ModifyOrder(
                            ::buffa::alloc::boxed::Box::new(val),
                        ),
                    );
                }
            }
            14u32 => {
                ::buffa::encoding::check_wire_type(
                    tag,
                    ::buffa::encoding::WireType::LengthDelimited,
                )?;
                if let ::core::option::Option::Some(
                    __buffa::oneof::client_frame::Payload::CancelAllOrders(
                        ref mut existing,
                    ),
                ) = self.payload
                {
                    ::buffa::Message::merge_length_delimited(&mut **existing, buf, ctx)?;
                } else {
                    let mut val = ::core::default::Default::default();
                    ::buffa::Message::merge_length_delimited(&mut val, buf, ctx)?;
                    self.payload = ::core::option::Option::Some(
                        __buffa::oneof::client_frame::Payload::CancelAllOrders(
                            ::buffa::alloc::boxed::Box::new(val),
                        ),
                    );
                }
            }
            _ => {
                self.__buffa_unknown_fields
                    .push(::buffa::encoding::decode_unknown_field(tag, buf, ctx)?);
            }
        }
        ::core::result::Result::Ok(())
    }
    fn clear(&mut self) {
        self.seq = 0u64;
        self.correlation_id.clear();
        self.payload = ::core::option::Option::None;
        self.__buffa_unknown_fields.clear();
    }
}
impl ::buffa::ExtensionSet for ClientFrame {
    const PROTO_FQN: &'static str = "tradews.v1.ClientFrame";
    fn unknown_fields(&self) -> &::buffa::UnknownFields {
        &self.__buffa_unknown_fields
    }
    fn unknown_fields_mut(&mut self) -> &mut ::buffa::UnknownFields {
        &mut self.__buffa_unknown_fields
    }
}
impl<'de> serde::Deserialize<'de> for ClientFrame {
    fn deserialize<D: serde::Deserializer<'de>>(
        d: D,
    ) -> ::core::result::Result<Self, D::Error> {
        struct _V;
        impl<'de> serde::de::Visitor<'de> for _V {
            type Value = ClientFrame;
            fn expecting(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result {
                f.write_str("struct ClientFrame")
            }
            #[allow(clippy::field_reassign_with_default)]
            fn visit_map<A: serde::de::MapAccess<'de>>(
                self,
                mut map: A,
            ) -> ::core::result::Result<ClientFrame, A::Error> {
                let mut __f_seq: ::core::option::Option<u64> = None;
                let mut __f_correlation_id: ::core::option::Option<
                    ::buffa::alloc::string::String,
                > = None;
                let mut __oneof_payload: ::core::option::Option<
                    __buffa::oneof::client_frame::Payload,
                > = None;
                while let Some(key) = map.next_key::<::buffa::alloc::string::String>()? {
                    match key.as_str() {
                        "seq" => {
                            __f_seq = Some({
                                struct _S;
                                impl<'de> serde::de::DeserializeSeed<'de> for _S {
                                    type Value = u64;
                                    fn deserialize<D: serde::Deserializer<'de>>(
                                        self,
                                        d: D,
                                    ) -> ::core::result::Result<u64, D::Error> {
                                        ::buffa::json_helpers::uint64::deserialize(d)
                                    }
                                }
                                map.next_value_seed(_S)?
                            });
                        }
                        "correlationId" | "correlation_id" => {
                            __f_correlation_id = Some({
                                struct _S;
                                impl<'de> serde::de::DeserializeSeed<'de> for _S {
                                    type Value = ::buffa::alloc::string::String;
                                    fn deserialize<D: serde::Deserializer<'de>>(
                                        self,
                                        d: D,
                                    ) -> ::core::result::Result<
                                        ::buffa::alloc::string::String,
                                        D::Error,
                                    > {
                                        ::buffa::json_helpers::proto_string::deserialize(d)
                                    }
                                }
                                map.next_value_seed(_S)?
                            });
                        }
                        "ping" => {
                            let v: ::core::option::Option<PingRequest> = map
                                .next_value_seed(
                                    ::buffa::json_helpers::NullableDeserializeSeed(
                                        ::buffa::json_helpers::DefaultDeserializeSeed::<
                                            PingRequest,
                                        >::new(),
                                    ),
                                )?;
                            if let Some(v) = v {
                                if __oneof_payload.is_some() {
                                    return Err(
                                        serde::de::Error::custom(
                                            "multiple oneof fields set for 'payload'",
                                        ),
                                    );
                                }
                                __oneof_payload = Some(
                                    __buffa::oneof::client_frame::Payload::Ping(
                                        ::buffa::alloc::boxed::Box::new(v),
                                    ),
                                );
                            }
                        }
                        "createOrder" | "create_order" => {
                            let v: ::core::option::Option<
                                super::super::orders::v1::CreateOrderRequest,
                            > = map
                                .next_value_seed(
                                    ::buffa::json_helpers::NullableDeserializeSeed(
                                        ::buffa::json_helpers::DefaultDeserializeSeed::<
                                            super::super::orders::v1::CreateOrderRequest,
                                        >::new(),
                                    ),
                                )?;
                            if let Some(v) = v {
                                if __oneof_payload.is_some() {
                                    return Err(
                                        serde::de::Error::custom(
                                            "multiple oneof fields set for 'payload'",
                                        ),
                                    );
                                }
                                __oneof_payload = Some(
                                    __buffa::oneof::client_frame::Payload::CreateOrder(
                                        ::buffa::alloc::boxed::Box::new(v),
                                    ),
                                );
                            }
                        }
                        "cancelOrder" | "cancel_order" => {
                            let v: ::core::option::Option<
                                super::super::orders::v1::CancelOrderRequest,
                            > = map
                                .next_value_seed(
                                    ::buffa::json_helpers::NullableDeserializeSeed(
                                        ::buffa::json_helpers::DefaultDeserializeSeed::<
                                            super::super::orders::v1::CancelOrderRequest,
                                        >::new(),
                                    ),
                                )?;
                            if let Some(v) = v {
                                if __oneof_payload.is_some() {
                                    return Err(
                                        serde::de::Error::custom(
                                            "multiple oneof fields set for 'payload'",
                                        ),
                                    );
                                }
                                __oneof_payload = Some(
                                    __buffa::oneof::client_frame::Payload::CancelOrder(
                                        ::buffa::alloc::boxed::Box::new(v),
                                    ),
                                );
                            }
                        }
                        "modifyOrder" | "modify_order" => {
                            let v: ::core::option::Option<
                                super::super::orders::v1::ModifyOrderRequest,
                            > = map
                                .next_value_seed(
                                    ::buffa::json_helpers::NullableDeserializeSeed(
                                        ::buffa::json_helpers::DefaultDeserializeSeed::<
                                            super::super::orders::v1::ModifyOrderRequest,
                                        >::new(),
                                    ),
                                )?;
                            if let Some(v) = v {
                                if __oneof_payload.is_some() {
                                    return Err(
                                        serde::de::Error::custom(
                                            "multiple oneof fields set for 'payload'",
                                        ),
                                    );
                                }
                                __oneof_payload = Some(
                                    __buffa::oneof::client_frame::Payload::ModifyOrder(
                                        ::buffa::alloc::boxed::Box::new(v),
                                    ),
                                );
                            }
                        }
                        "cancelAllOrders" | "cancel_all_orders" => {
                            let v: ::core::option::Option<
                                super::super::orders::v1::CancelAllOrdersRequest,
                            > = map
                                .next_value_seed(
                                    ::buffa::json_helpers::NullableDeserializeSeed(
                                        ::buffa::json_helpers::DefaultDeserializeSeed::<
                                            super::super::orders::v1::CancelAllOrdersRequest,
                                        >::new(),
                                    ),
                                )?;
                            if let Some(v) = v {
                                if __oneof_payload.is_some() {
                                    return Err(
                                        serde::de::Error::custom(
                                            "multiple oneof fields set for 'payload'",
                                        ),
                                    );
                                }
                                __oneof_payload = Some(
                                    __buffa::oneof::client_frame::Payload::CancelAllOrders(
                                        ::buffa::alloc::boxed::Box::new(v),
                                    ),
                                );
                            }
                        }
                        _ => {
                            map.next_value::<serde::de::IgnoredAny>()?;
                        }
                    }
                }
                let mut __r = <ClientFrame as ::core::default::Default>::default();
                if let ::core::option::Option::Some(v) = __f_seq {
                    __r.seq = v;
                }
                if let ::core::option::Option::Some(v) = __f_correlation_id {
                    __r.correlation_id = v;
                }
                __r.payload = __oneof_payload;
                Ok(__r)
            }
        }
        d.deserialize_map(_V)
    }
}
impl ::buffa::json_helpers::ProtoElemJson for ClientFrame {
    fn serialize_proto_json<S: ::serde::Serializer>(
        v: &Self,
        s: S,
    ) -> ::core::result::Result<S::Ok, S::Error> {
        ::serde::Serialize::serialize(v, s)
    }
    fn deserialize_proto_json<'de, D: ::serde::Deserializer<'de>>(
        d: D,
    ) -> ::core::result::Result<Self, D::Error> {
        <Self as ::serde::Deserialize>::deserialize(d)
    }
}
#[doc(hidden)]
pub const __CLIENT_FRAME_JSON_ANY: ::buffa::type_registry::JsonAnyEntry = ::buffa::type_registry::JsonAnyEntry {
    type_url: "type.googleapis.com/tradews.v1.ClientFrame",
    to_json: ::buffa::type_registry::any_to_json::<ClientFrame>,
    from_json: ::buffa::type_registry::any_from_json::<ClientFrame>,
    is_wkt: false,
};
pub mod client_frame {
    #[allow(unused_imports)]
    use super::*;
    #[doc(inline)]
    pub use super::__buffa::oneof::client_frame::Payload;
    #[doc(inline)]
    pub use super::__buffa::view::oneof::client_frame::Payload as PayloadView;
}
/// PingRequest carries an opaque payload that is echoed by PongResponse.
#[derive(Clone, PartialEq, Default)]
#[derive(::serde::Serialize, ::serde::Deserialize)]
#[serde(default)]
pub struct PingRequest {
    /// Opaque client payload echoed by the server.
    ///
    /// Field 1: `payload`
    #[serde(
        rename = "payload",
        with = "::buffa::json_helpers::bytes",
        skip_serializing_if = "::buffa::json_helpers::skip_if::is_empty_bytes"
    )]
    pub payload: ::buffa::alloc::vec::Vec<u8>,
    #[serde(skip)]
    #[doc(hidden)]
    pub __buffa_unknown_fields: ::buffa::UnknownFields,
}
impl ::core::fmt::Debug for PingRequest {
    fn fmt(&self, f: &mut ::core::fmt::Formatter<'_>) -> ::core::fmt::Result {
        f.debug_struct("PingRequest").field("payload", &self.payload).finish()
    }
}
impl PingRequest {
    /// Protobuf type URL for this message, for use with `Any::pack` and
    /// `Any::unpack_if`.
    ///
    /// Format: `type.googleapis.com/<fully.qualified.TypeName>`
    pub const TYPE_URL: &'static str = "type.googleapis.com/tradews.v1.PingRequest";
}
::buffa::impl_default_instance!(PingRequest);
impl ::buffa::MessageName for PingRequest {
    const PACKAGE: &'static str = "tradews.v1";
    const NAME: &'static str = "PingRequest";
    const FULL_NAME: &'static str = "tradews.v1.PingRequest";
    const TYPE_URL: &'static str = "type.googleapis.com/tradews.v1.PingRequest";
}
impl ::buffa::Message for PingRequest {
    /// Returns the total encoded size in bytes.
    ///
    /// The result is a `u32`; the protobuf specification requires all
    /// messages to fit within 2 GiB (2,147,483,647 bytes), so a
    /// compliant message will never overflow this type.
    #[allow(clippy::let_and_return)]
    fn compute_size(&self, _cache: &mut ::buffa::SizeCache) -> u32 {
        #[allow(unused_imports)]
        use ::buffa::Enumeration as _;
        let mut size = 0u32;
        if !self.payload.is_empty() {
            size += 1u32 + ::buffa::types::bytes_encoded_len(&self.payload) as u32;
        }
        size += self.__buffa_unknown_fields.encoded_len() as u32;
        size
    }
    fn write_to(
        &self,
        _cache: &mut ::buffa::SizeCache,
        buf: &mut impl ::buffa::bytes::BufMut,
    ) {
        #[allow(unused_imports)]
        use ::buffa::Enumeration as _;
        if !self.payload.is_empty() {
            ::buffa::types::put_bytes_field(1u32, &self.payload, buf);
        }
        self.__buffa_unknown_fields.write_to(buf);
    }
    fn merge_field(
        &mut self,
        tag: ::buffa::encoding::Tag,
        buf: &mut impl ::buffa::bytes::Buf,
        ctx: ::buffa::DecodeContext<'_>,
    ) -> ::core::result::Result<(), ::buffa::DecodeError> {
        #[allow(unused_imports)]
        use ::buffa::bytes::Buf as _;
        #[allow(unused_imports)]
        use ::buffa::Enumeration as _;
        match tag.field_number() {
            1u32 => {
                ::buffa::encoding::check_wire_type(
                    tag,
                    ::buffa::encoding::WireType::LengthDelimited,
                )?;
                ::buffa::types::merge_bytes(&mut self.payload, buf)?;
            }
            _ => {
                self.__buffa_unknown_fields
                    .push(::buffa::encoding::decode_unknown_field(tag, buf, ctx)?);
            }
        }
        ::core::result::Result::Ok(())
    }
    fn clear(&mut self) {
        self.payload.clear();
        self.__buffa_unknown_fields.clear();
    }
}
impl ::buffa::ExtensionSet for PingRequest {
    const PROTO_FQN: &'static str = "tradews.v1.PingRequest";
    fn unknown_fields(&self) -> &::buffa::UnknownFields {
        &self.__buffa_unknown_fields
    }
    fn unknown_fields_mut(&mut self) -> &mut ::buffa::UnknownFields {
        &mut self.__buffa_unknown_fields
    }
}
impl ::buffa::json_helpers::ProtoElemJson for PingRequest {
    fn serialize_proto_json<S: ::serde::Serializer>(
        v: &Self,
        s: S,
    ) -> ::core::result::Result<S::Ok, S::Error> {
        ::serde::Serialize::serialize(v, s)
    }
    fn deserialize_proto_json<'de, D: ::serde::Deserializer<'de>>(
        d: D,
    ) -> ::core::result::Result<Self, D::Error> {
        <Self as ::serde::Deserialize>::deserialize(d)
    }
}
#[doc(hidden)]
pub const __PING_REQUEST_JSON_ANY: ::buffa::type_registry::JsonAnyEntry = ::buffa::type_registry::JsonAnyEntry {
    type_url: "type.googleapis.com/tradews.v1.PingRequest",
    to_json: ::buffa::type_registry::any_to_json::<PingRequest>,
    from_json: ::buffa::type_registry::any_from_json::<PingRequest>,
    is_wkt: false,
};
/// ServerFrame is the protobuf write-websocket response envelope.
#[derive(Clone, PartialEq, Default)]
#[derive(::serde::Serialize)]
#[serde(default)]
pub struct ServerFrame {
    /// Client sequence number copied from the accepted or rejected frame.
    ///
    /// Field 1: `seq`
    #[serde(
        rename = "seq",
        with = "::buffa::json_helpers::uint64",
        skip_serializing_if = "::buffa::json_helpers::skip_if::is_zero_u64"
    )]
    pub seq: u64,
    /// Client correlation token copied from the accepted or rejected frame.
    ///
    /// Field 2: `correlation_id`
    #[serde(
        rename = "correlationId",
        alias = "correlation_id",
        with = "::buffa::json_helpers::proto_string",
        skip_serializing_if = "::buffa::json_helpers::skip_if::is_empty_str"
    )]
    pub correlation_id: ::buffa::alloc::string::String,
    #[serde(flatten)]
    pub payload: ::core::option::Option<__buffa::oneof::server_frame::Payload>,
    #[serde(skip)]
    #[doc(hidden)]
    pub __buffa_unknown_fields: ::buffa::UnknownFields,
}
impl ::core::fmt::Debug for ServerFrame {
    fn fmt(&self, f: &mut ::core::fmt::Formatter<'_>) -> ::core::fmt::Result {
        f.debug_struct("ServerFrame")
            .field("seq", &self.seq)
            .field("correlation_id", &self.correlation_id)
            .field("payload", &self.payload)
            .finish()
    }
}
impl ServerFrame {
    /// Protobuf type URL for this message, for use with `Any::pack` and
    /// `Any::unpack_if`.
    ///
    /// Format: `type.googleapis.com/<fully.qualified.TypeName>`
    pub const TYPE_URL: &'static str = "type.googleapis.com/tradews.v1.ServerFrame";
}
::buffa::impl_default_instance!(ServerFrame);
impl ::buffa::MessageName for ServerFrame {
    const PACKAGE: &'static str = "tradews.v1";
    const NAME: &'static str = "ServerFrame";
    const FULL_NAME: &'static str = "tradews.v1.ServerFrame";
    const TYPE_URL: &'static str = "type.googleapis.com/tradews.v1.ServerFrame";
}
impl ::buffa::Message for ServerFrame {
    /// Returns the total encoded size in bytes.
    ///
    /// The result is a `u32`; the protobuf specification requires all
    /// messages to fit within 2 GiB (2,147,483,647 bytes), so a
    /// compliant message will never overflow this type.
    #[allow(clippy::let_and_return)]
    fn compute_size(&self, __cache: &mut ::buffa::SizeCache) -> u32 {
        #[allow(unused_imports)]
        use ::buffa::Enumeration as _;
        let mut size = 0u32;
        if self.seq != 0u64 {
            size += 1u32 + ::buffa::types::uint64_encoded_len(self.seq) as u32;
        }
        if !self.correlation_id.is_empty() {
            size
                += 1u32
                    + ::buffa::types::string_encoded_len(&self.correlation_id) as u32;
        }
        if let ::core::option::Option::Some(ref v) = self.payload {
            match v {
                __buffa::oneof::server_frame::Payload::Pong(x) => {
                    let __slot = __cache.reserve();
                    let inner = x.compute_size(__cache);
                    __cache.set(__slot, inner);
                    size
                        += 1u32 + ::buffa::encoding::varint_len(inner as u64) as u32
                            + inner;
                }
                __buffa::oneof::server_frame::Payload::Ack(x) => {
                    let __slot = __cache.reserve();
                    let inner = x.compute_size(__cache);
                    __cache.set(__slot, inner);
                    size
                        += 1u32 + ::buffa::encoding::varint_len(inner as u64) as u32
                            + inner;
                }
                __buffa::oneof::server_frame::Payload::Reject(x) => {
                    let __slot = __cache.reserve();
                    let inner = x.compute_size(__cache);
                    __cache.set(__slot, inner);
                    size
                        += 1u32 + ::buffa::encoding::varint_len(inner as u64) as u32
                            + inner;
                }
                __buffa::oneof::server_frame::Payload::Overload(x) => {
                    let __slot = __cache.reserve();
                    let inner = x.compute_size(__cache);
                    __cache.set(__slot, inner);
                    size
                        += 1u32 + ::buffa::encoding::varint_len(inner as u64) as u32
                            + inner;
                }
                __buffa::oneof::server_frame::Payload::Terminal(x) => {
                    let __slot = __cache.reserve();
                    let inner = x.compute_size(__cache);
                    __cache.set(__slot, inner);
                    size
                        += 1u32 + ::buffa::encoding::varint_len(inner as u64) as u32
                            + inner;
                }
            }
        }
        size += self.__buffa_unknown_fields.encoded_len() as u32;
        size
    }
    fn write_to(
        &self,
        __cache: &mut ::buffa::SizeCache,
        buf: &mut impl ::buffa::bytes::BufMut,
    ) {
        #[allow(unused_imports)]
        use ::buffa::Enumeration as _;
        if self.seq != 0u64 {
            ::buffa::types::put_uint64_field(1u32, self.seq, buf);
        }
        if !self.correlation_id.is_empty() {
            ::buffa::types::put_string_field(2u32, &self.correlation_id, buf);
        }
        if let ::core::option::Option::Some(ref v) = self.payload {
            match v {
                __buffa::oneof::server_frame::Payload::Pong(x) => {
                    ::buffa::types::put_len_delimited_header(
                        10u32,
                        __cache.consume_next(),
                        buf,
                    );
                    x.write_to(__cache, buf);
                }
                __buffa::oneof::server_frame::Payload::Ack(x) => {
                    ::buffa::types::put_len_delimited_header(
                        11u32,
                        __cache.consume_next(),
                        buf,
                    );
                    x.write_to(__cache, buf);
                }
                __buffa::oneof::server_frame::Payload::Reject(x) => {
                    ::buffa::types::put_len_delimited_header(
                        12u32,
                        __cache.consume_next(),
                        buf,
                    );
                    x.write_to(__cache, buf);
                }
                __buffa::oneof::server_frame::Payload::Overload(x) => {
                    ::buffa::types::put_len_delimited_header(
                        13u32,
                        __cache.consume_next(),
                        buf,
                    );
                    x.write_to(__cache, buf);
                }
                __buffa::oneof::server_frame::Payload::Terminal(x) => {
                    ::buffa::types::put_len_delimited_header(
                        14u32,
                        __cache.consume_next(),
                        buf,
                    );
                    x.write_to(__cache, buf);
                }
            }
        }
        self.__buffa_unknown_fields.write_to(buf);
    }
    fn merge_field(
        &mut self,
        tag: ::buffa::encoding::Tag,
        buf: &mut impl ::buffa::bytes::Buf,
        ctx: ::buffa::DecodeContext<'_>,
    ) -> ::core::result::Result<(), ::buffa::DecodeError> {
        #[allow(unused_imports)]
        use ::buffa::bytes::Buf as _;
        #[allow(unused_imports)]
        use ::buffa::Enumeration as _;
        match tag.field_number() {
            1u32 => {
                ::buffa::encoding::check_wire_type(
                    tag,
                    ::buffa::encoding::WireType::Varint,
                )?;
                self.seq = ::buffa::types::decode_uint64(buf)?;
            }
            2u32 => {
                ::buffa::encoding::check_wire_type(
                    tag,
                    ::buffa::encoding::WireType::LengthDelimited,
                )?;
                ::buffa::types::merge_string(&mut self.correlation_id, buf)?;
            }
            10u32 => {
                ::buffa::encoding::check_wire_type(
                    tag,
                    ::buffa::encoding::WireType::LengthDelimited,
                )?;
                if let ::core::option::Option::Some(
                    __buffa::oneof::server_frame::Payload::Pong(ref mut existing),
                ) = self.payload
                {
                    ::buffa::Message::merge_length_delimited(&mut **existing, buf, ctx)?;
                } else {
                    let mut val = ::core::default::Default::default();
                    ::buffa::Message::merge_length_delimited(&mut val, buf, ctx)?;
                    self.payload = ::core::option::Option::Some(
                        __buffa::oneof::server_frame::Payload::Pong(
                            ::buffa::alloc::boxed::Box::new(val),
                        ),
                    );
                }
            }
            11u32 => {
                ::buffa::encoding::check_wire_type(
                    tag,
                    ::buffa::encoding::WireType::LengthDelimited,
                )?;
                if let ::core::option::Option::Some(
                    __buffa::oneof::server_frame::Payload::Ack(ref mut existing),
                ) = self.payload
                {
                    ::buffa::Message::merge_length_delimited(&mut **existing, buf, ctx)?;
                } else {
                    let mut val = ::core::default::Default::default();
                    ::buffa::Message::merge_length_delimited(&mut val, buf, ctx)?;
                    self.payload = ::core::option::Option::Some(
                        __buffa::oneof::server_frame::Payload::Ack(
                            ::buffa::alloc::boxed::Box::new(val),
                        ),
                    );
                }
            }
            12u32 => {
                ::buffa::encoding::check_wire_type(
                    tag,
                    ::buffa::encoding::WireType::LengthDelimited,
                )?;
                if let ::core::option::Option::Some(
                    __buffa::oneof::server_frame::Payload::Reject(ref mut existing),
                ) = self.payload
                {
                    ::buffa::Message::merge_length_delimited(&mut **existing, buf, ctx)?;
                } else {
                    let mut val = ::core::default::Default::default();
                    ::buffa::Message::merge_length_delimited(&mut val, buf, ctx)?;
                    self.payload = ::core::option::Option::Some(
                        __buffa::oneof::server_frame::Payload::Reject(
                            ::buffa::alloc::boxed::Box::new(val),
                        ),
                    );
                }
            }
            13u32 => {
                ::buffa::encoding::check_wire_type(
                    tag,
                    ::buffa::encoding::WireType::LengthDelimited,
                )?;
                if let ::core::option::Option::Some(
                    __buffa::oneof::server_frame::Payload::Overload(ref mut existing),
                ) = self.payload
                {
                    ::buffa::Message::merge_length_delimited(&mut **existing, buf, ctx)?;
                } else {
                    let mut val = ::core::default::Default::default();
                    ::buffa::Message::merge_length_delimited(&mut val, buf, ctx)?;
                    self.payload = ::core::option::Option::Some(
                        __buffa::oneof::server_frame::Payload::Overload(
                            ::buffa::alloc::boxed::Box::new(val),
                        ),
                    );
                }
            }
            14u32 => {
                ::buffa::encoding::check_wire_type(
                    tag,
                    ::buffa::encoding::WireType::LengthDelimited,
                )?;
                if let ::core::option::Option::Some(
                    __buffa::oneof::server_frame::Payload::Terminal(ref mut existing),
                ) = self.payload
                {
                    ::buffa::Message::merge_length_delimited(&mut **existing, buf, ctx)?;
                } else {
                    let mut val = ::core::default::Default::default();
                    ::buffa::Message::merge_length_delimited(&mut val, buf, ctx)?;
                    self.payload = ::core::option::Option::Some(
                        __buffa::oneof::server_frame::Payload::Terminal(
                            ::buffa::alloc::boxed::Box::new(val),
                        ),
                    );
                }
            }
            _ => {
                self.__buffa_unknown_fields
                    .push(::buffa::encoding::decode_unknown_field(tag, buf, ctx)?);
            }
        }
        ::core::result::Result::Ok(())
    }
    fn clear(&mut self) {
        self.seq = 0u64;
        self.correlation_id.clear();
        self.payload = ::core::option::Option::None;
        self.__buffa_unknown_fields.clear();
    }
}
impl ::buffa::ExtensionSet for ServerFrame {
    const PROTO_FQN: &'static str = "tradews.v1.ServerFrame";
    fn unknown_fields(&self) -> &::buffa::UnknownFields {
        &self.__buffa_unknown_fields
    }
    fn unknown_fields_mut(&mut self) -> &mut ::buffa::UnknownFields {
        &mut self.__buffa_unknown_fields
    }
}
impl<'de> serde::Deserialize<'de> for ServerFrame {
    fn deserialize<D: serde::Deserializer<'de>>(
        d: D,
    ) -> ::core::result::Result<Self, D::Error> {
        struct _V;
        impl<'de> serde::de::Visitor<'de> for _V {
            type Value = ServerFrame;
            fn expecting(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result {
                f.write_str("struct ServerFrame")
            }
            #[allow(clippy::field_reassign_with_default)]
            fn visit_map<A: serde::de::MapAccess<'de>>(
                self,
                mut map: A,
            ) -> ::core::result::Result<ServerFrame, A::Error> {
                let mut __f_seq: ::core::option::Option<u64> = None;
                let mut __f_correlation_id: ::core::option::Option<
                    ::buffa::alloc::string::String,
                > = None;
                let mut __oneof_payload: ::core::option::Option<
                    __buffa::oneof::server_frame::Payload,
                > = None;
                while let Some(key) = map.next_key::<::buffa::alloc::string::String>()? {
                    match key.as_str() {
                        "seq" => {
                            __f_seq = Some({
                                struct _S;
                                impl<'de> serde::de::DeserializeSeed<'de> for _S {
                                    type Value = u64;
                                    fn deserialize<D: serde::Deserializer<'de>>(
                                        self,
                                        d: D,
                                    ) -> ::core::result::Result<u64, D::Error> {
                                        ::buffa::json_helpers::uint64::deserialize(d)
                                    }
                                }
                                map.next_value_seed(_S)?
                            });
                        }
                        "correlationId" | "correlation_id" => {
                            __f_correlation_id = Some({
                                struct _S;
                                impl<'de> serde::de::DeserializeSeed<'de> for _S {
                                    type Value = ::buffa::alloc::string::String;
                                    fn deserialize<D: serde::Deserializer<'de>>(
                                        self,
                                        d: D,
                                    ) -> ::core::result::Result<
                                        ::buffa::alloc::string::String,
                                        D::Error,
                                    > {
                                        ::buffa::json_helpers::proto_string::deserialize(d)
                                    }
                                }
                                map.next_value_seed(_S)?
                            });
                        }
                        "pong" => {
                            let v: ::core::option::Option<PongResponse> = map
                                .next_value_seed(
                                    ::buffa::json_helpers::NullableDeserializeSeed(
                                        ::buffa::json_helpers::DefaultDeserializeSeed::<
                                            PongResponse,
                                        >::new(),
                                    ),
                                )?;
                            if let Some(v) = v {
                                if __oneof_payload.is_some() {
                                    return Err(
                                        serde::de::Error::custom(
                                            "multiple oneof fields set for 'payload'",
                                        ),
                                    );
                                }
                                __oneof_payload = Some(
                                    __buffa::oneof::server_frame::Payload::Pong(
                                        ::buffa::alloc::boxed::Box::new(v),
                                    ),
                                );
                            }
                        }
                        "ack" => {
                            let v: ::core::option::Option<AckResponse> = map
                                .next_value_seed(
                                    ::buffa::json_helpers::NullableDeserializeSeed(
                                        ::buffa::json_helpers::DefaultDeserializeSeed::<
                                            AckResponse,
                                        >::new(),
                                    ),
                                )?;
                            if let Some(v) = v {
                                if __oneof_payload.is_some() {
                                    return Err(
                                        serde::de::Error::custom(
                                            "multiple oneof fields set for 'payload'",
                                        ),
                                    );
                                }
                                __oneof_payload = Some(
                                    __buffa::oneof::server_frame::Payload::Ack(
                                        ::buffa::alloc::boxed::Box::new(v),
                                    ),
                                );
                            }
                        }
                        "reject" => {
                            let v: ::core::option::Option<CommandReject> = map
                                .next_value_seed(
                                    ::buffa::json_helpers::NullableDeserializeSeed(
                                        ::buffa::json_helpers::DefaultDeserializeSeed::<
                                            CommandReject,
                                        >::new(),
                                    ),
                                )?;
                            if let Some(v) = v {
                                if __oneof_payload.is_some() {
                                    return Err(
                                        serde::de::Error::custom(
                                            "multiple oneof fields set for 'payload'",
                                        ),
                                    );
                                }
                                __oneof_payload = Some(
                                    __buffa::oneof::server_frame::Payload::Reject(
                                        ::buffa::alloc::boxed::Box::new(v),
                                    ),
                                );
                            }
                        }
                        "overload" => {
                            let v: ::core::option::Option<OverloadResponse> = map
                                .next_value_seed(
                                    ::buffa::json_helpers::NullableDeserializeSeed(
                                        ::buffa::json_helpers::DefaultDeserializeSeed::<
                                            OverloadResponse,
                                        >::new(),
                                    ),
                                )?;
                            if let Some(v) = v {
                                if __oneof_payload.is_some() {
                                    return Err(
                                        serde::de::Error::custom(
                                            "multiple oneof fields set for 'payload'",
                                        ),
                                    );
                                }
                                __oneof_payload = Some(
                                    __buffa::oneof::server_frame::Payload::Overload(
                                        ::buffa::alloc::boxed::Box::new(v),
                                    ),
                                );
                            }
                        }
                        "terminal" => {
                            let v: ::core::option::Option<TerminalSessionEvent> = map
                                .next_value_seed(
                                    ::buffa::json_helpers::NullableDeserializeSeed(
                                        ::buffa::json_helpers::DefaultDeserializeSeed::<
                                            TerminalSessionEvent,
                                        >::new(),
                                    ),
                                )?;
                            if let Some(v) = v {
                                if __oneof_payload.is_some() {
                                    return Err(
                                        serde::de::Error::custom(
                                            "multiple oneof fields set for 'payload'",
                                        ),
                                    );
                                }
                                __oneof_payload = Some(
                                    __buffa::oneof::server_frame::Payload::Terminal(
                                        ::buffa::alloc::boxed::Box::new(v),
                                    ),
                                );
                            }
                        }
                        _ => {
                            map.next_value::<serde::de::IgnoredAny>()?;
                        }
                    }
                }
                let mut __r = <ServerFrame as ::core::default::Default>::default();
                if let ::core::option::Option::Some(v) = __f_seq {
                    __r.seq = v;
                }
                if let ::core::option::Option::Some(v) = __f_correlation_id {
                    __r.correlation_id = v;
                }
                __r.payload = __oneof_payload;
                Ok(__r)
            }
        }
        d.deserialize_map(_V)
    }
}
impl ::buffa::json_helpers::ProtoElemJson for ServerFrame {
    fn serialize_proto_json<S: ::serde::Serializer>(
        v: &Self,
        s: S,
    ) -> ::core::result::Result<S::Ok, S::Error> {
        ::serde::Serialize::serialize(v, s)
    }
    fn deserialize_proto_json<'de, D: ::serde::Deserializer<'de>>(
        d: D,
    ) -> ::core::result::Result<Self, D::Error> {
        <Self as ::serde::Deserialize>::deserialize(d)
    }
}
#[doc(hidden)]
pub const __SERVER_FRAME_JSON_ANY: ::buffa::type_registry::JsonAnyEntry = ::buffa::type_registry::JsonAnyEntry {
    type_url: "type.googleapis.com/tradews.v1.ServerFrame",
    to_json: ::buffa::type_registry::any_to_json::<ServerFrame>,
    from_json: ::buffa::type_registry::any_from_json::<ServerFrame>,
    is_wkt: false,
};
pub mod server_frame {
    #[allow(unused_imports)]
    use super::*;
    #[doc(inline)]
    pub use super::__buffa::oneof::server_frame::Payload;
    #[doc(inline)]
    pub use super::__buffa::view::oneof::server_frame::Payload as PayloadView;
}
/// PongResponse echoes a PingRequest payload.
#[derive(Clone, PartialEq, Default)]
#[derive(::serde::Serialize, ::serde::Deserialize)]
#[serde(default)]
pub struct PongResponse {
    /// Opaque payload copied from PingRequest.
    ///
    /// Field 1: `payload`
    #[serde(
        rename = "payload",
        with = "::buffa::json_helpers::bytes",
        skip_serializing_if = "::buffa::json_helpers::skip_if::is_empty_bytes"
    )]
    pub payload: ::buffa::alloc::vec::Vec<u8>,
    #[serde(skip)]
    #[doc(hidden)]
    pub __buffa_unknown_fields: ::buffa::UnknownFields,
}
impl ::core::fmt::Debug for PongResponse {
    fn fmt(&self, f: &mut ::core::fmt::Formatter<'_>) -> ::core::fmt::Result {
        f.debug_struct("PongResponse").field("payload", &self.payload).finish()
    }
}
impl PongResponse {
    /// Protobuf type URL for this message, for use with `Any::pack` and
    /// `Any::unpack_if`.
    ///
    /// Format: `type.googleapis.com/<fully.qualified.TypeName>`
    pub const TYPE_URL: &'static str = "type.googleapis.com/tradews.v1.PongResponse";
}
::buffa::impl_default_instance!(PongResponse);
impl ::buffa::MessageName for PongResponse {
    const PACKAGE: &'static str = "tradews.v1";
    const NAME: &'static str = "PongResponse";
    const FULL_NAME: &'static str = "tradews.v1.PongResponse";
    const TYPE_URL: &'static str = "type.googleapis.com/tradews.v1.PongResponse";
}
impl ::buffa::Message for PongResponse {
    /// Returns the total encoded size in bytes.
    ///
    /// The result is a `u32`; the protobuf specification requires all
    /// messages to fit within 2 GiB (2,147,483,647 bytes), so a
    /// compliant message will never overflow this type.
    #[allow(clippy::let_and_return)]
    fn compute_size(&self, _cache: &mut ::buffa::SizeCache) -> u32 {
        #[allow(unused_imports)]
        use ::buffa::Enumeration as _;
        let mut size = 0u32;
        if !self.payload.is_empty() {
            size += 1u32 + ::buffa::types::bytes_encoded_len(&self.payload) as u32;
        }
        size += self.__buffa_unknown_fields.encoded_len() as u32;
        size
    }
    fn write_to(
        &self,
        _cache: &mut ::buffa::SizeCache,
        buf: &mut impl ::buffa::bytes::BufMut,
    ) {
        #[allow(unused_imports)]
        use ::buffa::Enumeration as _;
        if !self.payload.is_empty() {
            ::buffa::types::put_bytes_field(1u32, &self.payload, buf);
        }
        self.__buffa_unknown_fields.write_to(buf);
    }
    fn merge_field(
        &mut self,
        tag: ::buffa::encoding::Tag,
        buf: &mut impl ::buffa::bytes::Buf,
        ctx: ::buffa::DecodeContext<'_>,
    ) -> ::core::result::Result<(), ::buffa::DecodeError> {
        #[allow(unused_imports)]
        use ::buffa::bytes::Buf as _;
        #[allow(unused_imports)]
        use ::buffa::Enumeration as _;
        match tag.field_number() {
            1u32 => {
                ::buffa::encoding::check_wire_type(
                    tag,
                    ::buffa::encoding::WireType::LengthDelimited,
                )?;
                ::buffa::types::merge_bytes(&mut self.payload, buf)?;
            }
            _ => {
                self.__buffa_unknown_fields
                    .push(::buffa::encoding::decode_unknown_field(tag, buf, ctx)?);
            }
        }
        ::core::result::Result::Ok(())
    }
    fn clear(&mut self) {
        self.payload.clear();
        self.__buffa_unknown_fields.clear();
    }
}
impl ::buffa::ExtensionSet for PongResponse {
    const PROTO_FQN: &'static str = "tradews.v1.PongResponse";
    fn unknown_fields(&self) -> &::buffa::UnknownFields {
        &self.__buffa_unknown_fields
    }
    fn unknown_fields_mut(&mut self) -> &mut ::buffa::UnknownFields {
        &mut self.__buffa_unknown_fields
    }
}
impl ::buffa::json_helpers::ProtoElemJson for PongResponse {
    fn serialize_proto_json<S: ::serde::Serializer>(
        v: &Self,
        s: S,
    ) -> ::core::result::Result<S::Ok, S::Error> {
        ::serde::Serialize::serialize(v, s)
    }
    fn deserialize_proto_json<'de, D: ::serde::Deserializer<'de>>(
        d: D,
    ) -> ::core::result::Result<Self, D::Error> {
        <Self as ::serde::Deserialize>::deserialize(d)
    }
}
#[doc(hidden)]
pub const __PONG_RESPONSE_JSON_ANY: ::buffa::type_registry::JsonAnyEntry = ::buffa::type_registry::JsonAnyEntry {
    type_url: "type.googleapis.com/tradews.v1.PongResponse",
    to_json: ::buffa::type_registry::any_to_json::<PongResponse>,
    from_json: ::buffa::type_registry::any_from_json::<PongResponse>,
    is_wkt: false,
};
/// AckResponse carries the command-specific public Orders API acknowledgement.
#[derive(Clone, PartialEq, Default)]
#[derive(::serde::Serialize)]
#[serde(default)]
pub struct AckResponse {
    #[serde(flatten)]
    pub result: ::core::option::Option<__buffa::oneof::ack_response::Result>,
    #[serde(skip)]
    #[doc(hidden)]
    pub __buffa_unknown_fields: ::buffa::UnknownFields,
}
impl ::core::fmt::Debug for AckResponse {
    fn fmt(&self, f: &mut ::core::fmt::Formatter<'_>) -> ::core::fmt::Result {
        f.debug_struct("AckResponse").field("result", &self.result).finish()
    }
}
impl AckResponse {
    /// Protobuf type URL for this message, for use with `Any::pack` and
    /// `Any::unpack_if`.
    ///
    /// Format: `type.googleapis.com/<fully.qualified.TypeName>`
    pub const TYPE_URL: &'static str = "type.googleapis.com/tradews.v1.AckResponse";
}
::buffa::impl_default_instance!(AckResponse);
impl ::buffa::MessageName for AckResponse {
    const PACKAGE: &'static str = "tradews.v1";
    const NAME: &'static str = "AckResponse";
    const FULL_NAME: &'static str = "tradews.v1.AckResponse";
    const TYPE_URL: &'static str = "type.googleapis.com/tradews.v1.AckResponse";
}
impl ::buffa::Message for AckResponse {
    /// Returns the total encoded size in bytes.
    ///
    /// The result is a `u32`; the protobuf specification requires all
    /// messages to fit within 2 GiB (2,147,483,647 bytes), so a
    /// compliant message will never overflow this type.
    #[allow(clippy::let_and_return)]
    fn compute_size(&self, __cache: &mut ::buffa::SizeCache) -> u32 {
        #[allow(unused_imports)]
        use ::buffa::Enumeration as _;
        let mut size = 0u32;
        if let ::core::option::Option::Some(ref v) = self.result {
            match v {
                __buffa::oneof::ack_response::Result::CreateOrder(x) => {
                    let __slot = __cache.reserve();
                    let inner = x.compute_size(__cache);
                    __cache.set(__slot, inner);
                    size
                        += 1u32 + ::buffa::encoding::varint_len(inner as u64) as u32
                            + inner;
                }
                __buffa::oneof::ack_response::Result::CancelOrder(x) => {
                    let __slot = __cache.reserve();
                    let inner = x.compute_size(__cache);
                    __cache.set(__slot, inner);
                    size
                        += 1u32 + ::buffa::encoding::varint_len(inner as u64) as u32
                            + inner;
                }
                __buffa::oneof::ack_response::Result::ModifyOrder(x) => {
                    let __slot = __cache.reserve();
                    let inner = x.compute_size(__cache);
                    __cache.set(__slot, inner);
                    size
                        += 1u32 + ::buffa::encoding::varint_len(inner as u64) as u32
                            + inner;
                }
                __buffa::oneof::ack_response::Result::CancelAllOrders(x) => {
                    let __slot = __cache.reserve();
                    let inner = x.compute_size(__cache);
                    __cache.set(__slot, inner);
                    size
                        += 1u32 + ::buffa::encoding::varint_len(inner as u64) as u32
                            + inner;
                }
            }
        }
        size += self.__buffa_unknown_fields.encoded_len() as u32;
        size
    }
    fn write_to(
        &self,
        __cache: &mut ::buffa::SizeCache,
        buf: &mut impl ::buffa::bytes::BufMut,
    ) {
        #[allow(unused_imports)]
        use ::buffa::Enumeration as _;
        if let ::core::option::Option::Some(ref v) = self.result {
            match v {
                __buffa::oneof::ack_response::Result::CreateOrder(x) => {
                    ::buffa::types::put_len_delimited_header(
                        1u32,
                        __cache.consume_next(),
                        buf,
                    );
                    x.write_to(__cache, buf);
                }
                __buffa::oneof::ack_response::Result::CancelOrder(x) => {
                    ::buffa::types::put_len_delimited_header(
                        2u32,
                        __cache.consume_next(),
                        buf,
                    );
                    x.write_to(__cache, buf);
                }
                __buffa::oneof::ack_response::Result::ModifyOrder(x) => {
                    ::buffa::types::put_len_delimited_header(
                        3u32,
                        __cache.consume_next(),
                        buf,
                    );
                    x.write_to(__cache, buf);
                }
                __buffa::oneof::ack_response::Result::CancelAllOrders(x) => {
                    ::buffa::types::put_len_delimited_header(
                        4u32,
                        __cache.consume_next(),
                        buf,
                    );
                    x.write_to(__cache, buf);
                }
            }
        }
        self.__buffa_unknown_fields.write_to(buf);
    }
    fn merge_field(
        &mut self,
        tag: ::buffa::encoding::Tag,
        buf: &mut impl ::buffa::bytes::Buf,
        ctx: ::buffa::DecodeContext<'_>,
    ) -> ::core::result::Result<(), ::buffa::DecodeError> {
        #[allow(unused_imports)]
        use ::buffa::bytes::Buf as _;
        #[allow(unused_imports)]
        use ::buffa::Enumeration as _;
        match tag.field_number() {
            1u32 => {
                ::buffa::encoding::check_wire_type(
                    tag,
                    ::buffa::encoding::WireType::LengthDelimited,
                )?;
                if let ::core::option::Option::Some(
                    __buffa::oneof::ack_response::Result::CreateOrder(ref mut existing),
                ) = self.result
                {
                    ::buffa::Message::merge_length_delimited(&mut **existing, buf, ctx)?;
                } else {
                    let mut val = ::core::default::Default::default();
                    ::buffa::Message::merge_length_delimited(&mut val, buf, ctx)?;
                    self.result = ::core::option::Option::Some(
                        __buffa::oneof::ack_response::Result::CreateOrder(
                            ::buffa::alloc::boxed::Box::new(val),
                        ),
                    );
                }
            }
            2u32 => {
                ::buffa::encoding::check_wire_type(
                    tag,
                    ::buffa::encoding::WireType::LengthDelimited,
                )?;
                if let ::core::option::Option::Some(
                    __buffa::oneof::ack_response::Result::CancelOrder(ref mut existing),
                ) = self.result
                {
                    ::buffa::Message::merge_length_delimited(&mut **existing, buf, ctx)?;
                } else {
                    let mut val = ::core::default::Default::default();
                    ::buffa::Message::merge_length_delimited(&mut val, buf, ctx)?;
                    self.result = ::core::option::Option::Some(
                        __buffa::oneof::ack_response::Result::CancelOrder(
                            ::buffa::alloc::boxed::Box::new(val),
                        ),
                    );
                }
            }
            3u32 => {
                ::buffa::encoding::check_wire_type(
                    tag,
                    ::buffa::encoding::WireType::LengthDelimited,
                )?;
                if let ::core::option::Option::Some(
                    __buffa::oneof::ack_response::Result::ModifyOrder(ref mut existing),
                ) = self.result
                {
                    ::buffa::Message::merge_length_delimited(&mut **existing, buf, ctx)?;
                } else {
                    let mut val = ::core::default::Default::default();
                    ::buffa::Message::merge_length_delimited(&mut val, buf, ctx)?;
                    self.result = ::core::option::Option::Some(
                        __buffa::oneof::ack_response::Result::ModifyOrder(
                            ::buffa::alloc::boxed::Box::new(val),
                        ),
                    );
                }
            }
            4u32 => {
                ::buffa::encoding::check_wire_type(
                    tag,
                    ::buffa::encoding::WireType::LengthDelimited,
                )?;
                if let ::core::option::Option::Some(
                    __buffa::oneof::ack_response::Result::CancelAllOrders(
                        ref mut existing,
                    ),
                ) = self.result
                {
                    ::buffa::Message::merge_length_delimited(&mut **existing, buf, ctx)?;
                } else {
                    let mut val = ::core::default::Default::default();
                    ::buffa::Message::merge_length_delimited(&mut val, buf, ctx)?;
                    self.result = ::core::option::Option::Some(
                        __buffa::oneof::ack_response::Result::CancelAllOrders(
                            ::buffa::alloc::boxed::Box::new(val),
                        ),
                    );
                }
            }
            _ => {
                self.__buffa_unknown_fields
                    .push(::buffa::encoding::decode_unknown_field(tag, buf, ctx)?);
            }
        }
        ::core::result::Result::Ok(())
    }
    fn clear(&mut self) {
        self.result = ::core::option::Option::None;
        self.__buffa_unknown_fields.clear();
    }
}
impl ::buffa::ExtensionSet for AckResponse {
    const PROTO_FQN: &'static str = "tradews.v1.AckResponse";
    fn unknown_fields(&self) -> &::buffa::UnknownFields {
        &self.__buffa_unknown_fields
    }
    fn unknown_fields_mut(&mut self) -> &mut ::buffa::UnknownFields {
        &mut self.__buffa_unknown_fields
    }
}
impl<'de> serde::Deserialize<'de> for AckResponse {
    fn deserialize<D: serde::Deserializer<'de>>(
        d: D,
    ) -> ::core::result::Result<Self, D::Error> {
        struct _V;
        impl<'de> serde::de::Visitor<'de> for _V {
            type Value = AckResponse;
            fn expecting(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result {
                f.write_str("struct AckResponse")
            }
            #[allow(clippy::field_reassign_with_default)]
            fn visit_map<A: serde::de::MapAccess<'de>>(
                self,
                mut map: A,
            ) -> ::core::result::Result<AckResponse, A::Error> {
                let mut __oneof_result: ::core::option::Option<
                    __buffa::oneof::ack_response::Result,
                > = None;
                while let Some(key) = map.next_key::<::buffa::alloc::string::String>()? {
                    match key.as_str() {
                        "createOrder" | "create_order" => {
                            let v: ::core::option::Option<
                                super::super::orders::v1::CreateOrderResponse,
                            > = map
                                .next_value_seed(
                                    ::buffa::json_helpers::NullableDeserializeSeed(
                                        ::buffa::json_helpers::DefaultDeserializeSeed::<
                                            super::super::orders::v1::CreateOrderResponse,
                                        >::new(),
                                    ),
                                )?;
                            if let Some(v) = v {
                                if __oneof_result.is_some() {
                                    return Err(
                                        serde::de::Error::custom(
                                            "multiple oneof fields set for 'result'",
                                        ),
                                    );
                                }
                                __oneof_result = Some(
                                    __buffa::oneof::ack_response::Result::CreateOrder(
                                        ::buffa::alloc::boxed::Box::new(v),
                                    ),
                                );
                            }
                        }
                        "cancelOrder" | "cancel_order" => {
                            let v: ::core::option::Option<
                                super::super::orders::v1::CancelOrderResponse,
                            > = map
                                .next_value_seed(
                                    ::buffa::json_helpers::NullableDeserializeSeed(
                                        ::buffa::json_helpers::DefaultDeserializeSeed::<
                                            super::super::orders::v1::CancelOrderResponse,
                                        >::new(),
                                    ),
                                )?;
                            if let Some(v) = v {
                                if __oneof_result.is_some() {
                                    return Err(
                                        serde::de::Error::custom(
                                            "multiple oneof fields set for 'result'",
                                        ),
                                    );
                                }
                                __oneof_result = Some(
                                    __buffa::oneof::ack_response::Result::CancelOrder(
                                        ::buffa::alloc::boxed::Box::new(v),
                                    ),
                                );
                            }
                        }
                        "modifyOrder" | "modify_order" => {
                            let v: ::core::option::Option<
                                super::super::orders::v1::ModifyOrderResponse,
                            > = map
                                .next_value_seed(
                                    ::buffa::json_helpers::NullableDeserializeSeed(
                                        ::buffa::json_helpers::DefaultDeserializeSeed::<
                                            super::super::orders::v1::ModifyOrderResponse,
                                        >::new(),
                                    ),
                                )?;
                            if let Some(v) = v {
                                if __oneof_result.is_some() {
                                    return Err(
                                        serde::de::Error::custom(
                                            "multiple oneof fields set for 'result'",
                                        ),
                                    );
                                }
                                __oneof_result = Some(
                                    __buffa::oneof::ack_response::Result::ModifyOrder(
                                        ::buffa::alloc::boxed::Box::new(v),
                                    ),
                                );
                            }
                        }
                        "cancelAllOrders" | "cancel_all_orders" => {
                            let v: ::core::option::Option<
                                super::super::orders::v1::CancelAllOrdersResponse,
                            > = map
                                .next_value_seed(
                                    ::buffa::json_helpers::NullableDeserializeSeed(
                                        ::buffa::json_helpers::DefaultDeserializeSeed::<
                                            super::super::orders::v1::CancelAllOrdersResponse,
                                        >::new(),
                                    ),
                                )?;
                            if let Some(v) = v {
                                if __oneof_result.is_some() {
                                    return Err(
                                        serde::de::Error::custom(
                                            "multiple oneof fields set for 'result'",
                                        ),
                                    );
                                }
                                __oneof_result = Some(
                                    __buffa::oneof::ack_response::Result::CancelAllOrders(
                                        ::buffa::alloc::boxed::Box::new(v),
                                    ),
                                );
                            }
                        }
                        _ => {
                            map.next_value::<serde::de::IgnoredAny>()?;
                        }
                    }
                }
                let mut __r = <AckResponse as ::core::default::Default>::default();
                __r.result = __oneof_result;
                Ok(__r)
            }
        }
        d.deserialize_map(_V)
    }
}
impl ::buffa::json_helpers::ProtoElemJson for AckResponse {
    fn serialize_proto_json<S: ::serde::Serializer>(
        v: &Self,
        s: S,
    ) -> ::core::result::Result<S::Ok, S::Error> {
        ::serde::Serialize::serialize(v, s)
    }
    fn deserialize_proto_json<'de, D: ::serde::Deserializer<'de>>(
        d: D,
    ) -> ::core::result::Result<Self, D::Error> {
        <Self as ::serde::Deserialize>::deserialize(d)
    }
}
#[doc(hidden)]
pub const __ACK_RESPONSE_JSON_ANY: ::buffa::type_registry::JsonAnyEntry = ::buffa::type_registry::JsonAnyEntry {
    type_url: "type.googleapis.com/tradews.v1.AckResponse",
    to_json: ::buffa::type_registry::any_to_json::<AckResponse>,
    from_json: ::buffa::type_registry::any_from_json::<AckResponse>,
    is_wkt: false,
};
pub mod ack_response {
    #[allow(unused_imports)]
    use super::*;
    #[doc(inline)]
    pub use super::__buffa::oneof::ack_response::Result;
    #[doc(inline)]
    pub use super::__buffa::view::oneof::ack_response::Result as ResultView;
}
/// CommandReject reports a command-level failure without closing the session.
#[derive(Clone, PartialEq, Default)]
#[derive(::serde::Serialize, ::serde::Deserialize)]
#[serde(default)]
pub struct CommandReject {
    /// Stable machine-readable reject code.
    ///
    /// Field 1: `code`
    #[serde(
        rename = "code",
        with = "::buffa::json_helpers::proto_string",
        skip_serializing_if = "::buffa::json_helpers::skip_if::is_empty_str"
    )]
    pub code: ::buffa::alloc::string::String,
    /// Client-safe diagnostic detail.
    ///
    /// Field 2: `detail`
    #[serde(
        rename = "detail",
        with = "::buffa::json_helpers::proto_string",
        skip_serializing_if = "::buffa::json_helpers::skip_if::is_empty_str"
    )]
    pub detail: ::buffa::alloc::string::String,
    #[serde(skip)]
    #[doc(hidden)]
    pub __buffa_unknown_fields: ::buffa::UnknownFields,
}
impl ::core::fmt::Debug for CommandReject {
    fn fmt(&self, f: &mut ::core::fmt::Formatter<'_>) -> ::core::fmt::Result {
        f.debug_struct("CommandReject")
            .field("code", &self.code)
            .field("detail", &self.detail)
            .finish()
    }
}
impl CommandReject {
    /// Protobuf type URL for this message, for use with `Any::pack` and
    /// `Any::unpack_if`.
    ///
    /// Format: `type.googleapis.com/<fully.qualified.TypeName>`
    pub const TYPE_URL: &'static str = "type.googleapis.com/tradews.v1.CommandReject";
}
::buffa::impl_default_instance!(CommandReject);
impl ::buffa::MessageName for CommandReject {
    const PACKAGE: &'static str = "tradews.v1";
    const NAME: &'static str = "CommandReject";
    const FULL_NAME: &'static str = "tradews.v1.CommandReject";
    const TYPE_URL: &'static str = "type.googleapis.com/tradews.v1.CommandReject";
}
impl ::buffa::Message for CommandReject {
    /// Returns the total encoded size in bytes.
    ///
    /// The result is a `u32`; the protobuf specification requires all
    /// messages to fit within 2 GiB (2,147,483,647 bytes), so a
    /// compliant message will never overflow this type.
    #[allow(clippy::let_and_return)]
    fn compute_size(&self, _cache: &mut ::buffa::SizeCache) -> u32 {
        #[allow(unused_imports)]
        use ::buffa::Enumeration as _;
        let mut size = 0u32;
        if !self.code.is_empty() {
            size += 1u32 + ::buffa::types::string_encoded_len(&self.code) as u32;
        }
        if !self.detail.is_empty() {
            size += 1u32 + ::buffa::types::string_encoded_len(&self.detail) as u32;
        }
        size += self.__buffa_unknown_fields.encoded_len() as u32;
        size
    }
    fn write_to(
        &self,
        _cache: &mut ::buffa::SizeCache,
        buf: &mut impl ::buffa::bytes::BufMut,
    ) {
        #[allow(unused_imports)]
        use ::buffa::Enumeration as _;
        if !self.code.is_empty() {
            ::buffa::types::put_string_field(1u32, &self.code, buf);
        }
        if !self.detail.is_empty() {
            ::buffa::types::put_string_field(2u32, &self.detail, buf);
        }
        self.__buffa_unknown_fields.write_to(buf);
    }
    fn merge_field(
        &mut self,
        tag: ::buffa::encoding::Tag,
        buf: &mut impl ::buffa::bytes::Buf,
        ctx: ::buffa::DecodeContext<'_>,
    ) -> ::core::result::Result<(), ::buffa::DecodeError> {
        #[allow(unused_imports)]
        use ::buffa::bytes::Buf as _;
        #[allow(unused_imports)]
        use ::buffa::Enumeration as _;
        match tag.field_number() {
            1u32 => {
                ::buffa::encoding::check_wire_type(
                    tag,
                    ::buffa::encoding::WireType::LengthDelimited,
                )?;
                ::buffa::types::merge_string(&mut self.code, buf)?;
            }
            2u32 => {
                ::buffa::encoding::check_wire_type(
                    tag,
                    ::buffa::encoding::WireType::LengthDelimited,
                )?;
                ::buffa::types::merge_string(&mut self.detail, buf)?;
            }
            _ => {
                self.__buffa_unknown_fields
                    .push(::buffa::encoding::decode_unknown_field(tag, buf, ctx)?);
            }
        }
        ::core::result::Result::Ok(())
    }
    fn clear(&mut self) {
        self.code.clear();
        self.detail.clear();
        self.__buffa_unknown_fields.clear();
    }
}
impl ::buffa::ExtensionSet for CommandReject {
    const PROTO_FQN: &'static str = "tradews.v1.CommandReject";
    fn unknown_fields(&self) -> &::buffa::UnknownFields {
        &self.__buffa_unknown_fields
    }
    fn unknown_fields_mut(&mut self) -> &mut ::buffa::UnknownFields {
        &mut self.__buffa_unknown_fields
    }
}
impl ::buffa::json_helpers::ProtoElemJson for CommandReject {
    fn serialize_proto_json<S: ::serde::Serializer>(
        v: &Self,
        s: S,
    ) -> ::core::result::Result<S::Ok, S::Error> {
        ::serde::Serialize::serialize(v, s)
    }
    fn deserialize_proto_json<'de, D: ::serde::Deserializer<'de>>(
        d: D,
    ) -> ::core::result::Result<Self, D::Error> {
        <Self as ::serde::Deserialize>::deserialize(d)
    }
}
#[doc(hidden)]
pub const __COMMAND_REJECT_JSON_ANY: ::buffa::type_registry::JsonAnyEntry = ::buffa::type_registry::JsonAnyEntry {
    type_url: "type.googleapis.com/tradews.v1.CommandReject",
    to_json: ::buffa::type_registry::any_to_json::<CommandReject>,
    from_json: ::buffa::type_registry::any_from_json::<CommandReject>,
    is_wkt: false,
};
/// OverloadResponse reports that the session exceeded server admission limits.
#[derive(Clone, PartialEq, Default)]
#[derive(::serde::Serialize, ::serde::Deserialize)]
#[serde(default)]
pub struct OverloadResponse {
    /// Stable machine-readable overload code.
    ///
    /// Field 1: `code`
    #[serde(
        rename = "code",
        with = "::buffa::json_helpers::proto_string",
        skip_serializing_if = "::buffa::json_helpers::skip_if::is_empty_str"
    )]
    pub code: ::buffa::alloc::string::String,
    /// Client-safe diagnostic detail.
    ///
    /// Field 2: `detail`
    #[serde(
        rename = "detail",
        with = "::buffa::json_helpers::proto_string",
        skip_serializing_if = "::buffa::json_helpers::skip_if::is_empty_str"
    )]
    pub detail: ::buffa::alloc::string::String,
    #[serde(skip)]
    #[doc(hidden)]
    pub __buffa_unknown_fields: ::buffa::UnknownFields,
}
impl ::core::fmt::Debug for OverloadResponse {
    fn fmt(&self, f: &mut ::core::fmt::Formatter<'_>) -> ::core::fmt::Result {
        f.debug_struct("OverloadResponse")
            .field("code", &self.code)
            .field("detail", &self.detail)
            .finish()
    }
}
impl OverloadResponse {
    /// Protobuf type URL for this message, for use with `Any::pack` and
    /// `Any::unpack_if`.
    ///
    /// Format: `type.googleapis.com/<fully.qualified.TypeName>`
    pub const TYPE_URL: &'static str = "type.googleapis.com/tradews.v1.OverloadResponse";
}
::buffa::impl_default_instance!(OverloadResponse);
impl ::buffa::MessageName for OverloadResponse {
    const PACKAGE: &'static str = "tradews.v1";
    const NAME: &'static str = "OverloadResponse";
    const FULL_NAME: &'static str = "tradews.v1.OverloadResponse";
    const TYPE_URL: &'static str = "type.googleapis.com/tradews.v1.OverloadResponse";
}
impl ::buffa::Message for OverloadResponse {
    /// Returns the total encoded size in bytes.
    ///
    /// The result is a `u32`; the protobuf specification requires all
    /// messages to fit within 2 GiB (2,147,483,647 bytes), so a
    /// compliant message will never overflow this type.
    #[allow(clippy::let_and_return)]
    fn compute_size(&self, _cache: &mut ::buffa::SizeCache) -> u32 {
        #[allow(unused_imports)]
        use ::buffa::Enumeration as _;
        let mut size = 0u32;
        if !self.code.is_empty() {
            size += 1u32 + ::buffa::types::string_encoded_len(&self.code) as u32;
        }
        if !self.detail.is_empty() {
            size += 1u32 + ::buffa::types::string_encoded_len(&self.detail) as u32;
        }
        size += self.__buffa_unknown_fields.encoded_len() as u32;
        size
    }
    fn write_to(
        &self,
        _cache: &mut ::buffa::SizeCache,
        buf: &mut impl ::buffa::bytes::BufMut,
    ) {
        #[allow(unused_imports)]
        use ::buffa::Enumeration as _;
        if !self.code.is_empty() {
            ::buffa::types::put_string_field(1u32, &self.code, buf);
        }
        if !self.detail.is_empty() {
            ::buffa::types::put_string_field(2u32, &self.detail, buf);
        }
        self.__buffa_unknown_fields.write_to(buf);
    }
    fn merge_field(
        &mut self,
        tag: ::buffa::encoding::Tag,
        buf: &mut impl ::buffa::bytes::Buf,
        ctx: ::buffa::DecodeContext<'_>,
    ) -> ::core::result::Result<(), ::buffa::DecodeError> {
        #[allow(unused_imports)]
        use ::buffa::bytes::Buf as _;
        #[allow(unused_imports)]
        use ::buffa::Enumeration as _;
        match tag.field_number() {
            1u32 => {
                ::buffa::encoding::check_wire_type(
                    tag,
                    ::buffa::encoding::WireType::LengthDelimited,
                )?;
                ::buffa::types::merge_string(&mut self.code, buf)?;
            }
            2u32 => {
                ::buffa::encoding::check_wire_type(
                    tag,
                    ::buffa::encoding::WireType::LengthDelimited,
                )?;
                ::buffa::types::merge_string(&mut self.detail, buf)?;
            }
            _ => {
                self.__buffa_unknown_fields
                    .push(::buffa::encoding::decode_unknown_field(tag, buf, ctx)?);
            }
        }
        ::core::result::Result::Ok(())
    }
    fn clear(&mut self) {
        self.code.clear();
        self.detail.clear();
        self.__buffa_unknown_fields.clear();
    }
}
impl ::buffa::ExtensionSet for OverloadResponse {
    const PROTO_FQN: &'static str = "tradews.v1.OverloadResponse";
    fn unknown_fields(&self) -> &::buffa::UnknownFields {
        &self.__buffa_unknown_fields
    }
    fn unknown_fields_mut(&mut self) -> &mut ::buffa::UnknownFields {
        &mut self.__buffa_unknown_fields
    }
}
impl ::buffa::json_helpers::ProtoElemJson for OverloadResponse {
    fn serialize_proto_json<S: ::serde::Serializer>(
        v: &Self,
        s: S,
    ) -> ::core::result::Result<S::Ok, S::Error> {
        ::serde::Serialize::serialize(v, s)
    }
    fn deserialize_proto_json<'de, D: ::serde::Deserializer<'de>>(
        d: D,
    ) -> ::core::result::Result<Self, D::Error> {
        <Self as ::serde::Deserialize>::deserialize(d)
    }
}
#[doc(hidden)]
pub const __OVERLOAD_RESPONSE_JSON_ANY: ::buffa::type_registry::JsonAnyEntry = ::buffa::type_registry::JsonAnyEntry {
    type_url: "type.googleapis.com/tradews.v1.OverloadResponse",
    to_json: ::buffa::type_registry::any_to_json::<OverloadResponse>,
    from_json: ::buffa::type_registry::any_from_json::<OverloadResponse>,
    is_wkt: false,
};
/// TerminalSessionEvent reports a terminal session condition.
#[derive(Clone, PartialEq, Default)]
#[derive(::serde::Serialize, ::serde::Deserialize)]
#[serde(default)]
pub struct TerminalSessionEvent {
    /// Stable machine-readable terminal code.
    ///
    /// Field 1: `code`
    #[serde(
        rename = "code",
        with = "::buffa::json_helpers::proto_string",
        skip_serializing_if = "::buffa::json_helpers::skip_if::is_empty_str"
    )]
    pub code: ::buffa::alloc::string::String,
    /// Client-safe diagnostic detail.
    ///
    /// Field 2: `detail`
    #[serde(
        rename = "detail",
        with = "::buffa::json_helpers::proto_string",
        skip_serializing_if = "::buffa::json_helpers::skip_if::is_empty_str"
    )]
    pub detail: ::buffa::alloc::string::String,
    #[serde(skip)]
    #[doc(hidden)]
    pub __buffa_unknown_fields: ::buffa::UnknownFields,
}
impl ::core::fmt::Debug for TerminalSessionEvent {
    fn fmt(&self, f: &mut ::core::fmt::Formatter<'_>) -> ::core::fmt::Result {
        f.debug_struct("TerminalSessionEvent")
            .field("code", &self.code)
            .field("detail", &self.detail)
            .finish()
    }
}
impl TerminalSessionEvent {
    /// Protobuf type URL for this message, for use with `Any::pack` and
    /// `Any::unpack_if`.
    ///
    /// Format: `type.googleapis.com/<fully.qualified.TypeName>`
    pub const TYPE_URL: &'static str = "type.googleapis.com/tradews.v1.TerminalSessionEvent";
}
::buffa::impl_default_instance!(TerminalSessionEvent);
impl ::buffa::MessageName for TerminalSessionEvent {
    const PACKAGE: &'static str = "tradews.v1";
    const NAME: &'static str = "TerminalSessionEvent";
    const FULL_NAME: &'static str = "tradews.v1.TerminalSessionEvent";
    const TYPE_URL: &'static str = "type.googleapis.com/tradews.v1.TerminalSessionEvent";
}
impl ::buffa::Message for TerminalSessionEvent {
    /// Returns the total encoded size in bytes.
    ///
    /// The result is a `u32`; the protobuf specification requires all
    /// messages to fit within 2 GiB (2,147,483,647 bytes), so a
    /// compliant message will never overflow this type.
    #[allow(clippy::let_and_return)]
    fn compute_size(&self, _cache: &mut ::buffa::SizeCache) -> u32 {
        #[allow(unused_imports)]
        use ::buffa::Enumeration as _;
        let mut size = 0u32;
        if !self.code.is_empty() {
            size += 1u32 + ::buffa::types::string_encoded_len(&self.code) as u32;
        }
        if !self.detail.is_empty() {
            size += 1u32 + ::buffa::types::string_encoded_len(&self.detail) as u32;
        }
        size += self.__buffa_unknown_fields.encoded_len() as u32;
        size
    }
    fn write_to(
        &self,
        _cache: &mut ::buffa::SizeCache,
        buf: &mut impl ::buffa::bytes::BufMut,
    ) {
        #[allow(unused_imports)]
        use ::buffa::Enumeration as _;
        if !self.code.is_empty() {
            ::buffa::types::put_string_field(1u32, &self.code, buf);
        }
        if !self.detail.is_empty() {
            ::buffa::types::put_string_field(2u32, &self.detail, buf);
        }
        self.__buffa_unknown_fields.write_to(buf);
    }
    fn merge_field(
        &mut self,
        tag: ::buffa::encoding::Tag,
        buf: &mut impl ::buffa::bytes::Buf,
        ctx: ::buffa::DecodeContext<'_>,
    ) -> ::core::result::Result<(), ::buffa::DecodeError> {
        #[allow(unused_imports)]
        use ::buffa::bytes::Buf as _;
        #[allow(unused_imports)]
        use ::buffa::Enumeration as _;
        match tag.field_number() {
            1u32 => {
                ::buffa::encoding::check_wire_type(
                    tag,
                    ::buffa::encoding::WireType::LengthDelimited,
                )?;
                ::buffa::types::merge_string(&mut self.code, buf)?;
            }
            2u32 => {
                ::buffa::encoding::check_wire_type(
                    tag,
                    ::buffa::encoding::WireType::LengthDelimited,
                )?;
                ::buffa::types::merge_string(&mut self.detail, buf)?;
            }
            _ => {
                self.__buffa_unknown_fields
                    .push(::buffa::encoding::decode_unknown_field(tag, buf, ctx)?);
            }
        }
        ::core::result::Result::Ok(())
    }
    fn clear(&mut self) {
        self.code.clear();
        self.detail.clear();
        self.__buffa_unknown_fields.clear();
    }
}
impl ::buffa::ExtensionSet for TerminalSessionEvent {
    const PROTO_FQN: &'static str = "tradews.v1.TerminalSessionEvent";
    fn unknown_fields(&self) -> &::buffa::UnknownFields {
        &self.__buffa_unknown_fields
    }
    fn unknown_fields_mut(&mut self) -> &mut ::buffa::UnknownFields {
        &mut self.__buffa_unknown_fields
    }
}
impl ::buffa::json_helpers::ProtoElemJson for TerminalSessionEvent {
    fn serialize_proto_json<S: ::serde::Serializer>(
        v: &Self,
        s: S,
    ) -> ::core::result::Result<S::Ok, S::Error> {
        ::serde::Serialize::serialize(v, s)
    }
    fn deserialize_proto_json<'de, D: ::serde::Deserializer<'de>>(
        d: D,
    ) -> ::core::result::Result<Self, D::Error> {
        <Self as ::serde::Deserialize>::deserialize(d)
    }
}
#[doc(hidden)]
pub const __TERMINAL_SESSION_EVENT_JSON_ANY: ::buffa::type_registry::JsonAnyEntry = ::buffa::type_registry::JsonAnyEntry {
    type_url: "type.googleapis.com/tradews.v1.TerminalSessionEvent",
    to_json: ::buffa::type_registry::any_to_json::<TerminalSessionEvent>,
    from_json: ::buffa::type_registry::any_from_json::<TerminalSessionEvent>,
    is_wkt: false,
};
#[allow(
    non_camel_case_types,
    dead_code,
    unused_imports,
    unused_qualifications,
    clippy::derivable_impls,
    clippy::match_single_binding,
    clippy::uninlined_format_args,
    clippy::doc_lazy_continuation,
    clippy::module_inception
)]
pub mod __buffa {
    #[allow(unused_imports)]
    use super::*;
    pub mod view {
        #[allow(unused_imports)]
        use super::*;
        /// ClientFrame is the protobuf write-websocket envelope. Its payloads reuse the
        /// public Orders API request contracts so every transport shares one order model.
        #[derive(Clone, Debug, Default)]
        pub struct ClientFrameView<'a> {
            /// Monotonic per-connection client sequence number, starting at 1.
            ///
            /// Field 1: `seq`
            pub seq: u64,
            /// Client correlation token echoed in every server response.
            ///
            /// Field 2: `correlation_id`
            pub correlation_id: &'a str,
            pub payload: ::core::option::Option<
                super::super::__buffa::view::oneof::client_frame::Payload<'a>,
            >,
            pub __buffa_unknown_fields: ::buffa::UnknownFieldsView<'a>,
        }
        impl<'a> ::buffa::MessageView<'a> for ClientFrameView<'a> {
            type Owned = super::super::ClientFrame;
            fn decode_view(
                buf: &'a [u8],
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                let __limit = ::core::cell::Cell::new(
                    ::buffa::DEFAULT_UNKNOWN_FIELD_LIMIT,
                );
                <Self as ::buffa::MessageView>::decode_view_ctx(
                    buf,
                    ::buffa::DecodeContext::new(::buffa::RECURSION_LIMIT, &__limit),
                )
            }
            fn decode_view_with_ctx(
                buf: &'a [u8],
                ctx: ::buffa::DecodeContext<'_>,
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                <Self as ::buffa::MessageView>::decode_view_ctx(buf, ctx)
            }
            fn merge_view_field(
                &mut self,
                tag: ::buffa::encoding::Tag,
                cur: &'a [u8],
                before_tag: &'a [u8],
                ctx: ::buffa::DecodeContext<'_>,
            ) -> ::core::result::Result<&'a [u8], ::buffa::DecodeError> {
                let _ = ctx;
                #[allow(unused_variables)]
                let view = self;
                let mut cur = cur;
                match tag.field_number() {
                    1u32 => {
                        ::buffa::encoding::check_wire_type(
                            tag,
                            ::buffa::encoding::WireType::Varint,
                        )?;
                        view.seq = ::buffa::types::decode_uint64(&mut cur)?;
                    }
                    2u32 => {
                        ::buffa::encoding::check_wire_type(
                            tag,
                            ::buffa::encoding::WireType::LengthDelimited,
                        )?;
                        view.correlation_id = ::buffa::types::borrow_str(&mut cur)?;
                    }
                    10u32 => {
                        ::buffa::encoding::check_wire_type(
                            tag,
                            ::buffa::encoding::WireType::LengthDelimited,
                        )?;
                        let __sub_ctx = ctx.descend()?;
                        let sub = ::buffa::types::borrow_bytes(&mut cur)?;
                        if let Some(
                            super::super::__buffa::view::oneof::client_frame::Payload::Ping(
                                ref mut existing,
                            ),
                        ) = view.payload
                        {
                            ::buffa::MessageView::merge_into_view(
                                &mut **existing,
                                sub,
                                __sub_ctx,
                            )?;
                        } else {
                            view.payload = Some(
                                super::super::__buffa::view::oneof::client_frame::Payload::Ping(
                                    ::buffa::alloc::boxed::Box::new(
                                        <super::super::__buffa::view::PingRequestView as ::buffa::MessageView>::decode_view_ctx(
                                            sub,
                                            __sub_ctx,
                                        )?,
                                    ),
                                ),
                            );
                        }
                    }
                    11u32 => {
                        ::buffa::encoding::check_wire_type(
                            tag,
                            ::buffa::encoding::WireType::LengthDelimited,
                        )?;
                        let __sub_ctx = ctx.descend()?;
                        let sub = ::buffa::types::borrow_bytes(&mut cur)?;
                        if let Some(
                            super::super::__buffa::view::oneof::client_frame::Payload::CreateOrder(
                                ref mut existing,
                            ),
                        ) = view.payload
                        {
                            ::buffa::MessageView::merge_into_view(
                                &mut **existing,
                                sub,
                                __sub_ctx,
                            )?;
                        } else {
                            view.payload = Some(
                                super::super::__buffa::view::oneof::client_frame::Payload::CreateOrder(
                                    ::buffa::alloc::boxed::Box::new(
                                        <super::super::super::super::orders::v1::__buffa::view::CreateOrderRequestView as ::buffa::MessageView>::decode_view_ctx(
                                            sub,
                                            __sub_ctx,
                                        )?,
                                    ),
                                ),
                            );
                        }
                    }
                    12u32 => {
                        ::buffa::encoding::check_wire_type(
                            tag,
                            ::buffa::encoding::WireType::LengthDelimited,
                        )?;
                        let __sub_ctx = ctx.descend()?;
                        let sub = ::buffa::types::borrow_bytes(&mut cur)?;
                        if let Some(
                            super::super::__buffa::view::oneof::client_frame::Payload::CancelOrder(
                                ref mut existing,
                            ),
                        ) = view.payload
                        {
                            ::buffa::MessageView::merge_into_view(
                                &mut **existing,
                                sub,
                                __sub_ctx,
                            )?;
                        } else {
                            view.payload = Some(
                                super::super::__buffa::view::oneof::client_frame::Payload::CancelOrder(
                                    ::buffa::alloc::boxed::Box::new(
                                        <super::super::super::super::orders::v1::__buffa::view::CancelOrderRequestView as ::buffa::MessageView>::decode_view_ctx(
                                            sub,
                                            __sub_ctx,
                                        )?,
                                    ),
                                ),
                            );
                        }
                    }
                    13u32 => {
                        ::buffa::encoding::check_wire_type(
                            tag,
                            ::buffa::encoding::WireType::LengthDelimited,
                        )?;
                        let __sub_ctx = ctx.descend()?;
                        let sub = ::buffa::types::borrow_bytes(&mut cur)?;
                        if let Some(
                            super::super::__buffa::view::oneof::client_frame::Payload::ModifyOrder(
                                ref mut existing,
                            ),
                        ) = view.payload
                        {
                            ::buffa::MessageView::merge_into_view(
                                &mut **existing,
                                sub,
                                __sub_ctx,
                            )?;
                        } else {
                            view.payload = Some(
                                super::super::__buffa::view::oneof::client_frame::Payload::ModifyOrder(
                                    ::buffa::alloc::boxed::Box::new(
                                        <super::super::super::super::orders::v1::__buffa::view::ModifyOrderRequestView as ::buffa::MessageView>::decode_view_ctx(
                                            sub,
                                            __sub_ctx,
                                        )?,
                                    ),
                                ),
                            );
                        }
                    }
                    14u32 => {
                        ::buffa::encoding::check_wire_type(
                            tag,
                            ::buffa::encoding::WireType::LengthDelimited,
                        )?;
                        let __sub_ctx = ctx.descend()?;
                        let sub = ::buffa::types::borrow_bytes(&mut cur)?;
                        if let Some(
                            super::super::__buffa::view::oneof::client_frame::Payload::CancelAllOrders(
                                ref mut existing,
                            ),
                        ) = view.payload
                        {
                            ::buffa::MessageView::merge_into_view(
                                &mut **existing,
                                sub,
                                __sub_ctx,
                            )?;
                        } else {
                            view.payload = Some(
                                super::super::__buffa::view::oneof::client_frame::Payload::CancelAllOrders(
                                    ::buffa::alloc::boxed::Box::new(
                                        <super::super::super::super::orders::v1::__buffa::view::CancelAllOrdersRequestView as ::buffa::MessageView>::decode_view_ctx(
                                            sub,
                                            __sub_ctx,
                                        )?,
                                    ),
                                ),
                            );
                        }
                    }
                    _ => {
                        ::buffa::encoding::skip_field_depth(tag, &mut cur, ctx.depth())?;
                        let span_len = before_tag.len() - cur.len();
                        view.__buffa_unknown_fields
                            .push_record(before_tag, span_len, ctx)?;
                    }
                }
                ::core::result::Result::Ok(cur)
            }
            fn to_owned_message(
                &self,
            ) -> ::core::result::Result<
                super::super::ClientFrame,
                ::buffa::DecodeError,
            > {
                self.to_owned_from_source(None)
            }
            #[allow(clippy::useless_conversion, clippy::needless_update)]
            fn to_owned_from_source(
                &self,
                __buffa_src: ::core::option::Option<&::buffa::bytes::Bytes>,
            ) -> ::core::result::Result<
                super::super::ClientFrame,
                ::buffa::DecodeError,
            > {
                #[allow(unused_imports)]
                use ::buffa::alloc::string::ToString as _;
                let _ = __buffa_src;
                ::core::result::Result::Ok(super::super::ClientFrame {
                    seq: self.seq,
                    correlation_id: self.correlation_id.to_string(),
                    payload: match self.payload.as_ref() {
                        ::core::option::Option::Some(v) => {
                            ::core::option::Option::Some(
                                match v {
                                    super::super::__buffa::view::oneof::client_frame::Payload::Ping(
                                        v,
                                    ) => {
                                        super::super::__buffa::oneof::client_frame::Payload::Ping(
                                            ::buffa::alloc::boxed::Box::new(
                                                v.to_owned_from_source(__buffa_src)?,
                                            ),
                                        )
                                    }
                                    super::super::__buffa::view::oneof::client_frame::Payload::CreateOrder(
                                        v,
                                    ) => {
                                        super::super::__buffa::oneof::client_frame::Payload::CreateOrder(
                                            ::buffa::alloc::boxed::Box::new(
                                                v.to_owned_from_source(__buffa_src)?,
                                            ),
                                        )
                                    }
                                    super::super::__buffa::view::oneof::client_frame::Payload::CancelOrder(
                                        v,
                                    ) => {
                                        super::super::__buffa::oneof::client_frame::Payload::CancelOrder(
                                            ::buffa::alloc::boxed::Box::new(
                                                v.to_owned_from_source(__buffa_src)?,
                                            ),
                                        )
                                    }
                                    super::super::__buffa::view::oneof::client_frame::Payload::ModifyOrder(
                                        v,
                                    ) => {
                                        super::super::__buffa::oneof::client_frame::Payload::ModifyOrder(
                                            ::buffa::alloc::boxed::Box::new(
                                                v.to_owned_from_source(__buffa_src)?,
                                            ),
                                        )
                                    }
                                    super::super::__buffa::view::oneof::client_frame::Payload::CancelAllOrders(
                                        v,
                                    ) => {
                                        super::super::__buffa::oneof::client_frame::Payload::CancelAllOrders(
                                            ::buffa::alloc::boxed::Box::new(
                                                v.to_owned_from_source(__buffa_src)?,
                                            ),
                                        )
                                    }
                                },
                            )
                        }
                        ::core::option::Option::None => ::core::option::Option::None,
                    },
                    __buffa_unknown_fields: self
                        .__buffa_unknown_fields
                        .to_owned()?
                        .into(),
                    ..::core::default::Default::default()
                })
            }
        }
        impl<'a> ::buffa::ViewEncode<'a> for ClientFrameView<'a> {
            #[allow(clippy::needless_borrow, clippy::let_and_return)]
            fn compute_size(&self, __cache: &mut ::buffa::SizeCache) -> u32 {
                #[allow(unused_imports)]
                use ::buffa::Enumeration as _;
                let mut size = 0u32;
                if self.seq != 0u64 {
                    size += 1u32 + ::buffa::types::uint64_encoded_len(self.seq) as u32;
                }
                if !self.correlation_id.is_empty() {
                    size
                        += 1u32
                            + ::buffa::types::string_encoded_len(&self.correlation_id)
                                as u32;
                }
                if let ::core::option::Option::Some(ref v) = self.payload {
                    match v {
                        super::super::__buffa::view::oneof::client_frame::Payload::Ping(
                            x,
                        ) => {
                            let __slot = __cache.reserve();
                            let inner = x.compute_size(__cache);
                            __cache.set(__slot, inner);
                            size
                                += 1u32 + ::buffa::encoding::varint_len(inner as u64) as u32
                                    + inner;
                        }
                        super::super::__buffa::view::oneof::client_frame::Payload::CreateOrder(
                            x,
                        ) => {
                            let __slot = __cache.reserve();
                            let inner = x.compute_size(__cache);
                            __cache.set(__slot, inner);
                            size
                                += 1u32 + ::buffa::encoding::varint_len(inner as u64) as u32
                                    + inner;
                        }
                        super::super::__buffa::view::oneof::client_frame::Payload::CancelOrder(
                            x,
                        ) => {
                            let __slot = __cache.reserve();
                            let inner = x.compute_size(__cache);
                            __cache.set(__slot, inner);
                            size
                                += 1u32 + ::buffa::encoding::varint_len(inner as u64) as u32
                                    + inner;
                        }
                        super::super::__buffa::view::oneof::client_frame::Payload::ModifyOrder(
                            x,
                        ) => {
                            let __slot = __cache.reserve();
                            let inner = x.compute_size(__cache);
                            __cache.set(__slot, inner);
                            size
                                += 1u32 + ::buffa::encoding::varint_len(inner as u64) as u32
                                    + inner;
                        }
                        super::super::__buffa::view::oneof::client_frame::Payload::CancelAllOrders(
                            x,
                        ) => {
                            let __slot = __cache.reserve();
                            let inner = x.compute_size(__cache);
                            __cache.set(__slot, inner);
                            size
                                += 1u32 + ::buffa::encoding::varint_len(inner as u64) as u32
                                    + inner;
                        }
                    }
                }
                size += self.__buffa_unknown_fields.encoded_len() as u32;
                size
            }
            #[allow(clippy::needless_borrow)]
            fn write_to(
                &self,
                __cache: &mut ::buffa::SizeCache,
                buf: &mut impl ::buffa::bytes::BufMut,
            ) {
                #[allow(unused_imports)]
                use ::buffa::Enumeration as _;
                if self.seq != 0u64 {
                    ::buffa::types::put_uint64_field(1u32, self.seq, buf);
                }
                if !self.correlation_id.is_empty() {
                    ::buffa::types::put_string_field(2u32, &self.correlation_id, buf);
                }
                if let ::core::option::Option::Some(ref v) = self.payload {
                    match v {
                        super::super::__buffa::view::oneof::client_frame::Payload::Ping(
                            x,
                        ) => {
                            ::buffa::types::put_len_delimited_header(
                                10u32,
                                __cache.consume_next(),
                                buf,
                            );
                            x.write_to(__cache, buf);
                        }
                        super::super::__buffa::view::oneof::client_frame::Payload::CreateOrder(
                            x,
                        ) => {
                            ::buffa::types::put_len_delimited_header(
                                11u32,
                                __cache.consume_next(),
                                buf,
                            );
                            x.write_to(__cache, buf);
                        }
                        super::super::__buffa::view::oneof::client_frame::Payload::CancelOrder(
                            x,
                        ) => {
                            ::buffa::types::put_len_delimited_header(
                                12u32,
                                __cache.consume_next(),
                                buf,
                            );
                            x.write_to(__cache, buf);
                        }
                        super::super::__buffa::view::oneof::client_frame::Payload::ModifyOrder(
                            x,
                        ) => {
                            ::buffa::types::put_len_delimited_header(
                                13u32,
                                __cache.consume_next(),
                                buf,
                            );
                            x.write_to(__cache, buf);
                        }
                        super::super::__buffa::view::oneof::client_frame::Payload::CancelAllOrders(
                            x,
                        ) => {
                            ::buffa::types::put_len_delimited_header(
                                14u32,
                                __cache.consume_next(),
                                buf,
                            );
                            x.write_to(__cache, buf);
                        }
                    }
                }
                self.__buffa_unknown_fields.write_to(buf);
            }
        }
        /// Serializes this view as protobuf JSON.
        ///
        /// Implicit-presence fields with default values are omitted, `required`
        /// fields are always emitted, explicit-presence (`optional`) fields are
        /// emitted only when set, bytes fields are base64-encoded, and enum
        /// values are their proto name strings.
        ///
        /// This impl uses `serialize_map(None)` because the number of emitted
        /// fields depends on default-omission rules; serializers that require
        /// known map lengths (e.g. `bincode`) will return a runtime error.
        /// Use the owned message type for those formats.
        impl<'__a> ::serde::Serialize for ClientFrameView<'__a> {
            fn serialize<__S: ::serde::Serializer>(
                &self,
                __s: __S,
            ) -> ::core::result::Result<__S::Ok, __S::Error> {
                use ::serde::ser::SerializeMap as _;
                let mut __map = __s.serialize_map(::core::option::Option::None)?;
                if !::buffa::json_helpers::skip_if::is_zero_u64(&self.seq) {
                    __map
                        .serialize_entry(
                            "seq",
                            &::buffa::json_helpers::ProtoJson(&self.seq),
                        )?;
                }
                if !::buffa::json_helpers::skip_if::is_empty_str(self.correlation_id) {
                    __map.serialize_entry("correlationId", self.correlation_id)?;
                }
                if let ::core::option::Option::Some(ref __ov) = self.payload {
                    match __ov {
                        super::super::__buffa::view::oneof::client_frame::Payload::Ping(
                            v,
                        ) => {
                            __map.serialize_entry("ping", v)?;
                        }
                        super::super::__buffa::view::oneof::client_frame::Payload::CreateOrder(
                            v,
                        ) => {
                            __map.serialize_entry("createOrder", v)?;
                        }
                        super::super::__buffa::view::oneof::client_frame::Payload::CancelOrder(
                            v,
                        ) => {
                            __map.serialize_entry("cancelOrder", v)?;
                        }
                        super::super::__buffa::view::oneof::client_frame::Payload::ModifyOrder(
                            v,
                        ) => {
                            __map.serialize_entry("modifyOrder", v)?;
                        }
                        super::super::__buffa::view::oneof::client_frame::Payload::CancelAllOrders(
                            v,
                        ) => {
                            __map.serialize_entry("cancelAllOrders", v)?;
                        }
                    }
                }
                __map.end()
            }
        }
        impl<'a> ::buffa::MessageName for ClientFrameView<'a> {
            const PACKAGE: &'static str = "tradews.v1";
            const NAME: &'static str = "ClientFrame";
            const FULL_NAME: &'static str = "tradews.v1.ClientFrame";
            const TYPE_URL: &'static str = "type.googleapis.com/tradews.v1.ClientFrame";
        }
        ::buffa::impl_default_view_instance!(ClientFrameView);
        ::buffa::impl_view_reborrow!(ClientFrameView);
        /** Self-contained, `'static` owned view of a `ClientFrame` message.

 Wraps [`::buffa::OwnedView`]`<`[`ClientFrameView`]`<'static>>`: the decoded view and the [`::buffa::bytes::Bytes`] buffer it borrows from travel together, so the handle is `'static` and `Send + Sync` — suitable for async handlers, spawned tasks, and anywhere a `'static` bound is required.

 Field accessors return borrows tied to `&self`. Use [`Self::view`] to get the full [`ClientFrameView`] when you need struct patterns, iteration helpers, or to pass the view to lifetime-parameterised code.*/
        #[derive(Clone, Debug)]
        pub struct ClientFrameOwnedView(::buffa::OwnedView<ClientFrameView<'static>>);
        impl ClientFrameOwnedView {
            /// Decode an owned view from a [`::buffa::bytes::Bytes`] buffer.
            ///
            /// The view borrows directly from the buffer's data; the buffer is
            /// retained inside the returned handle.
            ///
            /// # Errors
            ///
            /// Returns [`::buffa::DecodeError`] if the buffer contains invalid
            /// protobuf data.
            pub fn decode(
                bytes: ::buffa::bytes::Bytes,
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                ::core::result::Result::Ok(
                    ClientFrameOwnedView(::buffa::OwnedView::decode(bytes)?),
                )
            }
            /// Decode with custom [`::buffa::DecodeOptions`] (recursion limit,
            /// max message size).
            ///
            /// # Errors
            ///
            /// Returns [`::buffa::DecodeError`] if the buffer is invalid or
            /// exceeds the configured limits.
            pub fn decode_with_options(
                bytes: ::buffa::bytes::Bytes,
                opts: &::buffa::DecodeOptions,
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                ::core::result::Result::Ok(
                    ClientFrameOwnedView(
                        ::buffa::OwnedView::decode_with_options(bytes, opts)?,
                    ),
                )
            }
            /// Build from an owned message via an encode → decode round-trip.
            ///
            /// # Errors
            ///
            /// Returns [`::buffa::DecodeError`] if the re-encoded bytes are
            /// somehow invalid (should not happen for well-formed messages).
            pub fn from_owned(
                msg: &super::super::ClientFrame,
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                ::core::result::Result::Ok(
                    ClientFrameOwnedView(::buffa::OwnedView::from_owned(msg)?),
                )
            }
            /// Borrow the full [`ClientFrameView`] with its lifetime tied to `&self`.
            #[must_use]
            pub fn view(&self) -> &ClientFrameView<'_> {
                self.0.reborrow()
            }
            /// Convert to the owned message type.
            ///
            /// # Errors
            ///
            /// Returns an error if re-materializing preserved unknown fields
            /// fails (e.g. the unknown-field limit is exceeded).
            pub fn to_owned_message(
                &self,
            ) -> ::core::result::Result<
                super::super::ClientFrame,
                ::buffa::DecodeError,
            > {
                self.0.to_owned_message()
            }
            /// The underlying bytes buffer.
            #[must_use]
            pub fn bytes(&self) -> &::buffa::bytes::Bytes {
                self.0.bytes()
            }
            /// Consume the handle, returning the underlying bytes buffer.
            #[must_use]
            pub fn into_bytes(self) -> ::buffa::bytes::Bytes {
                self.0.into_bytes()
            }
            /// Monotonic per-connection client sequence number, starting at 1.
            ///
            /// Field 1: `seq`
            #[must_use]
            pub fn seq(&self) -> u64 {
                self.0.reborrow().seq
            }
            /// Client correlation token echoed in every server response.
            ///
            /// Field 2: `correlation_id`
            #[must_use]
            pub fn correlation_id(&self) -> &'_ str {
                self.0.reborrow().correlation_id
            }
            /// Oneof `payload`.
            #[must_use]
            pub fn payload(
                &self,
            ) -> ::core::option::Option<
                &super::super::__buffa::view::oneof::client_frame::Payload<'_>,
            > {
                self.0.reborrow().payload.as_ref()
            }
        }
        impl ::core::convert::From<::buffa::OwnedView<ClientFrameView<'static>>>
        for ClientFrameOwnedView {
            fn from(inner: ::buffa::OwnedView<ClientFrameView<'static>>) -> Self {
                ClientFrameOwnedView(inner)
            }
        }
        impl ::core::convert::From<ClientFrameOwnedView>
        for ::buffa::OwnedView<ClientFrameView<'static>> {
            fn from(wrapper: ClientFrameOwnedView) -> Self {
                wrapper.0
            }
        }
        impl ::core::convert::AsRef<::buffa::OwnedView<ClientFrameView<'static>>>
        for ClientFrameOwnedView {
            fn as_ref(&self) -> &::buffa::OwnedView<ClientFrameView<'static>> {
                &self.0
            }
        }
        impl ::buffa::HasMessageView for super::super::ClientFrame {
            type View<'a> = ClientFrameView<'a>;
            type ViewHandle = ClientFrameOwnedView;
        }
        impl ::serde::Serialize for ClientFrameOwnedView {
            fn serialize<__S: ::serde::Serializer>(
                &self,
                __s: __S,
            ) -> ::core::result::Result<__S::Ok, __S::Error> {
                ::serde::Serialize::serialize(&self.0, __s)
            }
        }
        /// PingRequest carries an opaque payload that is echoed by PongResponse.
        #[derive(Clone, Debug, Default)]
        pub struct PingRequestView<'a> {
            /// Opaque client payload echoed by the server.
            ///
            /// Field 1: `payload`
            pub payload: &'a [u8],
            pub __buffa_unknown_fields: ::buffa::UnknownFieldsView<'a>,
        }
        impl<'a> ::buffa::MessageView<'a> for PingRequestView<'a> {
            type Owned = super::super::PingRequest;
            fn decode_view(
                buf: &'a [u8],
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                let __limit = ::core::cell::Cell::new(
                    ::buffa::DEFAULT_UNKNOWN_FIELD_LIMIT,
                );
                <Self as ::buffa::MessageView>::decode_view_ctx(
                    buf,
                    ::buffa::DecodeContext::new(::buffa::RECURSION_LIMIT, &__limit),
                )
            }
            fn decode_view_with_ctx(
                buf: &'a [u8],
                ctx: ::buffa::DecodeContext<'_>,
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                <Self as ::buffa::MessageView>::decode_view_ctx(buf, ctx)
            }
            fn merge_view_field(
                &mut self,
                tag: ::buffa::encoding::Tag,
                cur: &'a [u8],
                before_tag: &'a [u8],
                ctx: ::buffa::DecodeContext<'_>,
            ) -> ::core::result::Result<&'a [u8], ::buffa::DecodeError> {
                let _ = ctx;
                #[allow(unused_variables)]
                let view = self;
                let mut cur = cur;
                match tag.field_number() {
                    1u32 => {
                        ::buffa::encoding::check_wire_type(
                            tag,
                            ::buffa::encoding::WireType::LengthDelimited,
                        )?;
                        view.payload = ::buffa::types::borrow_bytes(&mut cur)?;
                    }
                    _ => {
                        ::buffa::encoding::skip_field_depth(tag, &mut cur, ctx.depth())?;
                        let span_len = before_tag.len() - cur.len();
                        view.__buffa_unknown_fields
                            .push_record(before_tag, span_len, ctx)?;
                    }
                }
                ::core::result::Result::Ok(cur)
            }
            fn to_owned_message(
                &self,
            ) -> ::core::result::Result<
                super::super::PingRequest,
                ::buffa::DecodeError,
            > {
                self.to_owned_from_source(None)
            }
            #[allow(clippy::useless_conversion, clippy::needless_update)]
            fn to_owned_from_source(
                &self,
                __buffa_src: ::core::option::Option<&::buffa::bytes::Bytes>,
            ) -> ::core::result::Result<
                super::super::PingRequest,
                ::buffa::DecodeError,
            > {
                #[allow(unused_imports)]
                use ::buffa::alloc::string::ToString as _;
                let _ = __buffa_src;
                ::core::result::Result::Ok(super::super::PingRequest {
                    payload: (self.payload).to_vec(),
                    __buffa_unknown_fields: self
                        .__buffa_unknown_fields
                        .to_owned()?
                        .into(),
                    ..::core::default::Default::default()
                })
            }
        }
        impl<'a> ::buffa::ViewEncode<'a> for PingRequestView<'a> {
            #[allow(clippy::needless_borrow, clippy::let_and_return)]
            fn compute_size(&self, _cache: &mut ::buffa::SizeCache) -> u32 {
                #[allow(unused_imports)]
                use ::buffa::Enumeration as _;
                let mut size = 0u32;
                if !self.payload.is_empty() {
                    size
                        += 1u32
                            + ::buffa::types::bytes_encoded_len(&self.payload) as u32;
                }
                size += self.__buffa_unknown_fields.encoded_len() as u32;
                size
            }
            #[allow(clippy::needless_borrow)]
            fn write_to(
                &self,
                _cache: &mut ::buffa::SizeCache,
                buf: &mut impl ::buffa::bytes::BufMut,
            ) {
                #[allow(unused_imports)]
                use ::buffa::Enumeration as _;
                if !self.payload.is_empty() {
                    ::buffa::types::put_bytes_field(1u32, &self.payload, buf);
                }
                self.__buffa_unknown_fields.write_to(buf);
            }
        }
        /// Serializes this view as protobuf JSON.
        ///
        /// Implicit-presence fields with default values are omitted, `required`
        /// fields are always emitted, explicit-presence (`optional`) fields are
        /// emitted only when set, bytes fields are base64-encoded, and enum
        /// values are their proto name strings.
        ///
        /// This impl uses `serialize_map(None)` because the number of emitted
        /// fields depends on default-omission rules; serializers that require
        /// known map lengths (e.g. `bincode`) will return a runtime error.
        /// Use the owned message type for those formats.
        impl<'__a> ::serde::Serialize for PingRequestView<'__a> {
            fn serialize<__S: ::serde::Serializer>(
                &self,
                __s: __S,
            ) -> ::core::result::Result<__S::Ok, __S::Error> {
                use ::serde::ser::SerializeMap as _;
                let mut __map = __s.serialize_map(::core::option::Option::None)?;
                if !::buffa::json_helpers::skip_if::is_empty_bytes(self.payload) {
                    __map
                        .serialize_entry(
                            "payload",
                            &::buffa::json_helpers::BytesJson(self.payload),
                        )?;
                }
                __map.end()
            }
        }
        impl<'a> ::buffa::MessageName for PingRequestView<'a> {
            const PACKAGE: &'static str = "tradews.v1";
            const NAME: &'static str = "PingRequest";
            const FULL_NAME: &'static str = "tradews.v1.PingRequest";
            const TYPE_URL: &'static str = "type.googleapis.com/tradews.v1.PingRequest";
        }
        ::buffa::impl_default_view_instance!(PingRequestView);
        ::buffa::impl_view_reborrow!(PingRequestView);
        /** Self-contained, `'static` owned view of a `PingRequest` message.

 Wraps [`::buffa::OwnedView`]`<`[`PingRequestView`]`<'static>>`: the decoded view and the [`::buffa::bytes::Bytes`] buffer it borrows from travel together, so the handle is `'static` and `Send + Sync` — suitable for async handlers, spawned tasks, and anywhere a `'static` bound is required.

 Field accessors return borrows tied to `&self`. Use [`Self::view`] to get the full [`PingRequestView`] when you need struct patterns, iteration helpers, or to pass the view to lifetime-parameterised code.*/
        #[derive(Clone, Debug)]
        pub struct PingRequestOwnedView(::buffa::OwnedView<PingRequestView<'static>>);
        impl PingRequestOwnedView {
            /// Decode an owned view from a [`::buffa::bytes::Bytes`] buffer.
            ///
            /// The view borrows directly from the buffer's data; the buffer is
            /// retained inside the returned handle.
            ///
            /// # Errors
            ///
            /// Returns [`::buffa::DecodeError`] if the buffer contains invalid
            /// protobuf data.
            pub fn decode(
                bytes: ::buffa::bytes::Bytes,
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                ::core::result::Result::Ok(
                    PingRequestOwnedView(::buffa::OwnedView::decode(bytes)?),
                )
            }
            /// Decode with custom [`::buffa::DecodeOptions`] (recursion limit,
            /// max message size).
            ///
            /// # Errors
            ///
            /// Returns [`::buffa::DecodeError`] if the buffer is invalid or
            /// exceeds the configured limits.
            pub fn decode_with_options(
                bytes: ::buffa::bytes::Bytes,
                opts: &::buffa::DecodeOptions,
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                ::core::result::Result::Ok(
                    PingRequestOwnedView(
                        ::buffa::OwnedView::decode_with_options(bytes, opts)?,
                    ),
                )
            }
            /// Build from an owned message via an encode → decode round-trip.
            ///
            /// # Errors
            ///
            /// Returns [`::buffa::DecodeError`] if the re-encoded bytes are
            /// somehow invalid (should not happen for well-formed messages).
            pub fn from_owned(
                msg: &super::super::PingRequest,
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                ::core::result::Result::Ok(
                    PingRequestOwnedView(::buffa::OwnedView::from_owned(msg)?),
                )
            }
            /// Borrow the full [`PingRequestView`] with its lifetime tied to `&self`.
            #[must_use]
            pub fn view(&self) -> &PingRequestView<'_> {
                self.0.reborrow()
            }
            /// Convert to the owned message type.
            ///
            /// # Errors
            ///
            /// Returns an error if re-materializing preserved unknown fields
            /// fails (e.g. the unknown-field limit is exceeded).
            pub fn to_owned_message(
                &self,
            ) -> ::core::result::Result<
                super::super::PingRequest,
                ::buffa::DecodeError,
            > {
                self.0.to_owned_message()
            }
            /// The underlying bytes buffer.
            #[must_use]
            pub fn bytes(&self) -> &::buffa::bytes::Bytes {
                self.0.bytes()
            }
            /// Consume the handle, returning the underlying bytes buffer.
            #[must_use]
            pub fn into_bytes(self) -> ::buffa::bytes::Bytes {
                self.0.into_bytes()
            }
            /// Opaque client payload echoed by the server.
            ///
            /// Field 1: `payload`
            #[must_use]
            pub fn payload(&self) -> &'_ [u8] {
                self.0.reborrow().payload
            }
        }
        impl ::core::convert::From<::buffa::OwnedView<PingRequestView<'static>>>
        for PingRequestOwnedView {
            fn from(inner: ::buffa::OwnedView<PingRequestView<'static>>) -> Self {
                PingRequestOwnedView(inner)
            }
        }
        impl ::core::convert::From<PingRequestOwnedView>
        for ::buffa::OwnedView<PingRequestView<'static>> {
            fn from(wrapper: PingRequestOwnedView) -> Self {
                wrapper.0
            }
        }
        impl ::core::convert::AsRef<::buffa::OwnedView<PingRequestView<'static>>>
        for PingRequestOwnedView {
            fn as_ref(&self) -> &::buffa::OwnedView<PingRequestView<'static>> {
                &self.0
            }
        }
        impl ::buffa::HasMessageView for super::super::PingRequest {
            type View<'a> = PingRequestView<'a>;
            type ViewHandle = PingRequestOwnedView;
        }
        impl ::serde::Serialize for PingRequestOwnedView {
            fn serialize<__S: ::serde::Serializer>(
                &self,
                __s: __S,
            ) -> ::core::result::Result<__S::Ok, __S::Error> {
                ::serde::Serialize::serialize(&self.0, __s)
            }
        }
        /// ServerFrame is the protobuf write-websocket response envelope.
        #[derive(Clone, Debug, Default)]
        pub struct ServerFrameView<'a> {
            /// Client sequence number copied from the accepted or rejected frame.
            ///
            /// Field 1: `seq`
            pub seq: u64,
            /// Client correlation token copied from the accepted or rejected frame.
            ///
            /// Field 2: `correlation_id`
            pub correlation_id: &'a str,
            pub payload: ::core::option::Option<
                super::super::__buffa::view::oneof::server_frame::Payload<'a>,
            >,
            pub __buffa_unknown_fields: ::buffa::UnknownFieldsView<'a>,
        }
        impl<'a> ::buffa::MessageView<'a> for ServerFrameView<'a> {
            type Owned = super::super::ServerFrame;
            fn decode_view(
                buf: &'a [u8],
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                let __limit = ::core::cell::Cell::new(
                    ::buffa::DEFAULT_UNKNOWN_FIELD_LIMIT,
                );
                <Self as ::buffa::MessageView>::decode_view_ctx(
                    buf,
                    ::buffa::DecodeContext::new(::buffa::RECURSION_LIMIT, &__limit),
                )
            }
            fn decode_view_with_ctx(
                buf: &'a [u8],
                ctx: ::buffa::DecodeContext<'_>,
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                <Self as ::buffa::MessageView>::decode_view_ctx(buf, ctx)
            }
            fn merge_view_field(
                &mut self,
                tag: ::buffa::encoding::Tag,
                cur: &'a [u8],
                before_tag: &'a [u8],
                ctx: ::buffa::DecodeContext<'_>,
            ) -> ::core::result::Result<&'a [u8], ::buffa::DecodeError> {
                let _ = ctx;
                #[allow(unused_variables)]
                let view = self;
                let mut cur = cur;
                match tag.field_number() {
                    1u32 => {
                        ::buffa::encoding::check_wire_type(
                            tag,
                            ::buffa::encoding::WireType::Varint,
                        )?;
                        view.seq = ::buffa::types::decode_uint64(&mut cur)?;
                    }
                    2u32 => {
                        ::buffa::encoding::check_wire_type(
                            tag,
                            ::buffa::encoding::WireType::LengthDelimited,
                        )?;
                        view.correlation_id = ::buffa::types::borrow_str(&mut cur)?;
                    }
                    10u32 => {
                        ::buffa::encoding::check_wire_type(
                            tag,
                            ::buffa::encoding::WireType::LengthDelimited,
                        )?;
                        let __sub_ctx = ctx.descend()?;
                        let sub = ::buffa::types::borrow_bytes(&mut cur)?;
                        if let Some(
                            super::super::__buffa::view::oneof::server_frame::Payload::Pong(
                                ref mut existing,
                            ),
                        ) = view.payload
                        {
                            ::buffa::MessageView::merge_into_view(
                                &mut **existing,
                                sub,
                                __sub_ctx,
                            )?;
                        } else {
                            view.payload = Some(
                                super::super::__buffa::view::oneof::server_frame::Payload::Pong(
                                    ::buffa::alloc::boxed::Box::new(
                                        <super::super::__buffa::view::PongResponseView as ::buffa::MessageView>::decode_view_ctx(
                                            sub,
                                            __sub_ctx,
                                        )?,
                                    ),
                                ),
                            );
                        }
                    }
                    11u32 => {
                        ::buffa::encoding::check_wire_type(
                            tag,
                            ::buffa::encoding::WireType::LengthDelimited,
                        )?;
                        let __sub_ctx = ctx.descend()?;
                        let sub = ::buffa::types::borrow_bytes(&mut cur)?;
                        if let Some(
                            super::super::__buffa::view::oneof::server_frame::Payload::Ack(
                                ref mut existing,
                            ),
                        ) = view.payload
                        {
                            ::buffa::MessageView::merge_into_view(
                                &mut **existing,
                                sub,
                                __sub_ctx,
                            )?;
                        } else {
                            view.payload = Some(
                                super::super::__buffa::view::oneof::server_frame::Payload::Ack(
                                    ::buffa::alloc::boxed::Box::new(
                                        <super::super::__buffa::view::AckResponseView as ::buffa::MessageView>::decode_view_ctx(
                                            sub,
                                            __sub_ctx,
                                        )?,
                                    ),
                                ),
                            );
                        }
                    }
                    12u32 => {
                        ::buffa::encoding::check_wire_type(
                            tag,
                            ::buffa::encoding::WireType::LengthDelimited,
                        )?;
                        let __sub_ctx = ctx.descend()?;
                        let sub = ::buffa::types::borrow_bytes(&mut cur)?;
                        if let Some(
                            super::super::__buffa::view::oneof::server_frame::Payload::Reject(
                                ref mut existing,
                            ),
                        ) = view.payload
                        {
                            ::buffa::MessageView::merge_into_view(
                                &mut **existing,
                                sub,
                                __sub_ctx,
                            )?;
                        } else {
                            view.payload = Some(
                                super::super::__buffa::view::oneof::server_frame::Payload::Reject(
                                    ::buffa::alloc::boxed::Box::new(
                                        <super::super::__buffa::view::CommandRejectView as ::buffa::MessageView>::decode_view_ctx(
                                            sub,
                                            __sub_ctx,
                                        )?,
                                    ),
                                ),
                            );
                        }
                    }
                    13u32 => {
                        ::buffa::encoding::check_wire_type(
                            tag,
                            ::buffa::encoding::WireType::LengthDelimited,
                        )?;
                        let __sub_ctx = ctx.descend()?;
                        let sub = ::buffa::types::borrow_bytes(&mut cur)?;
                        if let Some(
                            super::super::__buffa::view::oneof::server_frame::Payload::Overload(
                                ref mut existing,
                            ),
                        ) = view.payload
                        {
                            ::buffa::MessageView::merge_into_view(
                                &mut **existing,
                                sub,
                                __sub_ctx,
                            )?;
                        } else {
                            view.payload = Some(
                                super::super::__buffa::view::oneof::server_frame::Payload::Overload(
                                    ::buffa::alloc::boxed::Box::new(
                                        <super::super::__buffa::view::OverloadResponseView as ::buffa::MessageView>::decode_view_ctx(
                                            sub,
                                            __sub_ctx,
                                        )?,
                                    ),
                                ),
                            );
                        }
                    }
                    14u32 => {
                        ::buffa::encoding::check_wire_type(
                            tag,
                            ::buffa::encoding::WireType::LengthDelimited,
                        )?;
                        let __sub_ctx = ctx.descend()?;
                        let sub = ::buffa::types::borrow_bytes(&mut cur)?;
                        if let Some(
                            super::super::__buffa::view::oneof::server_frame::Payload::Terminal(
                                ref mut existing,
                            ),
                        ) = view.payload
                        {
                            ::buffa::MessageView::merge_into_view(
                                &mut **existing,
                                sub,
                                __sub_ctx,
                            )?;
                        } else {
                            view.payload = Some(
                                super::super::__buffa::view::oneof::server_frame::Payload::Terminal(
                                    ::buffa::alloc::boxed::Box::new(
                                        <super::super::__buffa::view::TerminalSessionEventView as ::buffa::MessageView>::decode_view_ctx(
                                            sub,
                                            __sub_ctx,
                                        )?,
                                    ),
                                ),
                            );
                        }
                    }
                    _ => {
                        ::buffa::encoding::skip_field_depth(tag, &mut cur, ctx.depth())?;
                        let span_len = before_tag.len() - cur.len();
                        view.__buffa_unknown_fields
                            .push_record(before_tag, span_len, ctx)?;
                    }
                }
                ::core::result::Result::Ok(cur)
            }
            fn to_owned_message(
                &self,
            ) -> ::core::result::Result<
                super::super::ServerFrame,
                ::buffa::DecodeError,
            > {
                self.to_owned_from_source(None)
            }
            #[allow(clippy::useless_conversion, clippy::needless_update)]
            fn to_owned_from_source(
                &self,
                __buffa_src: ::core::option::Option<&::buffa::bytes::Bytes>,
            ) -> ::core::result::Result<
                super::super::ServerFrame,
                ::buffa::DecodeError,
            > {
                #[allow(unused_imports)]
                use ::buffa::alloc::string::ToString as _;
                let _ = __buffa_src;
                ::core::result::Result::Ok(super::super::ServerFrame {
                    seq: self.seq,
                    correlation_id: self.correlation_id.to_string(),
                    payload: match self.payload.as_ref() {
                        ::core::option::Option::Some(v) => {
                            ::core::option::Option::Some(
                                match v {
                                    super::super::__buffa::view::oneof::server_frame::Payload::Pong(
                                        v,
                                    ) => {
                                        super::super::__buffa::oneof::server_frame::Payload::Pong(
                                            ::buffa::alloc::boxed::Box::new(
                                                v.to_owned_from_source(__buffa_src)?,
                                            ),
                                        )
                                    }
                                    super::super::__buffa::view::oneof::server_frame::Payload::Ack(
                                        v,
                                    ) => {
                                        super::super::__buffa::oneof::server_frame::Payload::Ack(
                                            ::buffa::alloc::boxed::Box::new(
                                                v.to_owned_from_source(__buffa_src)?,
                                            ),
                                        )
                                    }
                                    super::super::__buffa::view::oneof::server_frame::Payload::Reject(
                                        v,
                                    ) => {
                                        super::super::__buffa::oneof::server_frame::Payload::Reject(
                                            ::buffa::alloc::boxed::Box::new(
                                                v.to_owned_from_source(__buffa_src)?,
                                            ),
                                        )
                                    }
                                    super::super::__buffa::view::oneof::server_frame::Payload::Overload(
                                        v,
                                    ) => {
                                        super::super::__buffa::oneof::server_frame::Payload::Overload(
                                            ::buffa::alloc::boxed::Box::new(
                                                v.to_owned_from_source(__buffa_src)?,
                                            ),
                                        )
                                    }
                                    super::super::__buffa::view::oneof::server_frame::Payload::Terminal(
                                        v,
                                    ) => {
                                        super::super::__buffa::oneof::server_frame::Payload::Terminal(
                                            ::buffa::alloc::boxed::Box::new(
                                                v.to_owned_from_source(__buffa_src)?,
                                            ),
                                        )
                                    }
                                },
                            )
                        }
                        ::core::option::Option::None => ::core::option::Option::None,
                    },
                    __buffa_unknown_fields: self
                        .__buffa_unknown_fields
                        .to_owned()?
                        .into(),
                    ..::core::default::Default::default()
                })
            }
        }
        impl<'a> ::buffa::ViewEncode<'a> for ServerFrameView<'a> {
            #[allow(clippy::needless_borrow, clippy::let_and_return)]
            fn compute_size(&self, __cache: &mut ::buffa::SizeCache) -> u32 {
                #[allow(unused_imports)]
                use ::buffa::Enumeration as _;
                let mut size = 0u32;
                if self.seq != 0u64 {
                    size += 1u32 + ::buffa::types::uint64_encoded_len(self.seq) as u32;
                }
                if !self.correlation_id.is_empty() {
                    size
                        += 1u32
                            + ::buffa::types::string_encoded_len(&self.correlation_id)
                                as u32;
                }
                if let ::core::option::Option::Some(ref v) = self.payload {
                    match v {
                        super::super::__buffa::view::oneof::server_frame::Payload::Pong(
                            x,
                        ) => {
                            let __slot = __cache.reserve();
                            let inner = x.compute_size(__cache);
                            __cache.set(__slot, inner);
                            size
                                += 1u32 + ::buffa::encoding::varint_len(inner as u64) as u32
                                    + inner;
                        }
                        super::super::__buffa::view::oneof::server_frame::Payload::Ack(
                            x,
                        ) => {
                            let __slot = __cache.reserve();
                            let inner = x.compute_size(__cache);
                            __cache.set(__slot, inner);
                            size
                                += 1u32 + ::buffa::encoding::varint_len(inner as u64) as u32
                                    + inner;
                        }
                        super::super::__buffa::view::oneof::server_frame::Payload::Reject(
                            x,
                        ) => {
                            let __slot = __cache.reserve();
                            let inner = x.compute_size(__cache);
                            __cache.set(__slot, inner);
                            size
                                += 1u32 + ::buffa::encoding::varint_len(inner as u64) as u32
                                    + inner;
                        }
                        super::super::__buffa::view::oneof::server_frame::Payload::Overload(
                            x,
                        ) => {
                            let __slot = __cache.reserve();
                            let inner = x.compute_size(__cache);
                            __cache.set(__slot, inner);
                            size
                                += 1u32 + ::buffa::encoding::varint_len(inner as u64) as u32
                                    + inner;
                        }
                        super::super::__buffa::view::oneof::server_frame::Payload::Terminal(
                            x,
                        ) => {
                            let __slot = __cache.reserve();
                            let inner = x.compute_size(__cache);
                            __cache.set(__slot, inner);
                            size
                                += 1u32 + ::buffa::encoding::varint_len(inner as u64) as u32
                                    + inner;
                        }
                    }
                }
                size += self.__buffa_unknown_fields.encoded_len() as u32;
                size
            }
            #[allow(clippy::needless_borrow)]
            fn write_to(
                &self,
                __cache: &mut ::buffa::SizeCache,
                buf: &mut impl ::buffa::bytes::BufMut,
            ) {
                #[allow(unused_imports)]
                use ::buffa::Enumeration as _;
                if self.seq != 0u64 {
                    ::buffa::types::put_uint64_field(1u32, self.seq, buf);
                }
                if !self.correlation_id.is_empty() {
                    ::buffa::types::put_string_field(2u32, &self.correlation_id, buf);
                }
                if let ::core::option::Option::Some(ref v) = self.payload {
                    match v {
                        super::super::__buffa::view::oneof::server_frame::Payload::Pong(
                            x,
                        ) => {
                            ::buffa::types::put_len_delimited_header(
                                10u32,
                                __cache.consume_next(),
                                buf,
                            );
                            x.write_to(__cache, buf);
                        }
                        super::super::__buffa::view::oneof::server_frame::Payload::Ack(
                            x,
                        ) => {
                            ::buffa::types::put_len_delimited_header(
                                11u32,
                                __cache.consume_next(),
                                buf,
                            );
                            x.write_to(__cache, buf);
                        }
                        super::super::__buffa::view::oneof::server_frame::Payload::Reject(
                            x,
                        ) => {
                            ::buffa::types::put_len_delimited_header(
                                12u32,
                                __cache.consume_next(),
                                buf,
                            );
                            x.write_to(__cache, buf);
                        }
                        super::super::__buffa::view::oneof::server_frame::Payload::Overload(
                            x,
                        ) => {
                            ::buffa::types::put_len_delimited_header(
                                13u32,
                                __cache.consume_next(),
                                buf,
                            );
                            x.write_to(__cache, buf);
                        }
                        super::super::__buffa::view::oneof::server_frame::Payload::Terminal(
                            x,
                        ) => {
                            ::buffa::types::put_len_delimited_header(
                                14u32,
                                __cache.consume_next(),
                                buf,
                            );
                            x.write_to(__cache, buf);
                        }
                    }
                }
                self.__buffa_unknown_fields.write_to(buf);
            }
        }
        /// Serializes this view as protobuf JSON.
        ///
        /// Implicit-presence fields with default values are omitted, `required`
        /// fields are always emitted, explicit-presence (`optional`) fields are
        /// emitted only when set, bytes fields are base64-encoded, and enum
        /// values are their proto name strings.
        ///
        /// This impl uses `serialize_map(None)` because the number of emitted
        /// fields depends on default-omission rules; serializers that require
        /// known map lengths (e.g. `bincode`) will return a runtime error.
        /// Use the owned message type for those formats.
        impl<'__a> ::serde::Serialize for ServerFrameView<'__a> {
            fn serialize<__S: ::serde::Serializer>(
                &self,
                __s: __S,
            ) -> ::core::result::Result<__S::Ok, __S::Error> {
                use ::serde::ser::SerializeMap as _;
                let mut __map = __s.serialize_map(::core::option::Option::None)?;
                if !::buffa::json_helpers::skip_if::is_zero_u64(&self.seq) {
                    __map
                        .serialize_entry(
                            "seq",
                            &::buffa::json_helpers::ProtoJson(&self.seq),
                        )?;
                }
                if !::buffa::json_helpers::skip_if::is_empty_str(self.correlation_id) {
                    __map.serialize_entry("correlationId", self.correlation_id)?;
                }
                if let ::core::option::Option::Some(ref __ov) = self.payload {
                    match __ov {
                        super::super::__buffa::view::oneof::server_frame::Payload::Pong(
                            v,
                        ) => {
                            __map.serialize_entry("pong", v)?;
                        }
                        super::super::__buffa::view::oneof::server_frame::Payload::Ack(
                            v,
                        ) => {
                            __map.serialize_entry("ack", v)?;
                        }
                        super::super::__buffa::view::oneof::server_frame::Payload::Reject(
                            v,
                        ) => {
                            __map.serialize_entry("reject", v)?;
                        }
                        super::super::__buffa::view::oneof::server_frame::Payload::Overload(
                            v,
                        ) => {
                            __map.serialize_entry("overload", v)?;
                        }
                        super::super::__buffa::view::oneof::server_frame::Payload::Terminal(
                            v,
                        ) => {
                            __map.serialize_entry("terminal", v)?;
                        }
                    }
                }
                __map.end()
            }
        }
        impl<'a> ::buffa::MessageName for ServerFrameView<'a> {
            const PACKAGE: &'static str = "tradews.v1";
            const NAME: &'static str = "ServerFrame";
            const FULL_NAME: &'static str = "tradews.v1.ServerFrame";
            const TYPE_URL: &'static str = "type.googleapis.com/tradews.v1.ServerFrame";
        }
        ::buffa::impl_default_view_instance!(ServerFrameView);
        ::buffa::impl_view_reborrow!(ServerFrameView);
        /** Self-contained, `'static` owned view of a `ServerFrame` message.

 Wraps [`::buffa::OwnedView`]`<`[`ServerFrameView`]`<'static>>`: the decoded view and the [`::buffa::bytes::Bytes`] buffer it borrows from travel together, so the handle is `'static` and `Send + Sync` — suitable for async handlers, spawned tasks, and anywhere a `'static` bound is required.

 Field accessors return borrows tied to `&self`. Use [`Self::view`] to get the full [`ServerFrameView`] when you need struct patterns, iteration helpers, or to pass the view to lifetime-parameterised code.*/
        #[derive(Clone, Debug)]
        pub struct ServerFrameOwnedView(::buffa::OwnedView<ServerFrameView<'static>>);
        impl ServerFrameOwnedView {
            /// Decode an owned view from a [`::buffa::bytes::Bytes`] buffer.
            ///
            /// The view borrows directly from the buffer's data; the buffer is
            /// retained inside the returned handle.
            ///
            /// # Errors
            ///
            /// Returns [`::buffa::DecodeError`] if the buffer contains invalid
            /// protobuf data.
            pub fn decode(
                bytes: ::buffa::bytes::Bytes,
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                ::core::result::Result::Ok(
                    ServerFrameOwnedView(::buffa::OwnedView::decode(bytes)?),
                )
            }
            /// Decode with custom [`::buffa::DecodeOptions`] (recursion limit,
            /// max message size).
            ///
            /// # Errors
            ///
            /// Returns [`::buffa::DecodeError`] if the buffer is invalid or
            /// exceeds the configured limits.
            pub fn decode_with_options(
                bytes: ::buffa::bytes::Bytes,
                opts: &::buffa::DecodeOptions,
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                ::core::result::Result::Ok(
                    ServerFrameOwnedView(
                        ::buffa::OwnedView::decode_with_options(bytes, opts)?,
                    ),
                )
            }
            /// Build from an owned message via an encode → decode round-trip.
            ///
            /// # Errors
            ///
            /// Returns [`::buffa::DecodeError`] if the re-encoded bytes are
            /// somehow invalid (should not happen for well-formed messages).
            pub fn from_owned(
                msg: &super::super::ServerFrame,
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                ::core::result::Result::Ok(
                    ServerFrameOwnedView(::buffa::OwnedView::from_owned(msg)?),
                )
            }
            /// Borrow the full [`ServerFrameView`] with its lifetime tied to `&self`.
            #[must_use]
            pub fn view(&self) -> &ServerFrameView<'_> {
                self.0.reborrow()
            }
            /// Convert to the owned message type.
            ///
            /// # Errors
            ///
            /// Returns an error if re-materializing preserved unknown fields
            /// fails (e.g. the unknown-field limit is exceeded).
            pub fn to_owned_message(
                &self,
            ) -> ::core::result::Result<
                super::super::ServerFrame,
                ::buffa::DecodeError,
            > {
                self.0.to_owned_message()
            }
            /// The underlying bytes buffer.
            #[must_use]
            pub fn bytes(&self) -> &::buffa::bytes::Bytes {
                self.0.bytes()
            }
            /// Consume the handle, returning the underlying bytes buffer.
            #[must_use]
            pub fn into_bytes(self) -> ::buffa::bytes::Bytes {
                self.0.into_bytes()
            }
            /// Client sequence number copied from the accepted or rejected frame.
            ///
            /// Field 1: `seq`
            #[must_use]
            pub fn seq(&self) -> u64 {
                self.0.reborrow().seq
            }
            /// Client correlation token copied from the accepted or rejected frame.
            ///
            /// Field 2: `correlation_id`
            #[must_use]
            pub fn correlation_id(&self) -> &'_ str {
                self.0.reborrow().correlation_id
            }
            /// Oneof `payload`.
            #[must_use]
            pub fn payload(
                &self,
            ) -> ::core::option::Option<
                &super::super::__buffa::view::oneof::server_frame::Payload<'_>,
            > {
                self.0.reborrow().payload.as_ref()
            }
        }
        impl ::core::convert::From<::buffa::OwnedView<ServerFrameView<'static>>>
        for ServerFrameOwnedView {
            fn from(inner: ::buffa::OwnedView<ServerFrameView<'static>>) -> Self {
                ServerFrameOwnedView(inner)
            }
        }
        impl ::core::convert::From<ServerFrameOwnedView>
        for ::buffa::OwnedView<ServerFrameView<'static>> {
            fn from(wrapper: ServerFrameOwnedView) -> Self {
                wrapper.0
            }
        }
        impl ::core::convert::AsRef<::buffa::OwnedView<ServerFrameView<'static>>>
        for ServerFrameOwnedView {
            fn as_ref(&self) -> &::buffa::OwnedView<ServerFrameView<'static>> {
                &self.0
            }
        }
        impl ::buffa::HasMessageView for super::super::ServerFrame {
            type View<'a> = ServerFrameView<'a>;
            type ViewHandle = ServerFrameOwnedView;
        }
        impl ::serde::Serialize for ServerFrameOwnedView {
            fn serialize<__S: ::serde::Serializer>(
                &self,
                __s: __S,
            ) -> ::core::result::Result<__S::Ok, __S::Error> {
                ::serde::Serialize::serialize(&self.0, __s)
            }
        }
        /// PongResponse echoes a PingRequest payload.
        #[derive(Clone, Debug, Default)]
        pub struct PongResponseView<'a> {
            /// Opaque payload copied from PingRequest.
            ///
            /// Field 1: `payload`
            pub payload: &'a [u8],
            pub __buffa_unknown_fields: ::buffa::UnknownFieldsView<'a>,
        }
        impl<'a> ::buffa::MessageView<'a> for PongResponseView<'a> {
            type Owned = super::super::PongResponse;
            fn decode_view(
                buf: &'a [u8],
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                let __limit = ::core::cell::Cell::new(
                    ::buffa::DEFAULT_UNKNOWN_FIELD_LIMIT,
                );
                <Self as ::buffa::MessageView>::decode_view_ctx(
                    buf,
                    ::buffa::DecodeContext::new(::buffa::RECURSION_LIMIT, &__limit),
                )
            }
            fn decode_view_with_ctx(
                buf: &'a [u8],
                ctx: ::buffa::DecodeContext<'_>,
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                <Self as ::buffa::MessageView>::decode_view_ctx(buf, ctx)
            }
            fn merge_view_field(
                &mut self,
                tag: ::buffa::encoding::Tag,
                cur: &'a [u8],
                before_tag: &'a [u8],
                ctx: ::buffa::DecodeContext<'_>,
            ) -> ::core::result::Result<&'a [u8], ::buffa::DecodeError> {
                let _ = ctx;
                #[allow(unused_variables)]
                let view = self;
                let mut cur = cur;
                match tag.field_number() {
                    1u32 => {
                        ::buffa::encoding::check_wire_type(
                            tag,
                            ::buffa::encoding::WireType::LengthDelimited,
                        )?;
                        view.payload = ::buffa::types::borrow_bytes(&mut cur)?;
                    }
                    _ => {
                        ::buffa::encoding::skip_field_depth(tag, &mut cur, ctx.depth())?;
                        let span_len = before_tag.len() - cur.len();
                        view.__buffa_unknown_fields
                            .push_record(before_tag, span_len, ctx)?;
                    }
                }
                ::core::result::Result::Ok(cur)
            }
            fn to_owned_message(
                &self,
            ) -> ::core::result::Result<
                super::super::PongResponse,
                ::buffa::DecodeError,
            > {
                self.to_owned_from_source(None)
            }
            #[allow(clippy::useless_conversion, clippy::needless_update)]
            fn to_owned_from_source(
                &self,
                __buffa_src: ::core::option::Option<&::buffa::bytes::Bytes>,
            ) -> ::core::result::Result<
                super::super::PongResponse,
                ::buffa::DecodeError,
            > {
                #[allow(unused_imports)]
                use ::buffa::alloc::string::ToString as _;
                let _ = __buffa_src;
                ::core::result::Result::Ok(super::super::PongResponse {
                    payload: (self.payload).to_vec(),
                    __buffa_unknown_fields: self
                        .__buffa_unknown_fields
                        .to_owned()?
                        .into(),
                    ..::core::default::Default::default()
                })
            }
        }
        impl<'a> ::buffa::ViewEncode<'a> for PongResponseView<'a> {
            #[allow(clippy::needless_borrow, clippy::let_and_return)]
            fn compute_size(&self, _cache: &mut ::buffa::SizeCache) -> u32 {
                #[allow(unused_imports)]
                use ::buffa::Enumeration as _;
                let mut size = 0u32;
                if !self.payload.is_empty() {
                    size
                        += 1u32
                            + ::buffa::types::bytes_encoded_len(&self.payload) as u32;
                }
                size += self.__buffa_unknown_fields.encoded_len() as u32;
                size
            }
            #[allow(clippy::needless_borrow)]
            fn write_to(
                &self,
                _cache: &mut ::buffa::SizeCache,
                buf: &mut impl ::buffa::bytes::BufMut,
            ) {
                #[allow(unused_imports)]
                use ::buffa::Enumeration as _;
                if !self.payload.is_empty() {
                    ::buffa::types::put_bytes_field(1u32, &self.payload, buf);
                }
                self.__buffa_unknown_fields.write_to(buf);
            }
        }
        /// Serializes this view as protobuf JSON.
        ///
        /// Implicit-presence fields with default values are omitted, `required`
        /// fields are always emitted, explicit-presence (`optional`) fields are
        /// emitted only when set, bytes fields are base64-encoded, and enum
        /// values are their proto name strings.
        ///
        /// This impl uses `serialize_map(None)` because the number of emitted
        /// fields depends on default-omission rules; serializers that require
        /// known map lengths (e.g. `bincode`) will return a runtime error.
        /// Use the owned message type for those formats.
        impl<'__a> ::serde::Serialize for PongResponseView<'__a> {
            fn serialize<__S: ::serde::Serializer>(
                &self,
                __s: __S,
            ) -> ::core::result::Result<__S::Ok, __S::Error> {
                use ::serde::ser::SerializeMap as _;
                let mut __map = __s.serialize_map(::core::option::Option::None)?;
                if !::buffa::json_helpers::skip_if::is_empty_bytes(self.payload) {
                    __map
                        .serialize_entry(
                            "payload",
                            &::buffa::json_helpers::BytesJson(self.payload),
                        )?;
                }
                __map.end()
            }
        }
        impl<'a> ::buffa::MessageName for PongResponseView<'a> {
            const PACKAGE: &'static str = "tradews.v1";
            const NAME: &'static str = "PongResponse";
            const FULL_NAME: &'static str = "tradews.v1.PongResponse";
            const TYPE_URL: &'static str = "type.googleapis.com/tradews.v1.PongResponse";
        }
        ::buffa::impl_default_view_instance!(PongResponseView);
        ::buffa::impl_view_reborrow!(PongResponseView);
        /** Self-contained, `'static` owned view of a `PongResponse` message.

 Wraps [`::buffa::OwnedView`]`<`[`PongResponseView`]`<'static>>`: the decoded view and the [`::buffa::bytes::Bytes`] buffer it borrows from travel together, so the handle is `'static` and `Send + Sync` — suitable for async handlers, spawned tasks, and anywhere a `'static` bound is required.

 Field accessors return borrows tied to `&self`. Use [`Self::view`] to get the full [`PongResponseView`] when you need struct patterns, iteration helpers, or to pass the view to lifetime-parameterised code.*/
        #[derive(Clone, Debug)]
        pub struct PongResponseOwnedView(::buffa::OwnedView<PongResponseView<'static>>);
        impl PongResponseOwnedView {
            /// Decode an owned view from a [`::buffa::bytes::Bytes`] buffer.
            ///
            /// The view borrows directly from the buffer's data; the buffer is
            /// retained inside the returned handle.
            ///
            /// # Errors
            ///
            /// Returns [`::buffa::DecodeError`] if the buffer contains invalid
            /// protobuf data.
            pub fn decode(
                bytes: ::buffa::bytes::Bytes,
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                ::core::result::Result::Ok(
                    PongResponseOwnedView(::buffa::OwnedView::decode(bytes)?),
                )
            }
            /// Decode with custom [`::buffa::DecodeOptions`] (recursion limit,
            /// max message size).
            ///
            /// # Errors
            ///
            /// Returns [`::buffa::DecodeError`] if the buffer is invalid or
            /// exceeds the configured limits.
            pub fn decode_with_options(
                bytes: ::buffa::bytes::Bytes,
                opts: &::buffa::DecodeOptions,
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                ::core::result::Result::Ok(
                    PongResponseOwnedView(
                        ::buffa::OwnedView::decode_with_options(bytes, opts)?,
                    ),
                )
            }
            /// Build from an owned message via an encode → decode round-trip.
            ///
            /// # Errors
            ///
            /// Returns [`::buffa::DecodeError`] if the re-encoded bytes are
            /// somehow invalid (should not happen for well-formed messages).
            pub fn from_owned(
                msg: &super::super::PongResponse,
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                ::core::result::Result::Ok(
                    PongResponseOwnedView(::buffa::OwnedView::from_owned(msg)?),
                )
            }
            /// Borrow the full [`PongResponseView`] with its lifetime tied to `&self`.
            #[must_use]
            pub fn view(&self) -> &PongResponseView<'_> {
                self.0.reborrow()
            }
            /// Convert to the owned message type.
            ///
            /// # Errors
            ///
            /// Returns an error if re-materializing preserved unknown fields
            /// fails (e.g. the unknown-field limit is exceeded).
            pub fn to_owned_message(
                &self,
            ) -> ::core::result::Result<
                super::super::PongResponse,
                ::buffa::DecodeError,
            > {
                self.0.to_owned_message()
            }
            /// The underlying bytes buffer.
            #[must_use]
            pub fn bytes(&self) -> &::buffa::bytes::Bytes {
                self.0.bytes()
            }
            /// Consume the handle, returning the underlying bytes buffer.
            #[must_use]
            pub fn into_bytes(self) -> ::buffa::bytes::Bytes {
                self.0.into_bytes()
            }
            /// Opaque payload copied from PingRequest.
            ///
            /// Field 1: `payload`
            #[must_use]
            pub fn payload(&self) -> &'_ [u8] {
                self.0.reborrow().payload
            }
        }
        impl ::core::convert::From<::buffa::OwnedView<PongResponseView<'static>>>
        for PongResponseOwnedView {
            fn from(inner: ::buffa::OwnedView<PongResponseView<'static>>) -> Self {
                PongResponseOwnedView(inner)
            }
        }
        impl ::core::convert::From<PongResponseOwnedView>
        for ::buffa::OwnedView<PongResponseView<'static>> {
            fn from(wrapper: PongResponseOwnedView) -> Self {
                wrapper.0
            }
        }
        impl ::core::convert::AsRef<::buffa::OwnedView<PongResponseView<'static>>>
        for PongResponseOwnedView {
            fn as_ref(&self) -> &::buffa::OwnedView<PongResponseView<'static>> {
                &self.0
            }
        }
        impl ::buffa::HasMessageView for super::super::PongResponse {
            type View<'a> = PongResponseView<'a>;
            type ViewHandle = PongResponseOwnedView;
        }
        impl ::serde::Serialize for PongResponseOwnedView {
            fn serialize<__S: ::serde::Serializer>(
                &self,
                __s: __S,
            ) -> ::core::result::Result<__S::Ok, __S::Error> {
                ::serde::Serialize::serialize(&self.0, __s)
            }
        }
        /// AckResponse carries the command-specific public Orders API acknowledgement.
        #[derive(Clone, Debug, Default)]
        pub struct AckResponseView<'a> {
            pub result: ::core::option::Option<
                super::super::__buffa::view::oneof::ack_response::Result<'a>,
            >,
            pub __buffa_unknown_fields: ::buffa::UnknownFieldsView<'a>,
        }
        impl<'a> ::buffa::MessageView<'a> for AckResponseView<'a> {
            type Owned = super::super::AckResponse;
            fn decode_view(
                buf: &'a [u8],
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                let __limit = ::core::cell::Cell::new(
                    ::buffa::DEFAULT_UNKNOWN_FIELD_LIMIT,
                );
                <Self as ::buffa::MessageView>::decode_view_ctx(
                    buf,
                    ::buffa::DecodeContext::new(::buffa::RECURSION_LIMIT, &__limit),
                )
            }
            fn decode_view_with_ctx(
                buf: &'a [u8],
                ctx: ::buffa::DecodeContext<'_>,
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                <Self as ::buffa::MessageView>::decode_view_ctx(buf, ctx)
            }
            fn merge_view_field(
                &mut self,
                tag: ::buffa::encoding::Tag,
                cur: &'a [u8],
                before_tag: &'a [u8],
                ctx: ::buffa::DecodeContext<'_>,
            ) -> ::core::result::Result<&'a [u8], ::buffa::DecodeError> {
                let _ = ctx;
                #[allow(unused_variables)]
                let view = self;
                let mut cur = cur;
                match tag.field_number() {
                    1u32 => {
                        ::buffa::encoding::check_wire_type(
                            tag,
                            ::buffa::encoding::WireType::LengthDelimited,
                        )?;
                        let __sub_ctx = ctx.descend()?;
                        let sub = ::buffa::types::borrow_bytes(&mut cur)?;
                        if let Some(
                            super::super::__buffa::view::oneof::ack_response::Result::CreateOrder(
                                ref mut existing,
                            ),
                        ) = view.result
                        {
                            ::buffa::MessageView::merge_into_view(
                                &mut **existing,
                                sub,
                                __sub_ctx,
                            )?;
                        } else {
                            view.result = Some(
                                super::super::__buffa::view::oneof::ack_response::Result::CreateOrder(
                                    ::buffa::alloc::boxed::Box::new(
                                        <super::super::super::super::orders::v1::__buffa::view::CreateOrderResponseView as ::buffa::MessageView>::decode_view_ctx(
                                            sub,
                                            __sub_ctx,
                                        )?,
                                    ),
                                ),
                            );
                        }
                    }
                    2u32 => {
                        ::buffa::encoding::check_wire_type(
                            tag,
                            ::buffa::encoding::WireType::LengthDelimited,
                        )?;
                        let __sub_ctx = ctx.descend()?;
                        let sub = ::buffa::types::borrow_bytes(&mut cur)?;
                        if let Some(
                            super::super::__buffa::view::oneof::ack_response::Result::CancelOrder(
                                ref mut existing,
                            ),
                        ) = view.result
                        {
                            ::buffa::MessageView::merge_into_view(
                                &mut **existing,
                                sub,
                                __sub_ctx,
                            )?;
                        } else {
                            view.result = Some(
                                super::super::__buffa::view::oneof::ack_response::Result::CancelOrder(
                                    ::buffa::alloc::boxed::Box::new(
                                        <super::super::super::super::orders::v1::__buffa::view::CancelOrderResponseView as ::buffa::MessageView>::decode_view_ctx(
                                            sub,
                                            __sub_ctx,
                                        )?,
                                    ),
                                ),
                            );
                        }
                    }
                    3u32 => {
                        ::buffa::encoding::check_wire_type(
                            tag,
                            ::buffa::encoding::WireType::LengthDelimited,
                        )?;
                        let __sub_ctx = ctx.descend()?;
                        let sub = ::buffa::types::borrow_bytes(&mut cur)?;
                        if let Some(
                            super::super::__buffa::view::oneof::ack_response::Result::ModifyOrder(
                                ref mut existing,
                            ),
                        ) = view.result
                        {
                            ::buffa::MessageView::merge_into_view(
                                &mut **existing,
                                sub,
                                __sub_ctx,
                            )?;
                        } else {
                            view.result = Some(
                                super::super::__buffa::view::oneof::ack_response::Result::ModifyOrder(
                                    ::buffa::alloc::boxed::Box::new(
                                        <super::super::super::super::orders::v1::__buffa::view::ModifyOrderResponseView as ::buffa::MessageView>::decode_view_ctx(
                                            sub,
                                            __sub_ctx,
                                        )?,
                                    ),
                                ),
                            );
                        }
                    }
                    4u32 => {
                        ::buffa::encoding::check_wire_type(
                            tag,
                            ::buffa::encoding::WireType::LengthDelimited,
                        )?;
                        let __sub_ctx = ctx.descend()?;
                        let sub = ::buffa::types::borrow_bytes(&mut cur)?;
                        if let Some(
                            super::super::__buffa::view::oneof::ack_response::Result::CancelAllOrders(
                                ref mut existing,
                            ),
                        ) = view.result
                        {
                            ::buffa::MessageView::merge_into_view(
                                &mut **existing,
                                sub,
                                __sub_ctx,
                            )?;
                        } else {
                            view.result = Some(
                                super::super::__buffa::view::oneof::ack_response::Result::CancelAllOrders(
                                    ::buffa::alloc::boxed::Box::new(
                                        <super::super::super::super::orders::v1::__buffa::view::CancelAllOrdersResponseView as ::buffa::MessageView>::decode_view_ctx(
                                            sub,
                                            __sub_ctx,
                                        )?,
                                    ),
                                ),
                            );
                        }
                    }
                    _ => {
                        ::buffa::encoding::skip_field_depth(tag, &mut cur, ctx.depth())?;
                        let span_len = before_tag.len() - cur.len();
                        view.__buffa_unknown_fields
                            .push_record(before_tag, span_len, ctx)?;
                    }
                }
                ::core::result::Result::Ok(cur)
            }
            fn to_owned_message(
                &self,
            ) -> ::core::result::Result<
                super::super::AckResponse,
                ::buffa::DecodeError,
            > {
                self.to_owned_from_source(None)
            }
            #[allow(clippy::useless_conversion, clippy::needless_update)]
            fn to_owned_from_source(
                &self,
                __buffa_src: ::core::option::Option<&::buffa::bytes::Bytes>,
            ) -> ::core::result::Result<
                super::super::AckResponse,
                ::buffa::DecodeError,
            > {
                #[allow(unused_imports)]
                use ::buffa::alloc::string::ToString as _;
                let _ = __buffa_src;
                ::core::result::Result::Ok(super::super::AckResponse {
                    result: match self.result.as_ref() {
                        ::core::option::Option::Some(v) => {
                            ::core::option::Option::Some(
                                match v {
                                    super::super::__buffa::view::oneof::ack_response::Result::CreateOrder(
                                        v,
                                    ) => {
                                        super::super::__buffa::oneof::ack_response::Result::CreateOrder(
                                            ::buffa::alloc::boxed::Box::new(
                                                v.to_owned_from_source(__buffa_src)?,
                                            ),
                                        )
                                    }
                                    super::super::__buffa::view::oneof::ack_response::Result::CancelOrder(
                                        v,
                                    ) => {
                                        super::super::__buffa::oneof::ack_response::Result::CancelOrder(
                                            ::buffa::alloc::boxed::Box::new(
                                                v.to_owned_from_source(__buffa_src)?,
                                            ),
                                        )
                                    }
                                    super::super::__buffa::view::oneof::ack_response::Result::ModifyOrder(
                                        v,
                                    ) => {
                                        super::super::__buffa::oneof::ack_response::Result::ModifyOrder(
                                            ::buffa::alloc::boxed::Box::new(
                                                v.to_owned_from_source(__buffa_src)?,
                                            ),
                                        )
                                    }
                                    super::super::__buffa::view::oneof::ack_response::Result::CancelAllOrders(
                                        v,
                                    ) => {
                                        super::super::__buffa::oneof::ack_response::Result::CancelAllOrders(
                                            ::buffa::alloc::boxed::Box::new(
                                                v.to_owned_from_source(__buffa_src)?,
                                            ),
                                        )
                                    }
                                },
                            )
                        }
                        ::core::option::Option::None => ::core::option::Option::None,
                    },
                    __buffa_unknown_fields: self
                        .__buffa_unknown_fields
                        .to_owned()?
                        .into(),
                    ..::core::default::Default::default()
                })
            }
        }
        impl<'a> ::buffa::ViewEncode<'a> for AckResponseView<'a> {
            #[allow(clippy::needless_borrow, clippy::let_and_return)]
            fn compute_size(&self, __cache: &mut ::buffa::SizeCache) -> u32 {
                #[allow(unused_imports)]
                use ::buffa::Enumeration as _;
                let mut size = 0u32;
                if let ::core::option::Option::Some(ref v) = self.result {
                    match v {
                        super::super::__buffa::view::oneof::ack_response::Result::CreateOrder(
                            x,
                        ) => {
                            let __slot = __cache.reserve();
                            let inner = x.compute_size(__cache);
                            __cache.set(__slot, inner);
                            size
                                += 1u32 + ::buffa::encoding::varint_len(inner as u64) as u32
                                    + inner;
                        }
                        super::super::__buffa::view::oneof::ack_response::Result::CancelOrder(
                            x,
                        ) => {
                            let __slot = __cache.reserve();
                            let inner = x.compute_size(__cache);
                            __cache.set(__slot, inner);
                            size
                                += 1u32 + ::buffa::encoding::varint_len(inner as u64) as u32
                                    + inner;
                        }
                        super::super::__buffa::view::oneof::ack_response::Result::ModifyOrder(
                            x,
                        ) => {
                            let __slot = __cache.reserve();
                            let inner = x.compute_size(__cache);
                            __cache.set(__slot, inner);
                            size
                                += 1u32 + ::buffa::encoding::varint_len(inner as u64) as u32
                                    + inner;
                        }
                        super::super::__buffa::view::oneof::ack_response::Result::CancelAllOrders(
                            x,
                        ) => {
                            let __slot = __cache.reserve();
                            let inner = x.compute_size(__cache);
                            __cache.set(__slot, inner);
                            size
                                += 1u32 + ::buffa::encoding::varint_len(inner as u64) as u32
                                    + inner;
                        }
                    }
                }
                size += self.__buffa_unknown_fields.encoded_len() as u32;
                size
            }
            #[allow(clippy::needless_borrow)]
            fn write_to(
                &self,
                __cache: &mut ::buffa::SizeCache,
                buf: &mut impl ::buffa::bytes::BufMut,
            ) {
                #[allow(unused_imports)]
                use ::buffa::Enumeration as _;
                if let ::core::option::Option::Some(ref v) = self.result {
                    match v {
                        super::super::__buffa::view::oneof::ack_response::Result::CreateOrder(
                            x,
                        ) => {
                            ::buffa::types::put_len_delimited_header(
                                1u32,
                                __cache.consume_next(),
                                buf,
                            );
                            x.write_to(__cache, buf);
                        }
                        super::super::__buffa::view::oneof::ack_response::Result::CancelOrder(
                            x,
                        ) => {
                            ::buffa::types::put_len_delimited_header(
                                2u32,
                                __cache.consume_next(),
                                buf,
                            );
                            x.write_to(__cache, buf);
                        }
                        super::super::__buffa::view::oneof::ack_response::Result::ModifyOrder(
                            x,
                        ) => {
                            ::buffa::types::put_len_delimited_header(
                                3u32,
                                __cache.consume_next(),
                                buf,
                            );
                            x.write_to(__cache, buf);
                        }
                        super::super::__buffa::view::oneof::ack_response::Result::CancelAllOrders(
                            x,
                        ) => {
                            ::buffa::types::put_len_delimited_header(
                                4u32,
                                __cache.consume_next(),
                                buf,
                            );
                            x.write_to(__cache, buf);
                        }
                    }
                }
                self.__buffa_unknown_fields.write_to(buf);
            }
        }
        /// Serializes this view as protobuf JSON.
        ///
        /// Implicit-presence fields with default values are omitted, `required`
        /// fields are always emitted, explicit-presence (`optional`) fields are
        /// emitted only when set, bytes fields are base64-encoded, and enum
        /// values are their proto name strings.
        ///
        /// This impl uses `serialize_map(None)` because the number of emitted
        /// fields depends on default-omission rules; serializers that require
        /// known map lengths (e.g. `bincode`) will return a runtime error.
        /// Use the owned message type for those formats.
        impl<'__a> ::serde::Serialize for AckResponseView<'__a> {
            fn serialize<__S: ::serde::Serializer>(
                &self,
                __s: __S,
            ) -> ::core::result::Result<__S::Ok, __S::Error> {
                use ::serde::ser::SerializeMap as _;
                let mut __map = __s.serialize_map(::core::option::Option::None)?;
                if let ::core::option::Option::Some(ref __ov) = self.result {
                    match __ov {
                        super::super::__buffa::view::oneof::ack_response::Result::CreateOrder(
                            v,
                        ) => {
                            __map.serialize_entry("createOrder", v)?;
                        }
                        super::super::__buffa::view::oneof::ack_response::Result::CancelOrder(
                            v,
                        ) => {
                            __map.serialize_entry("cancelOrder", v)?;
                        }
                        super::super::__buffa::view::oneof::ack_response::Result::ModifyOrder(
                            v,
                        ) => {
                            __map.serialize_entry("modifyOrder", v)?;
                        }
                        super::super::__buffa::view::oneof::ack_response::Result::CancelAllOrders(
                            v,
                        ) => {
                            __map.serialize_entry("cancelAllOrders", v)?;
                        }
                    }
                }
                __map.end()
            }
        }
        impl<'a> ::buffa::MessageName for AckResponseView<'a> {
            const PACKAGE: &'static str = "tradews.v1";
            const NAME: &'static str = "AckResponse";
            const FULL_NAME: &'static str = "tradews.v1.AckResponse";
            const TYPE_URL: &'static str = "type.googleapis.com/tradews.v1.AckResponse";
        }
        ::buffa::impl_default_view_instance!(AckResponseView);
        ::buffa::impl_view_reborrow!(AckResponseView);
        /** Self-contained, `'static` owned view of a `AckResponse` message.

 Wraps [`::buffa::OwnedView`]`<`[`AckResponseView`]`<'static>>`: the decoded view and the [`::buffa::bytes::Bytes`] buffer it borrows from travel together, so the handle is `'static` and `Send + Sync` — suitable for async handlers, spawned tasks, and anywhere a `'static` bound is required.

 Field accessors return borrows tied to `&self`. Use [`Self::view`] to get the full [`AckResponseView`] when you need struct patterns, iteration helpers, or to pass the view to lifetime-parameterised code.*/
        #[derive(Clone, Debug)]
        pub struct AckResponseOwnedView(::buffa::OwnedView<AckResponseView<'static>>);
        impl AckResponseOwnedView {
            /// Decode an owned view from a [`::buffa::bytes::Bytes`] buffer.
            ///
            /// The view borrows directly from the buffer's data; the buffer is
            /// retained inside the returned handle.
            ///
            /// # Errors
            ///
            /// Returns [`::buffa::DecodeError`] if the buffer contains invalid
            /// protobuf data.
            pub fn decode(
                bytes: ::buffa::bytes::Bytes,
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                ::core::result::Result::Ok(
                    AckResponseOwnedView(::buffa::OwnedView::decode(bytes)?),
                )
            }
            /// Decode with custom [`::buffa::DecodeOptions`] (recursion limit,
            /// max message size).
            ///
            /// # Errors
            ///
            /// Returns [`::buffa::DecodeError`] if the buffer is invalid or
            /// exceeds the configured limits.
            pub fn decode_with_options(
                bytes: ::buffa::bytes::Bytes,
                opts: &::buffa::DecodeOptions,
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                ::core::result::Result::Ok(
                    AckResponseOwnedView(
                        ::buffa::OwnedView::decode_with_options(bytes, opts)?,
                    ),
                )
            }
            /// Build from an owned message via an encode → decode round-trip.
            ///
            /// # Errors
            ///
            /// Returns [`::buffa::DecodeError`] if the re-encoded bytes are
            /// somehow invalid (should not happen for well-formed messages).
            pub fn from_owned(
                msg: &super::super::AckResponse,
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                ::core::result::Result::Ok(
                    AckResponseOwnedView(::buffa::OwnedView::from_owned(msg)?),
                )
            }
            /// Borrow the full [`AckResponseView`] with its lifetime tied to `&self`.
            #[must_use]
            pub fn view(&self) -> &AckResponseView<'_> {
                self.0.reborrow()
            }
            /// Convert to the owned message type.
            ///
            /// # Errors
            ///
            /// Returns an error if re-materializing preserved unknown fields
            /// fails (e.g. the unknown-field limit is exceeded).
            pub fn to_owned_message(
                &self,
            ) -> ::core::result::Result<
                super::super::AckResponse,
                ::buffa::DecodeError,
            > {
                self.0.to_owned_message()
            }
            /// The underlying bytes buffer.
            #[must_use]
            pub fn bytes(&self) -> &::buffa::bytes::Bytes {
                self.0.bytes()
            }
            /// Consume the handle, returning the underlying bytes buffer.
            #[must_use]
            pub fn into_bytes(self) -> ::buffa::bytes::Bytes {
                self.0.into_bytes()
            }
            /// Oneof `result`.
            #[must_use]
            pub fn result(
                &self,
            ) -> ::core::option::Option<
                &super::super::__buffa::view::oneof::ack_response::Result<'_>,
            > {
                self.0.reborrow().result.as_ref()
            }
        }
        impl ::core::convert::From<::buffa::OwnedView<AckResponseView<'static>>>
        for AckResponseOwnedView {
            fn from(inner: ::buffa::OwnedView<AckResponseView<'static>>) -> Self {
                AckResponseOwnedView(inner)
            }
        }
        impl ::core::convert::From<AckResponseOwnedView>
        for ::buffa::OwnedView<AckResponseView<'static>> {
            fn from(wrapper: AckResponseOwnedView) -> Self {
                wrapper.0
            }
        }
        impl ::core::convert::AsRef<::buffa::OwnedView<AckResponseView<'static>>>
        for AckResponseOwnedView {
            fn as_ref(&self) -> &::buffa::OwnedView<AckResponseView<'static>> {
                &self.0
            }
        }
        impl ::buffa::HasMessageView for super::super::AckResponse {
            type View<'a> = AckResponseView<'a>;
            type ViewHandle = AckResponseOwnedView;
        }
        impl ::serde::Serialize for AckResponseOwnedView {
            fn serialize<__S: ::serde::Serializer>(
                &self,
                __s: __S,
            ) -> ::core::result::Result<__S::Ok, __S::Error> {
                ::serde::Serialize::serialize(&self.0, __s)
            }
        }
        /// CommandReject reports a command-level failure without closing the session.
        #[derive(Clone, Debug, Default)]
        pub struct CommandRejectView<'a> {
            /// Stable machine-readable reject code.
            ///
            /// Field 1: `code`
            pub code: &'a str,
            /// Client-safe diagnostic detail.
            ///
            /// Field 2: `detail`
            pub detail: &'a str,
            pub __buffa_unknown_fields: ::buffa::UnknownFieldsView<'a>,
        }
        impl<'a> ::buffa::MessageView<'a> for CommandRejectView<'a> {
            type Owned = super::super::CommandReject;
            fn decode_view(
                buf: &'a [u8],
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                let __limit = ::core::cell::Cell::new(
                    ::buffa::DEFAULT_UNKNOWN_FIELD_LIMIT,
                );
                <Self as ::buffa::MessageView>::decode_view_ctx(
                    buf,
                    ::buffa::DecodeContext::new(::buffa::RECURSION_LIMIT, &__limit),
                )
            }
            fn decode_view_with_ctx(
                buf: &'a [u8],
                ctx: ::buffa::DecodeContext<'_>,
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                <Self as ::buffa::MessageView>::decode_view_ctx(buf, ctx)
            }
            fn merge_view_field(
                &mut self,
                tag: ::buffa::encoding::Tag,
                cur: &'a [u8],
                before_tag: &'a [u8],
                ctx: ::buffa::DecodeContext<'_>,
            ) -> ::core::result::Result<&'a [u8], ::buffa::DecodeError> {
                let _ = ctx;
                #[allow(unused_variables)]
                let view = self;
                let mut cur = cur;
                match tag.field_number() {
                    1u32 => {
                        ::buffa::encoding::check_wire_type(
                            tag,
                            ::buffa::encoding::WireType::LengthDelimited,
                        )?;
                        view.code = ::buffa::types::borrow_str(&mut cur)?;
                    }
                    2u32 => {
                        ::buffa::encoding::check_wire_type(
                            tag,
                            ::buffa::encoding::WireType::LengthDelimited,
                        )?;
                        view.detail = ::buffa::types::borrow_str(&mut cur)?;
                    }
                    _ => {
                        ::buffa::encoding::skip_field_depth(tag, &mut cur, ctx.depth())?;
                        let span_len = before_tag.len() - cur.len();
                        view.__buffa_unknown_fields
                            .push_record(before_tag, span_len, ctx)?;
                    }
                }
                ::core::result::Result::Ok(cur)
            }
            fn to_owned_message(
                &self,
            ) -> ::core::result::Result<
                super::super::CommandReject,
                ::buffa::DecodeError,
            > {
                self.to_owned_from_source(None)
            }
            #[allow(clippy::useless_conversion, clippy::needless_update)]
            fn to_owned_from_source(
                &self,
                __buffa_src: ::core::option::Option<&::buffa::bytes::Bytes>,
            ) -> ::core::result::Result<
                super::super::CommandReject,
                ::buffa::DecodeError,
            > {
                #[allow(unused_imports)]
                use ::buffa::alloc::string::ToString as _;
                let _ = __buffa_src;
                ::core::result::Result::Ok(super::super::CommandReject {
                    code: self.code.to_string(),
                    detail: self.detail.to_string(),
                    __buffa_unknown_fields: self
                        .__buffa_unknown_fields
                        .to_owned()?
                        .into(),
                    ..::core::default::Default::default()
                })
            }
        }
        impl<'a> ::buffa::ViewEncode<'a> for CommandRejectView<'a> {
            #[allow(clippy::needless_borrow, clippy::let_and_return)]
            fn compute_size(&self, _cache: &mut ::buffa::SizeCache) -> u32 {
                #[allow(unused_imports)]
                use ::buffa::Enumeration as _;
                let mut size = 0u32;
                if !self.code.is_empty() {
                    size += 1u32 + ::buffa::types::string_encoded_len(&self.code) as u32;
                }
                if !self.detail.is_empty() {
                    size
                        += 1u32
                            + ::buffa::types::string_encoded_len(&self.detail) as u32;
                }
                size += self.__buffa_unknown_fields.encoded_len() as u32;
                size
            }
            #[allow(clippy::needless_borrow)]
            fn write_to(
                &self,
                _cache: &mut ::buffa::SizeCache,
                buf: &mut impl ::buffa::bytes::BufMut,
            ) {
                #[allow(unused_imports)]
                use ::buffa::Enumeration as _;
                if !self.code.is_empty() {
                    ::buffa::types::put_string_field(1u32, &self.code, buf);
                }
                if !self.detail.is_empty() {
                    ::buffa::types::put_string_field(2u32, &self.detail, buf);
                }
                self.__buffa_unknown_fields.write_to(buf);
            }
        }
        /// Serializes this view as protobuf JSON.
        ///
        /// Implicit-presence fields with default values are omitted, `required`
        /// fields are always emitted, explicit-presence (`optional`) fields are
        /// emitted only when set, bytes fields are base64-encoded, and enum
        /// values are their proto name strings.
        ///
        /// This impl uses `serialize_map(None)` because the number of emitted
        /// fields depends on default-omission rules; serializers that require
        /// known map lengths (e.g. `bincode`) will return a runtime error.
        /// Use the owned message type for those formats.
        impl<'__a> ::serde::Serialize for CommandRejectView<'__a> {
            fn serialize<__S: ::serde::Serializer>(
                &self,
                __s: __S,
            ) -> ::core::result::Result<__S::Ok, __S::Error> {
                use ::serde::ser::SerializeMap as _;
                let mut __map = __s.serialize_map(::core::option::Option::None)?;
                if !::buffa::json_helpers::skip_if::is_empty_str(self.code) {
                    __map.serialize_entry("code", self.code)?;
                }
                if !::buffa::json_helpers::skip_if::is_empty_str(self.detail) {
                    __map.serialize_entry("detail", self.detail)?;
                }
                __map.end()
            }
        }
        impl<'a> ::buffa::MessageName for CommandRejectView<'a> {
            const PACKAGE: &'static str = "tradews.v1";
            const NAME: &'static str = "CommandReject";
            const FULL_NAME: &'static str = "tradews.v1.CommandReject";
            const TYPE_URL: &'static str = "type.googleapis.com/tradews.v1.CommandReject";
        }
        ::buffa::impl_default_view_instance!(CommandRejectView);
        ::buffa::impl_view_reborrow!(CommandRejectView);
        /** Self-contained, `'static` owned view of a `CommandReject` message.

 Wraps [`::buffa::OwnedView`]`<`[`CommandRejectView`]`<'static>>`: the decoded view and the [`::buffa::bytes::Bytes`] buffer it borrows from travel together, so the handle is `'static` and `Send + Sync` — suitable for async handlers, spawned tasks, and anywhere a `'static` bound is required.

 Field accessors return borrows tied to `&self`. Use [`Self::view`] to get the full [`CommandRejectView`] when you need struct patterns, iteration helpers, or to pass the view to lifetime-parameterised code.*/
        #[derive(Clone, Debug)]
        pub struct CommandRejectOwnedView(
            ::buffa::OwnedView<CommandRejectView<'static>>,
        );
        impl CommandRejectOwnedView {
            /// Decode an owned view from a [`::buffa::bytes::Bytes`] buffer.
            ///
            /// The view borrows directly from the buffer's data; the buffer is
            /// retained inside the returned handle.
            ///
            /// # Errors
            ///
            /// Returns [`::buffa::DecodeError`] if the buffer contains invalid
            /// protobuf data.
            pub fn decode(
                bytes: ::buffa::bytes::Bytes,
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                ::core::result::Result::Ok(
                    CommandRejectOwnedView(::buffa::OwnedView::decode(bytes)?),
                )
            }
            /// Decode with custom [`::buffa::DecodeOptions`] (recursion limit,
            /// max message size).
            ///
            /// # Errors
            ///
            /// Returns [`::buffa::DecodeError`] if the buffer is invalid or
            /// exceeds the configured limits.
            pub fn decode_with_options(
                bytes: ::buffa::bytes::Bytes,
                opts: &::buffa::DecodeOptions,
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                ::core::result::Result::Ok(
                    CommandRejectOwnedView(
                        ::buffa::OwnedView::decode_with_options(bytes, opts)?,
                    ),
                )
            }
            /// Build from an owned message via an encode → decode round-trip.
            ///
            /// # Errors
            ///
            /// Returns [`::buffa::DecodeError`] if the re-encoded bytes are
            /// somehow invalid (should not happen for well-formed messages).
            pub fn from_owned(
                msg: &super::super::CommandReject,
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                ::core::result::Result::Ok(
                    CommandRejectOwnedView(::buffa::OwnedView::from_owned(msg)?),
                )
            }
            /// Borrow the full [`CommandRejectView`] with its lifetime tied to `&self`.
            #[must_use]
            pub fn view(&self) -> &CommandRejectView<'_> {
                self.0.reborrow()
            }
            /// Convert to the owned message type.
            ///
            /// # Errors
            ///
            /// Returns an error if re-materializing preserved unknown fields
            /// fails (e.g. the unknown-field limit is exceeded).
            pub fn to_owned_message(
                &self,
            ) -> ::core::result::Result<
                super::super::CommandReject,
                ::buffa::DecodeError,
            > {
                self.0.to_owned_message()
            }
            /// The underlying bytes buffer.
            #[must_use]
            pub fn bytes(&self) -> &::buffa::bytes::Bytes {
                self.0.bytes()
            }
            /// Consume the handle, returning the underlying bytes buffer.
            #[must_use]
            pub fn into_bytes(self) -> ::buffa::bytes::Bytes {
                self.0.into_bytes()
            }
            /// Stable machine-readable reject code.
            ///
            /// Field 1: `code`
            #[must_use]
            pub fn code(&self) -> &'_ str {
                self.0.reborrow().code
            }
            /// Client-safe diagnostic detail.
            ///
            /// Field 2: `detail`
            #[must_use]
            pub fn detail(&self) -> &'_ str {
                self.0.reborrow().detail
            }
        }
        impl ::core::convert::From<::buffa::OwnedView<CommandRejectView<'static>>>
        for CommandRejectOwnedView {
            fn from(inner: ::buffa::OwnedView<CommandRejectView<'static>>) -> Self {
                CommandRejectOwnedView(inner)
            }
        }
        impl ::core::convert::From<CommandRejectOwnedView>
        for ::buffa::OwnedView<CommandRejectView<'static>> {
            fn from(wrapper: CommandRejectOwnedView) -> Self {
                wrapper.0
            }
        }
        impl ::core::convert::AsRef<::buffa::OwnedView<CommandRejectView<'static>>>
        for CommandRejectOwnedView {
            fn as_ref(&self) -> &::buffa::OwnedView<CommandRejectView<'static>> {
                &self.0
            }
        }
        impl ::buffa::HasMessageView for super::super::CommandReject {
            type View<'a> = CommandRejectView<'a>;
            type ViewHandle = CommandRejectOwnedView;
        }
        impl ::serde::Serialize for CommandRejectOwnedView {
            fn serialize<__S: ::serde::Serializer>(
                &self,
                __s: __S,
            ) -> ::core::result::Result<__S::Ok, __S::Error> {
                ::serde::Serialize::serialize(&self.0, __s)
            }
        }
        /// OverloadResponse reports that the session exceeded server admission limits.
        #[derive(Clone, Debug, Default)]
        pub struct OverloadResponseView<'a> {
            /// Stable machine-readable overload code.
            ///
            /// Field 1: `code`
            pub code: &'a str,
            /// Client-safe diagnostic detail.
            ///
            /// Field 2: `detail`
            pub detail: &'a str,
            pub __buffa_unknown_fields: ::buffa::UnknownFieldsView<'a>,
        }
        impl<'a> ::buffa::MessageView<'a> for OverloadResponseView<'a> {
            type Owned = super::super::OverloadResponse;
            fn decode_view(
                buf: &'a [u8],
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                let __limit = ::core::cell::Cell::new(
                    ::buffa::DEFAULT_UNKNOWN_FIELD_LIMIT,
                );
                <Self as ::buffa::MessageView>::decode_view_ctx(
                    buf,
                    ::buffa::DecodeContext::new(::buffa::RECURSION_LIMIT, &__limit),
                )
            }
            fn decode_view_with_ctx(
                buf: &'a [u8],
                ctx: ::buffa::DecodeContext<'_>,
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                <Self as ::buffa::MessageView>::decode_view_ctx(buf, ctx)
            }
            fn merge_view_field(
                &mut self,
                tag: ::buffa::encoding::Tag,
                cur: &'a [u8],
                before_tag: &'a [u8],
                ctx: ::buffa::DecodeContext<'_>,
            ) -> ::core::result::Result<&'a [u8], ::buffa::DecodeError> {
                let _ = ctx;
                #[allow(unused_variables)]
                let view = self;
                let mut cur = cur;
                match tag.field_number() {
                    1u32 => {
                        ::buffa::encoding::check_wire_type(
                            tag,
                            ::buffa::encoding::WireType::LengthDelimited,
                        )?;
                        view.code = ::buffa::types::borrow_str(&mut cur)?;
                    }
                    2u32 => {
                        ::buffa::encoding::check_wire_type(
                            tag,
                            ::buffa::encoding::WireType::LengthDelimited,
                        )?;
                        view.detail = ::buffa::types::borrow_str(&mut cur)?;
                    }
                    _ => {
                        ::buffa::encoding::skip_field_depth(tag, &mut cur, ctx.depth())?;
                        let span_len = before_tag.len() - cur.len();
                        view.__buffa_unknown_fields
                            .push_record(before_tag, span_len, ctx)?;
                    }
                }
                ::core::result::Result::Ok(cur)
            }
            fn to_owned_message(
                &self,
            ) -> ::core::result::Result<
                super::super::OverloadResponse,
                ::buffa::DecodeError,
            > {
                self.to_owned_from_source(None)
            }
            #[allow(clippy::useless_conversion, clippy::needless_update)]
            fn to_owned_from_source(
                &self,
                __buffa_src: ::core::option::Option<&::buffa::bytes::Bytes>,
            ) -> ::core::result::Result<
                super::super::OverloadResponse,
                ::buffa::DecodeError,
            > {
                #[allow(unused_imports)]
                use ::buffa::alloc::string::ToString as _;
                let _ = __buffa_src;
                ::core::result::Result::Ok(super::super::OverloadResponse {
                    code: self.code.to_string(),
                    detail: self.detail.to_string(),
                    __buffa_unknown_fields: self
                        .__buffa_unknown_fields
                        .to_owned()?
                        .into(),
                    ..::core::default::Default::default()
                })
            }
        }
        impl<'a> ::buffa::ViewEncode<'a> for OverloadResponseView<'a> {
            #[allow(clippy::needless_borrow, clippy::let_and_return)]
            fn compute_size(&self, _cache: &mut ::buffa::SizeCache) -> u32 {
                #[allow(unused_imports)]
                use ::buffa::Enumeration as _;
                let mut size = 0u32;
                if !self.code.is_empty() {
                    size += 1u32 + ::buffa::types::string_encoded_len(&self.code) as u32;
                }
                if !self.detail.is_empty() {
                    size
                        += 1u32
                            + ::buffa::types::string_encoded_len(&self.detail) as u32;
                }
                size += self.__buffa_unknown_fields.encoded_len() as u32;
                size
            }
            #[allow(clippy::needless_borrow)]
            fn write_to(
                &self,
                _cache: &mut ::buffa::SizeCache,
                buf: &mut impl ::buffa::bytes::BufMut,
            ) {
                #[allow(unused_imports)]
                use ::buffa::Enumeration as _;
                if !self.code.is_empty() {
                    ::buffa::types::put_string_field(1u32, &self.code, buf);
                }
                if !self.detail.is_empty() {
                    ::buffa::types::put_string_field(2u32, &self.detail, buf);
                }
                self.__buffa_unknown_fields.write_to(buf);
            }
        }
        /// Serializes this view as protobuf JSON.
        ///
        /// Implicit-presence fields with default values are omitted, `required`
        /// fields are always emitted, explicit-presence (`optional`) fields are
        /// emitted only when set, bytes fields are base64-encoded, and enum
        /// values are their proto name strings.
        ///
        /// This impl uses `serialize_map(None)` because the number of emitted
        /// fields depends on default-omission rules; serializers that require
        /// known map lengths (e.g. `bincode`) will return a runtime error.
        /// Use the owned message type for those formats.
        impl<'__a> ::serde::Serialize for OverloadResponseView<'__a> {
            fn serialize<__S: ::serde::Serializer>(
                &self,
                __s: __S,
            ) -> ::core::result::Result<__S::Ok, __S::Error> {
                use ::serde::ser::SerializeMap as _;
                let mut __map = __s.serialize_map(::core::option::Option::None)?;
                if !::buffa::json_helpers::skip_if::is_empty_str(self.code) {
                    __map.serialize_entry("code", self.code)?;
                }
                if !::buffa::json_helpers::skip_if::is_empty_str(self.detail) {
                    __map.serialize_entry("detail", self.detail)?;
                }
                __map.end()
            }
        }
        impl<'a> ::buffa::MessageName for OverloadResponseView<'a> {
            const PACKAGE: &'static str = "tradews.v1";
            const NAME: &'static str = "OverloadResponse";
            const FULL_NAME: &'static str = "tradews.v1.OverloadResponse";
            const TYPE_URL: &'static str = "type.googleapis.com/tradews.v1.OverloadResponse";
        }
        ::buffa::impl_default_view_instance!(OverloadResponseView);
        ::buffa::impl_view_reborrow!(OverloadResponseView);
        /** Self-contained, `'static` owned view of a `OverloadResponse` message.

 Wraps [`::buffa::OwnedView`]`<`[`OverloadResponseView`]`<'static>>`: the decoded view and the [`::buffa::bytes::Bytes`] buffer it borrows from travel together, so the handle is `'static` and `Send + Sync` — suitable for async handlers, spawned tasks, and anywhere a `'static` bound is required.

 Field accessors return borrows tied to `&self`. Use [`Self::view`] to get the full [`OverloadResponseView`] when you need struct patterns, iteration helpers, or to pass the view to lifetime-parameterised code.*/
        #[derive(Clone, Debug)]
        pub struct OverloadResponseOwnedView(
            ::buffa::OwnedView<OverloadResponseView<'static>>,
        );
        impl OverloadResponseOwnedView {
            /// Decode an owned view from a [`::buffa::bytes::Bytes`] buffer.
            ///
            /// The view borrows directly from the buffer's data; the buffer is
            /// retained inside the returned handle.
            ///
            /// # Errors
            ///
            /// Returns [`::buffa::DecodeError`] if the buffer contains invalid
            /// protobuf data.
            pub fn decode(
                bytes: ::buffa::bytes::Bytes,
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                ::core::result::Result::Ok(
                    OverloadResponseOwnedView(::buffa::OwnedView::decode(bytes)?),
                )
            }
            /// Decode with custom [`::buffa::DecodeOptions`] (recursion limit,
            /// max message size).
            ///
            /// # Errors
            ///
            /// Returns [`::buffa::DecodeError`] if the buffer is invalid or
            /// exceeds the configured limits.
            pub fn decode_with_options(
                bytes: ::buffa::bytes::Bytes,
                opts: &::buffa::DecodeOptions,
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                ::core::result::Result::Ok(
                    OverloadResponseOwnedView(
                        ::buffa::OwnedView::decode_with_options(bytes, opts)?,
                    ),
                )
            }
            /// Build from an owned message via an encode → decode round-trip.
            ///
            /// # Errors
            ///
            /// Returns [`::buffa::DecodeError`] if the re-encoded bytes are
            /// somehow invalid (should not happen for well-formed messages).
            pub fn from_owned(
                msg: &super::super::OverloadResponse,
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                ::core::result::Result::Ok(
                    OverloadResponseOwnedView(::buffa::OwnedView::from_owned(msg)?),
                )
            }
            /// Borrow the full [`OverloadResponseView`] with its lifetime tied to `&self`.
            #[must_use]
            pub fn view(&self) -> &OverloadResponseView<'_> {
                self.0.reborrow()
            }
            /// Convert to the owned message type.
            ///
            /// # Errors
            ///
            /// Returns an error if re-materializing preserved unknown fields
            /// fails (e.g. the unknown-field limit is exceeded).
            pub fn to_owned_message(
                &self,
            ) -> ::core::result::Result<
                super::super::OverloadResponse,
                ::buffa::DecodeError,
            > {
                self.0.to_owned_message()
            }
            /// The underlying bytes buffer.
            #[must_use]
            pub fn bytes(&self) -> &::buffa::bytes::Bytes {
                self.0.bytes()
            }
            /// Consume the handle, returning the underlying bytes buffer.
            #[must_use]
            pub fn into_bytes(self) -> ::buffa::bytes::Bytes {
                self.0.into_bytes()
            }
            /// Stable machine-readable overload code.
            ///
            /// Field 1: `code`
            #[must_use]
            pub fn code(&self) -> &'_ str {
                self.0.reborrow().code
            }
            /// Client-safe diagnostic detail.
            ///
            /// Field 2: `detail`
            #[must_use]
            pub fn detail(&self) -> &'_ str {
                self.0.reborrow().detail
            }
        }
        impl ::core::convert::From<::buffa::OwnedView<OverloadResponseView<'static>>>
        for OverloadResponseOwnedView {
            fn from(inner: ::buffa::OwnedView<OverloadResponseView<'static>>) -> Self {
                OverloadResponseOwnedView(inner)
            }
        }
        impl ::core::convert::From<OverloadResponseOwnedView>
        for ::buffa::OwnedView<OverloadResponseView<'static>> {
            fn from(wrapper: OverloadResponseOwnedView) -> Self {
                wrapper.0
            }
        }
        impl ::core::convert::AsRef<::buffa::OwnedView<OverloadResponseView<'static>>>
        for OverloadResponseOwnedView {
            fn as_ref(&self) -> &::buffa::OwnedView<OverloadResponseView<'static>> {
                &self.0
            }
        }
        impl ::buffa::HasMessageView for super::super::OverloadResponse {
            type View<'a> = OverloadResponseView<'a>;
            type ViewHandle = OverloadResponseOwnedView;
        }
        impl ::serde::Serialize for OverloadResponseOwnedView {
            fn serialize<__S: ::serde::Serializer>(
                &self,
                __s: __S,
            ) -> ::core::result::Result<__S::Ok, __S::Error> {
                ::serde::Serialize::serialize(&self.0, __s)
            }
        }
        /// TerminalSessionEvent reports a terminal session condition.
        #[derive(Clone, Debug, Default)]
        pub struct TerminalSessionEventView<'a> {
            /// Stable machine-readable terminal code.
            ///
            /// Field 1: `code`
            pub code: &'a str,
            /// Client-safe diagnostic detail.
            ///
            /// Field 2: `detail`
            pub detail: &'a str,
            pub __buffa_unknown_fields: ::buffa::UnknownFieldsView<'a>,
        }
        impl<'a> ::buffa::MessageView<'a> for TerminalSessionEventView<'a> {
            type Owned = super::super::TerminalSessionEvent;
            fn decode_view(
                buf: &'a [u8],
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                let __limit = ::core::cell::Cell::new(
                    ::buffa::DEFAULT_UNKNOWN_FIELD_LIMIT,
                );
                <Self as ::buffa::MessageView>::decode_view_ctx(
                    buf,
                    ::buffa::DecodeContext::new(::buffa::RECURSION_LIMIT, &__limit),
                )
            }
            fn decode_view_with_ctx(
                buf: &'a [u8],
                ctx: ::buffa::DecodeContext<'_>,
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                <Self as ::buffa::MessageView>::decode_view_ctx(buf, ctx)
            }
            fn merge_view_field(
                &mut self,
                tag: ::buffa::encoding::Tag,
                cur: &'a [u8],
                before_tag: &'a [u8],
                ctx: ::buffa::DecodeContext<'_>,
            ) -> ::core::result::Result<&'a [u8], ::buffa::DecodeError> {
                let _ = ctx;
                #[allow(unused_variables)]
                let view = self;
                let mut cur = cur;
                match tag.field_number() {
                    1u32 => {
                        ::buffa::encoding::check_wire_type(
                            tag,
                            ::buffa::encoding::WireType::LengthDelimited,
                        )?;
                        view.code = ::buffa::types::borrow_str(&mut cur)?;
                    }
                    2u32 => {
                        ::buffa::encoding::check_wire_type(
                            tag,
                            ::buffa::encoding::WireType::LengthDelimited,
                        )?;
                        view.detail = ::buffa::types::borrow_str(&mut cur)?;
                    }
                    _ => {
                        ::buffa::encoding::skip_field_depth(tag, &mut cur, ctx.depth())?;
                        let span_len = before_tag.len() - cur.len();
                        view.__buffa_unknown_fields
                            .push_record(before_tag, span_len, ctx)?;
                    }
                }
                ::core::result::Result::Ok(cur)
            }
            fn to_owned_message(
                &self,
            ) -> ::core::result::Result<
                super::super::TerminalSessionEvent,
                ::buffa::DecodeError,
            > {
                self.to_owned_from_source(None)
            }
            #[allow(clippy::useless_conversion, clippy::needless_update)]
            fn to_owned_from_source(
                &self,
                __buffa_src: ::core::option::Option<&::buffa::bytes::Bytes>,
            ) -> ::core::result::Result<
                super::super::TerminalSessionEvent,
                ::buffa::DecodeError,
            > {
                #[allow(unused_imports)]
                use ::buffa::alloc::string::ToString as _;
                let _ = __buffa_src;
                ::core::result::Result::Ok(super::super::TerminalSessionEvent {
                    code: self.code.to_string(),
                    detail: self.detail.to_string(),
                    __buffa_unknown_fields: self
                        .__buffa_unknown_fields
                        .to_owned()?
                        .into(),
                    ..::core::default::Default::default()
                })
            }
        }
        impl<'a> ::buffa::ViewEncode<'a> for TerminalSessionEventView<'a> {
            #[allow(clippy::needless_borrow, clippy::let_and_return)]
            fn compute_size(&self, _cache: &mut ::buffa::SizeCache) -> u32 {
                #[allow(unused_imports)]
                use ::buffa::Enumeration as _;
                let mut size = 0u32;
                if !self.code.is_empty() {
                    size += 1u32 + ::buffa::types::string_encoded_len(&self.code) as u32;
                }
                if !self.detail.is_empty() {
                    size
                        += 1u32
                            + ::buffa::types::string_encoded_len(&self.detail) as u32;
                }
                size += self.__buffa_unknown_fields.encoded_len() as u32;
                size
            }
            #[allow(clippy::needless_borrow)]
            fn write_to(
                &self,
                _cache: &mut ::buffa::SizeCache,
                buf: &mut impl ::buffa::bytes::BufMut,
            ) {
                #[allow(unused_imports)]
                use ::buffa::Enumeration as _;
                if !self.code.is_empty() {
                    ::buffa::types::put_string_field(1u32, &self.code, buf);
                }
                if !self.detail.is_empty() {
                    ::buffa::types::put_string_field(2u32, &self.detail, buf);
                }
                self.__buffa_unknown_fields.write_to(buf);
            }
        }
        /// Serializes this view as protobuf JSON.
        ///
        /// Implicit-presence fields with default values are omitted, `required`
        /// fields are always emitted, explicit-presence (`optional`) fields are
        /// emitted only when set, bytes fields are base64-encoded, and enum
        /// values are their proto name strings.
        ///
        /// This impl uses `serialize_map(None)` because the number of emitted
        /// fields depends on default-omission rules; serializers that require
        /// known map lengths (e.g. `bincode`) will return a runtime error.
        /// Use the owned message type for those formats.
        impl<'__a> ::serde::Serialize for TerminalSessionEventView<'__a> {
            fn serialize<__S: ::serde::Serializer>(
                &self,
                __s: __S,
            ) -> ::core::result::Result<__S::Ok, __S::Error> {
                use ::serde::ser::SerializeMap as _;
                let mut __map = __s.serialize_map(::core::option::Option::None)?;
                if !::buffa::json_helpers::skip_if::is_empty_str(self.code) {
                    __map.serialize_entry("code", self.code)?;
                }
                if !::buffa::json_helpers::skip_if::is_empty_str(self.detail) {
                    __map.serialize_entry("detail", self.detail)?;
                }
                __map.end()
            }
        }
        impl<'a> ::buffa::MessageName for TerminalSessionEventView<'a> {
            const PACKAGE: &'static str = "tradews.v1";
            const NAME: &'static str = "TerminalSessionEvent";
            const FULL_NAME: &'static str = "tradews.v1.TerminalSessionEvent";
            const TYPE_URL: &'static str = "type.googleapis.com/tradews.v1.TerminalSessionEvent";
        }
        ::buffa::impl_default_view_instance!(TerminalSessionEventView);
        ::buffa::impl_view_reborrow!(TerminalSessionEventView);
        /** Self-contained, `'static` owned view of a `TerminalSessionEvent` message.

 Wraps [`::buffa::OwnedView`]`<`[`TerminalSessionEventView`]`<'static>>`: the decoded view and the [`::buffa::bytes::Bytes`] buffer it borrows from travel together, so the handle is `'static` and `Send + Sync` — suitable for async handlers, spawned tasks, and anywhere a `'static` bound is required.

 Field accessors return borrows tied to `&self`. Use [`Self::view`] to get the full [`TerminalSessionEventView`] when you need struct patterns, iteration helpers, or to pass the view to lifetime-parameterised code.*/
        #[derive(Clone, Debug)]
        pub struct TerminalSessionEventOwnedView(
            ::buffa::OwnedView<TerminalSessionEventView<'static>>,
        );
        impl TerminalSessionEventOwnedView {
            /// Decode an owned view from a [`::buffa::bytes::Bytes`] buffer.
            ///
            /// The view borrows directly from the buffer's data; the buffer is
            /// retained inside the returned handle.
            ///
            /// # Errors
            ///
            /// Returns [`::buffa::DecodeError`] if the buffer contains invalid
            /// protobuf data.
            pub fn decode(
                bytes: ::buffa::bytes::Bytes,
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                ::core::result::Result::Ok(
                    TerminalSessionEventOwnedView(::buffa::OwnedView::decode(bytes)?),
                )
            }
            /// Decode with custom [`::buffa::DecodeOptions`] (recursion limit,
            /// max message size).
            ///
            /// # Errors
            ///
            /// Returns [`::buffa::DecodeError`] if the buffer is invalid or
            /// exceeds the configured limits.
            pub fn decode_with_options(
                bytes: ::buffa::bytes::Bytes,
                opts: &::buffa::DecodeOptions,
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                ::core::result::Result::Ok(
                    TerminalSessionEventOwnedView(
                        ::buffa::OwnedView::decode_with_options(bytes, opts)?,
                    ),
                )
            }
            /// Build from an owned message via an encode → decode round-trip.
            ///
            /// # Errors
            ///
            /// Returns [`::buffa::DecodeError`] if the re-encoded bytes are
            /// somehow invalid (should not happen for well-formed messages).
            pub fn from_owned(
                msg: &super::super::TerminalSessionEvent,
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                ::core::result::Result::Ok(
                    TerminalSessionEventOwnedView(::buffa::OwnedView::from_owned(msg)?),
                )
            }
            /// Borrow the full [`TerminalSessionEventView`] with its lifetime tied to `&self`.
            #[must_use]
            pub fn view(&self) -> &TerminalSessionEventView<'_> {
                self.0.reborrow()
            }
            /// Convert to the owned message type.
            ///
            /// # Errors
            ///
            /// Returns an error if re-materializing preserved unknown fields
            /// fails (e.g. the unknown-field limit is exceeded).
            pub fn to_owned_message(
                &self,
            ) -> ::core::result::Result<
                super::super::TerminalSessionEvent,
                ::buffa::DecodeError,
            > {
                self.0.to_owned_message()
            }
            /// The underlying bytes buffer.
            #[must_use]
            pub fn bytes(&self) -> &::buffa::bytes::Bytes {
                self.0.bytes()
            }
            /// Consume the handle, returning the underlying bytes buffer.
            #[must_use]
            pub fn into_bytes(self) -> ::buffa::bytes::Bytes {
                self.0.into_bytes()
            }
            /// Stable machine-readable terminal code.
            ///
            /// Field 1: `code`
            #[must_use]
            pub fn code(&self) -> &'_ str {
                self.0.reborrow().code
            }
            /// Client-safe diagnostic detail.
            ///
            /// Field 2: `detail`
            #[must_use]
            pub fn detail(&self) -> &'_ str {
                self.0.reborrow().detail
            }
        }
        impl ::core::convert::From<::buffa::OwnedView<TerminalSessionEventView<'static>>>
        for TerminalSessionEventOwnedView {
            fn from(
                inner: ::buffa::OwnedView<TerminalSessionEventView<'static>>,
            ) -> Self {
                TerminalSessionEventOwnedView(inner)
            }
        }
        impl ::core::convert::From<TerminalSessionEventOwnedView>
        for ::buffa::OwnedView<TerminalSessionEventView<'static>> {
            fn from(wrapper: TerminalSessionEventOwnedView) -> Self {
                wrapper.0
            }
        }
        impl ::core::convert::AsRef<
            ::buffa::OwnedView<TerminalSessionEventView<'static>>,
        > for TerminalSessionEventOwnedView {
            fn as_ref(&self) -> &::buffa::OwnedView<TerminalSessionEventView<'static>> {
                &self.0
            }
        }
        impl ::buffa::HasMessageView for super::super::TerminalSessionEvent {
            type View<'a> = TerminalSessionEventView<'a>;
            type ViewHandle = TerminalSessionEventOwnedView;
        }
        impl ::serde::Serialize for TerminalSessionEventOwnedView {
            fn serialize<__S: ::serde::Serializer>(
                &self,
                __s: __S,
            ) -> ::core::result::Result<__S::Ok, __S::Error> {
                ::serde::Serialize::serialize(&self.0, __s)
            }
        }
        pub mod oneof {
            #[allow(unused_imports)]
            use super::*;
            pub mod client_frame {
                #[allow(unused_imports)]
                use super::*;
                #[derive(Clone, Debug)]
                pub enum Payload<'a> {
                    Ping(
                        ::buffa::alloc::boxed::Box<
                            super::super::super::super::__buffa::view::PingRequestView<
                                'a,
                            >,
                        >,
                    ),
                    CreateOrder(
                        ::buffa::alloc::boxed::Box<
                            super::super::super::super::super::super::orders::v1::__buffa::view::CreateOrderRequestView<
                                'a,
                            >,
                        >,
                    ),
                    CancelOrder(
                        ::buffa::alloc::boxed::Box<
                            super::super::super::super::super::super::orders::v1::__buffa::view::CancelOrderRequestView<
                                'a,
                            >,
                        >,
                    ),
                    ModifyOrder(
                        ::buffa::alloc::boxed::Box<
                            super::super::super::super::super::super::orders::v1::__buffa::view::ModifyOrderRequestView<
                                'a,
                            >,
                        >,
                    ),
                    CancelAllOrders(
                        ::buffa::alloc::boxed::Box<
                            super::super::super::super::super::super::orders::v1::__buffa::view::CancelAllOrdersRequestView<
                                'a,
                            >,
                        >,
                    ),
                }
            }
            pub mod server_frame {
                #[allow(unused_imports)]
                use super::*;
                #[derive(Clone, Debug)]
                pub enum Payload<'a> {
                    Pong(
                        ::buffa::alloc::boxed::Box<
                            super::super::super::super::__buffa::view::PongResponseView<
                                'a,
                            >,
                        >,
                    ),
                    Ack(
                        ::buffa::alloc::boxed::Box<
                            super::super::super::super::__buffa::view::AckResponseView<
                                'a,
                            >,
                        >,
                    ),
                    Reject(
                        ::buffa::alloc::boxed::Box<
                            super::super::super::super::__buffa::view::CommandRejectView<
                                'a,
                            >,
                        >,
                    ),
                    Overload(
                        ::buffa::alloc::boxed::Box<
                            super::super::super::super::__buffa::view::OverloadResponseView<
                                'a,
                            >,
                        >,
                    ),
                    Terminal(
                        ::buffa::alloc::boxed::Box<
                            super::super::super::super::__buffa::view::TerminalSessionEventView<
                                'a,
                            >,
                        >,
                    ),
                }
            }
            pub mod ack_response {
                #[allow(unused_imports)]
                use super::*;
                #[derive(Clone, Debug)]
                pub enum Result<'a> {
                    CreateOrder(
                        ::buffa::alloc::boxed::Box<
                            super::super::super::super::super::super::orders::v1::__buffa::view::CreateOrderResponseView<
                                'a,
                            >,
                        >,
                    ),
                    CancelOrder(
                        ::buffa::alloc::boxed::Box<
                            super::super::super::super::super::super::orders::v1::__buffa::view::CancelOrderResponseView<
                                'a,
                            >,
                        >,
                    ),
                    ModifyOrder(
                        ::buffa::alloc::boxed::Box<
                            super::super::super::super::super::super::orders::v1::__buffa::view::ModifyOrderResponseView<
                                'a,
                            >,
                        >,
                    ),
                    CancelAllOrders(
                        ::buffa::alloc::boxed::Box<
                            super::super::super::super::super::super::orders::v1::__buffa::view::CancelAllOrdersResponseView<
                                'a,
                            >,
                        >,
                    ),
                }
            }
        }
    }
    pub mod oneof {
        #[allow(unused_imports)]
        use super::*;
        pub mod client_frame {
            #[allow(unused_imports)]
            use super::*;
            #[derive(Clone, PartialEq, Debug)]
            pub enum Payload {
                Ping(::buffa::alloc::boxed::Box<super::super::super::PingRequest>),
                CreateOrder(
                    ::buffa::alloc::boxed::Box<
                        super::super::super::super::super::orders::v1::CreateOrderRequest,
                    >,
                ),
                CancelOrder(
                    ::buffa::alloc::boxed::Box<
                        super::super::super::super::super::orders::v1::CancelOrderRequest,
                    >,
                ),
                ModifyOrder(
                    ::buffa::alloc::boxed::Box<
                        super::super::super::super::super::orders::v1::ModifyOrderRequest,
                    >,
                ),
                CancelAllOrders(
                    ::buffa::alloc::boxed::Box<
                        super::super::super::super::super::orders::v1::CancelAllOrdersRequest,
                    >,
                ),
            }
            impl ::buffa::Oneof for Payload {}
            impl From<super::super::super::PingRequest> for Payload {
                fn from(v: super::super::super::PingRequest) -> Self {
                    Self::Ping(::buffa::alloc::boxed::Box::new(v))
                }
            }
            impl From<super::super::super::PingRequest>
            for ::core::option::Option<Payload> {
                fn from(v: super::super::super::PingRequest) -> Self {
                    Self::Some(Payload::from(v))
                }
            }
            impl From<super::super::super::super::super::orders::v1::CreateOrderRequest>
            for Payload {
                fn from(
                    v: super::super::super::super::super::orders::v1::CreateOrderRequest,
                ) -> Self {
                    Self::CreateOrder(::buffa::alloc::boxed::Box::new(v))
                }
            }
            impl From<super::super::super::super::super::orders::v1::CreateOrderRequest>
            for ::core::option::Option<Payload> {
                fn from(
                    v: super::super::super::super::super::orders::v1::CreateOrderRequest,
                ) -> Self {
                    Self::Some(Payload::from(v))
                }
            }
            impl From<super::super::super::super::super::orders::v1::CancelOrderRequest>
            for Payload {
                fn from(
                    v: super::super::super::super::super::orders::v1::CancelOrderRequest,
                ) -> Self {
                    Self::CancelOrder(::buffa::alloc::boxed::Box::new(v))
                }
            }
            impl From<super::super::super::super::super::orders::v1::CancelOrderRequest>
            for ::core::option::Option<Payload> {
                fn from(
                    v: super::super::super::super::super::orders::v1::CancelOrderRequest,
                ) -> Self {
                    Self::Some(Payload::from(v))
                }
            }
            impl From<super::super::super::super::super::orders::v1::ModifyOrderRequest>
            for Payload {
                fn from(
                    v: super::super::super::super::super::orders::v1::ModifyOrderRequest,
                ) -> Self {
                    Self::ModifyOrder(::buffa::alloc::boxed::Box::new(v))
                }
            }
            impl From<super::super::super::super::super::orders::v1::ModifyOrderRequest>
            for ::core::option::Option<Payload> {
                fn from(
                    v: super::super::super::super::super::orders::v1::ModifyOrderRequest,
                ) -> Self {
                    Self::Some(Payload::from(v))
                }
            }
            impl From<
                super::super::super::super::super::orders::v1::CancelAllOrdersRequest,
            > for Payload {
                fn from(
                    v: super::super::super::super::super::orders::v1::CancelAllOrdersRequest,
                ) -> Self {
                    Self::CancelAllOrders(::buffa::alloc::boxed::Box::new(v))
                }
            }
            impl From<
                super::super::super::super::super::orders::v1::CancelAllOrdersRequest,
            > for ::core::option::Option<Payload> {
                fn from(
                    v: super::super::super::super::super::orders::v1::CancelAllOrdersRequest,
                ) -> Self {
                    Self::Some(Payload::from(v))
                }
            }
            impl serde::Serialize for Payload {
                fn serialize<S: serde::Serializer>(
                    &self,
                    s: S,
                ) -> ::core::result::Result<S::Ok, S::Error> {
                    use serde::ser::SerializeMap;
                    let mut map = s.serialize_map(Some(1))?;
                    match self {
                        Self::Ping(v) => {
                            map.serialize_entry("ping", v)?;
                        }
                        Self::CreateOrder(v) => {
                            map.serialize_entry("createOrder", v)?;
                        }
                        Self::CancelOrder(v) => {
                            map.serialize_entry("cancelOrder", v)?;
                        }
                        Self::ModifyOrder(v) => {
                            map.serialize_entry("modifyOrder", v)?;
                        }
                        Self::CancelAllOrders(v) => {
                            map.serialize_entry("cancelAllOrders", v)?;
                        }
                    }
                    map.end()
                }
            }
        }
        pub mod server_frame {
            #[allow(unused_imports)]
            use super::*;
            #[derive(Clone, PartialEq, Debug)]
            pub enum Payload {
                Pong(::buffa::alloc::boxed::Box<super::super::super::PongResponse>),
                Ack(::buffa::alloc::boxed::Box<super::super::super::AckResponse>),
                Reject(::buffa::alloc::boxed::Box<super::super::super::CommandReject>),
                Overload(
                    ::buffa::alloc::boxed::Box<super::super::super::OverloadResponse>,
                ),
                Terminal(
                    ::buffa::alloc::boxed::Box<super::super::super::TerminalSessionEvent>,
                ),
            }
            impl ::buffa::Oneof for Payload {}
            impl From<super::super::super::PongResponse> for Payload {
                fn from(v: super::super::super::PongResponse) -> Self {
                    Self::Pong(::buffa::alloc::boxed::Box::new(v))
                }
            }
            impl From<super::super::super::PongResponse>
            for ::core::option::Option<Payload> {
                fn from(v: super::super::super::PongResponse) -> Self {
                    Self::Some(Payload::from(v))
                }
            }
            impl From<super::super::super::AckResponse> for Payload {
                fn from(v: super::super::super::AckResponse) -> Self {
                    Self::Ack(::buffa::alloc::boxed::Box::new(v))
                }
            }
            impl From<super::super::super::AckResponse>
            for ::core::option::Option<Payload> {
                fn from(v: super::super::super::AckResponse) -> Self {
                    Self::Some(Payload::from(v))
                }
            }
            impl From<super::super::super::CommandReject> for Payload {
                fn from(v: super::super::super::CommandReject) -> Self {
                    Self::Reject(::buffa::alloc::boxed::Box::new(v))
                }
            }
            impl From<super::super::super::CommandReject>
            for ::core::option::Option<Payload> {
                fn from(v: super::super::super::CommandReject) -> Self {
                    Self::Some(Payload::from(v))
                }
            }
            impl From<super::super::super::OverloadResponse> for Payload {
                fn from(v: super::super::super::OverloadResponse) -> Self {
                    Self::Overload(::buffa::alloc::boxed::Box::new(v))
                }
            }
            impl From<super::super::super::OverloadResponse>
            for ::core::option::Option<Payload> {
                fn from(v: super::super::super::OverloadResponse) -> Self {
                    Self::Some(Payload::from(v))
                }
            }
            impl From<super::super::super::TerminalSessionEvent> for Payload {
                fn from(v: super::super::super::TerminalSessionEvent) -> Self {
                    Self::Terminal(::buffa::alloc::boxed::Box::new(v))
                }
            }
            impl From<super::super::super::TerminalSessionEvent>
            for ::core::option::Option<Payload> {
                fn from(v: super::super::super::TerminalSessionEvent) -> Self {
                    Self::Some(Payload::from(v))
                }
            }
            impl serde::Serialize for Payload {
                fn serialize<S: serde::Serializer>(
                    &self,
                    s: S,
                ) -> ::core::result::Result<S::Ok, S::Error> {
                    use serde::ser::SerializeMap;
                    let mut map = s.serialize_map(Some(1))?;
                    match self {
                        Self::Pong(v) => {
                            map.serialize_entry("pong", v)?;
                        }
                        Self::Ack(v) => {
                            map.serialize_entry("ack", v)?;
                        }
                        Self::Reject(v) => {
                            map.serialize_entry("reject", v)?;
                        }
                        Self::Overload(v) => {
                            map.serialize_entry("overload", v)?;
                        }
                        Self::Terminal(v) => {
                            map.serialize_entry("terminal", v)?;
                        }
                    }
                    map.end()
                }
            }
        }
        pub mod ack_response {
            #[allow(unused_imports)]
            use super::*;
            #[derive(Clone, PartialEq, Debug)]
            pub enum Result {
                CreateOrder(
                    ::buffa::alloc::boxed::Box<
                        super::super::super::super::super::orders::v1::CreateOrderResponse,
                    >,
                ),
                CancelOrder(
                    ::buffa::alloc::boxed::Box<
                        super::super::super::super::super::orders::v1::CancelOrderResponse,
                    >,
                ),
                ModifyOrder(
                    ::buffa::alloc::boxed::Box<
                        super::super::super::super::super::orders::v1::ModifyOrderResponse,
                    >,
                ),
                CancelAllOrders(
                    ::buffa::alloc::boxed::Box<
                        super::super::super::super::super::orders::v1::CancelAllOrdersResponse,
                    >,
                ),
            }
            impl ::buffa::Oneof for Result {}
            impl From<super::super::super::super::super::orders::v1::CreateOrderResponse>
            for Result {
                fn from(
                    v: super::super::super::super::super::orders::v1::CreateOrderResponse,
                ) -> Self {
                    Self::CreateOrder(::buffa::alloc::boxed::Box::new(v))
                }
            }
            impl From<super::super::super::super::super::orders::v1::CreateOrderResponse>
            for ::core::option::Option<Result> {
                fn from(
                    v: super::super::super::super::super::orders::v1::CreateOrderResponse,
                ) -> Self {
                    Self::Some(Result::from(v))
                }
            }
            impl From<super::super::super::super::super::orders::v1::CancelOrderResponse>
            for Result {
                fn from(
                    v: super::super::super::super::super::orders::v1::CancelOrderResponse,
                ) -> Self {
                    Self::CancelOrder(::buffa::alloc::boxed::Box::new(v))
                }
            }
            impl From<super::super::super::super::super::orders::v1::CancelOrderResponse>
            for ::core::option::Option<Result> {
                fn from(
                    v: super::super::super::super::super::orders::v1::CancelOrderResponse,
                ) -> Self {
                    Self::Some(Result::from(v))
                }
            }
            impl From<super::super::super::super::super::orders::v1::ModifyOrderResponse>
            for Result {
                fn from(
                    v: super::super::super::super::super::orders::v1::ModifyOrderResponse,
                ) -> Self {
                    Self::ModifyOrder(::buffa::alloc::boxed::Box::new(v))
                }
            }
            impl From<super::super::super::super::super::orders::v1::ModifyOrderResponse>
            for ::core::option::Option<Result> {
                fn from(
                    v: super::super::super::super::super::orders::v1::ModifyOrderResponse,
                ) -> Self {
                    Self::Some(Result::from(v))
                }
            }
            impl From<
                super::super::super::super::super::orders::v1::CancelAllOrdersResponse,
            > for Result {
                fn from(
                    v: super::super::super::super::super::orders::v1::CancelAllOrdersResponse,
                ) -> Self {
                    Self::CancelAllOrders(::buffa::alloc::boxed::Box::new(v))
                }
            }
            impl From<
                super::super::super::super::super::orders::v1::CancelAllOrdersResponse,
            > for ::core::option::Option<Result> {
                fn from(
                    v: super::super::super::super::super::orders::v1::CancelAllOrdersResponse,
                ) -> Self {
                    Self::Some(Result::from(v))
                }
            }
            impl serde::Serialize for Result {
                fn serialize<S: serde::Serializer>(
                    &self,
                    s: S,
                ) -> ::core::result::Result<S::Ok, S::Error> {
                    use serde::ser::SerializeMap;
                    let mut map = s.serialize_map(Some(1))?;
                    match self {
                        Self::CreateOrder(v) => {
                            map.serialize_entry("createOrder", v)?;
                        }
                        Self::CancelOrder(v) => {
                            map.serialize_entry("cancelOrder", v)?;
                        }
                        Self::ModifyOrder(v) => {
                            map.serialize_entry("modifyOrder", v)?;
                        }
                        Self::CancelAllOrders(v) => {
                            map.serialize_entry("cancelAllOrders", v)?;
                        }
                    }
                    map.end()
                }
            }
        }
    }
    /// Register this package's `Any` type entries and extension entries.
    pub fn register_types(reg: &mut ::buffa::type_registry::TypeRegistry) {
        reg.register_json_any(super::__CLIENT_FRAME_JSON_ANY);
        reg.register_json_any(super::__PING_REQUEST_JSON_ANY);
        reg.register_json_any(super::__SERVER_FRAME_JSON_ANY);
        reg.register_json_any(super::__PONG_RESPONSE_JSON_ANY);
        reg.register_json_any(super::__ACK_RESPONSE_JSON_ANY);
        reg.register_json_any(super::__COMMAND_REJECT_JSON_ANY);
        reg.register_json_any(super::__OVERLOAD_RESPONSE_JSON_ANY);
        reg.register_json_any(super::__TERMINAL_SESSION_EVENT_JSON_ANY);
    }
}
#[doc(inline)]
pub use self::__buffa::view::ClientFrameView;
#[doc(inline)]
pub use self::__buffa::view::ClientFrameOwnedView;
#[doc(inline)]
pub use self::__buffa::view::PingRequestView;
#[doc(inline)]
pub use self::__buffa::view::PingRequestOwnedView;
#[doc(inline)]
pub use self::__buffa::view::ServerFrameView;
#[doc(inline)]
pub use self::__buffa::view::ServerFrameOwnedView;
#[doc(inline)]
pub use self::__buffa::view::PongResponseView;
#[doc(inline)]
pub use self::__buffa::view::PongResponseOwnedView;
#[doc(inline)]
pub use self::__buffa::view::AckResponseView;
#[doc(inline)]
pub use self::__buffa::view::AckResponseOwnedView;
#[doc(inline)]
pub use self::__buffa::view::CommandRejectView;
#[doc(inline)]
pub use self::__buffa::view::CommandRejectOwnedView;
#[doc(inline)]
pub use self::__buffa::view::OverloadResponseView;
#[doc(inline)]
pub use self::__buffa::view::OverloadResponseOwnedView;
#[doc(inline)]
pub use self::__buffa::view::TerminalSessionEventView;
#[doc(inline)]
pub use self::__buffa::view::TerminalSessionEventOwnedView;
#[doc(inline)]
pub use self::__buffa::register_types;