polyester/gen/buffa/

orderbook.v1.rs

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

/// Depth specifies the number of price levels per side.
#[derive(Clone, Copy, PartialEq, Eq, Hash, Debug)]
#[repr(i32)]
pub enum Depth {
    /// Default depth (50 levels per side).
    DEPTH_UNSPECIFIED = 0i32,
    /// 1 level per side (top of book / best bid-ask).
    DEPTH_1 = 1i32,
    /// 5 levels per side.
    DEPTH_5 = 2i32,
    /// 10 levels per side.
    DEPTH_10 = 3i32,
    /// 20 levels per side.
    DEPTH_20 = 4i32,
    /// 50 levels per side.
    DEPTH_50 = 5i32,
    /// 100 levels per side.
    DEPTH_100 = 6i32,
    /// 200 levels per side.
    DEPTH_200 = 7i32,
    /// 500 levels per side.
    DEPTH_500 = 8i32,
    /// 1000 levels per side.
    DEPTH_1000 = 9i32,
}
impl Depth {
    ///Idiomatic alias for [`Self::DEPTH_UNSPECIFIED`]; `Debug` prints the variant name.
    #[allow(non_upper_case_globals)]
    pub const DepthUnspecified: Self = Self::DEPTH_UNSPECIFIED;
    ///Idiomatic alias for [`Self::DEPTH_1`]; `Debug` prints the variant name.
    #[allow(non_upper_case_globals)]
    pub const Depth1: Self = Self::DEPTH_1;
    ///Idiomatic alias for [`Self::DEPTH_5`]; `Debug` prints the variant name.
    #[allow(non_upper_case_globals)]
    pub const Depth5: Self = Self::DEPTH_5;
    ///Idiomatic alias for [`Self::DEPTH_10`]; `Debug` prints the variant name.
    #[allow(non_upper_case_globals)]
    pub const Depth10: Self = Self::DEPTH_10;
    ///Idiomatic alias for [`Self::DEPTH_20`]; `Debug` prints the variant name.
    #[allow(non_upper_case_globals)]
    pub const Depth20: Self = Self::DEPTH_20;
    ///Idiomatic alias for [`Self::DEPTH_50`]; `Debug` prints the variant name.
    #[allow(non_upper_case_globals)]
    pub const Depth50: Self = Self::DEPTH_50;
    ///Idiomatic alias for [`Self::DEPTH_100`]; `Debug` prints the variant name.
    #[allow(non_upper_case_globals)]
    pub const Depth100: Self = Self::DEPTH_100;
    ///Idiomatic alias for [`Self::DEPTH_200`]; `Debug` prints the variant name.
    #[allow(non_upper_case_globals)]
    pub const Depth200: Self = Self::DEPTH_200;
    ///Idiomatic alias for [`Self::DEPTH_500`]; `Debug` prints the variant name.
    #[allow(non_upper_case_globals)]
    pub const Depth500: Self = Self::DEPTH_500;
    ///Idiomatic alias for [`Self::DEPTH_1000`]; `Debug` prints the variant name.
    #[allow(non_upper_case_globals)]
    pub const Depth1000: Self = Self::DEPTH_1000;
}
impl ::core::default::Default for Depth {
    fn default() -> Self {
        Self::DEPTH_UNSPECIFIED
    }
}
impl ::serde::Serialize for Depth {
    fn serialize<S: ::serde::Serializer>(
        &self,
        s: S,
    ) -> ::core::result::Result<S::Ok, S::Error> {
        s.serialize_str(::buffa::Enumeration::proto_name(self))
    }
}
impl<'de> ::serde::Deserialize<'de> for Depth {
    fn deserialize<D: ::serde::Deserializer<'de>>(
        d: D,
    ) -> ::core::result::Result<Self, D::Error> {
        struct _V;
        impl ::serde::de::Visitor<'_> for _V {
            type Value = Depth;
            fn expecting(
                &self,
                f: &mut ::core::fmt::Formatter<'_>,
            ) -> ::core::fmt::Result {
                f.write_str(
                    concat!("a string, integer, or null for ", stringify!(Depth)),
                )
            }
            fn visit_str<E: ::serde::de::Error>(
                self,
                v: &str,
            ) -> ::core::result::Result<Depth, E> {
                <Depth as ::buffa::Enumeration>::from_proto_name(v)
                    .ok_or_else(|| { ::serde::de::Error::unknown_variant(v, &[]) })
            }
            fn visit_i64<E: ::serde::de::Error>(
                self,
                v: i64,
            ) -> ::core::result::Result<Depth, E> {
                let v32 = i32::try_from(v)
                    .map_err(|_| {
                        ::serde::de::Error::custom(
                            ::buffa::alloc::format!("enum value {v} out of i32 range"),
                        )
                    })?;
                <Depth as ::buffa::Enumeration>::from_i32(v32)
                    .ok_or_else(|| {
                        ::serde::de::Error::custom(
                            ::buffa::alloc::format!("unknown enum value {v32}"),
                        )
                    })
            }
            fn visit_u64<E: ::serde::de::Error>(
                self,
                v: u64,
            ) -> ::core::result::Result<Depth, E> {
                let v32 = i32::try_from(v)
                    .map_err(|_| {
                        ::serde::de::Error::custom(
                            ::buffa::alloc::format!("enum value {v} out of i32 range"),
                        )
                    })?;
                <Depth as ::buffa::Enumeration>::from_i32(v32)
                    .ok_or_else(|| {
                        ::serde::de::Error::custom(
                            ::buffa::alloc::format!("unknown enum value {v32}"),
                        )
                    })
            }
            fn visit_unit<E: ::serde::de::Error>(
                self,
            ) -> ::core::result::Result<Depth, E> {
                ::core::result::Result::Ok(::core::default::Default::default())
            }
        }
        d.deserialize_any(_V)
    }
}
impl ::buffa::json_helpers::ProtoElemJson for Depth {
    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)
    }
}
impl ::buffa::Enumeration for Depth {
    fn from_i32(value: i32) -> ::core::option::Option<Self> {
        match value {
            0i32 => ::core::option::Option::Some(Self::DEPTH_UNSPECIFIED),
            1i32 => ::core::option::Option::Some(Self::DEPTH_1),
            2i32 => ::core::option::Option::Some(Self::DEPTH_5),
            3i32 => ::core::option::Option::Some(Self::DEPTH_10),
            4i32 => ::core::option::Option::Some(Self::DEPTH_20),
            5i32 => ::core::option::Option::Some(Self::DEPTH_50),
            6i32 => ::core::option::Option::Some(Self::DEPTH_100),
            7i32 => ::core::option::Option::Some(Self::DEPTH_200),
            8i32 => ::core::option::Option::Some(Self::DEPTH_500),
            9i32 => ::core::option::Option::Some(Self::DEPTH_1000),
            _ => ::core::option::Option::None,
        }
    }
    fn to_i32(&self) -> i32 {
        *self as i32
    }
    fn proto_name(&self) -> &'static str {
        match self {
            Self::DEPTH_UNSPECIFIED => "DEPTH_UNSPECIFIED",
            Self::DEPTH_1 => "DEPTH_1",
            Self::DEPTH_5 => "DEPTH_5",
            Self::DEPTH_10 => "DEPTH_10",
            Self::DEPTH_20 => "DEPTH_20",
            Self::DEPTH_50 => "DEPTH_50",
            Self::DEPTH_100 => "DEPTH_100",
            Self::DEPTH_200 => "DEPTH_200",
            Self::DEPTH_500 => "DEPTH_500",
            Self::DEPTH_1000 => "DEPTH_1000",
        }
    }
    fn from_proto_name(name: &str) -> ::core::option::Option<Self> {
        match name {
            "DEPTH_UNSPECIFIED" => ::core::option::Option::Some(Self::DEPTH_UNSPECIFIED),
            "DEPTH_1" => ::core::option::Option::Some(Self::DEPTH_1),
            "DEPTH_5" => ::core::option::Option::Some(Self::DEPTH_5),
            "DEPTH_10" => ::core::option::Option::Some(Self::DEPTH_10),
            "DEPTH_20" => ::core::option::Option::Some(Self::DEPTH_20),
            "DEPTH_50" => ::core::option::Option::Some(Self::DEPTH_50),
            "DEPTH_100" => ::core::option::Option::Some(Self::DEPTH_100),
            "DEPTH_200" => ::core::option::Option::Some(Self::DEPTH_200),
            "DEPTH_500" => ::core::option::Option::Some(Self::DEPTH_500),
            "DEPTH_1000" => ::core::option::Option::Some(Self::DEPTH_1000),
            _ => ::core::option::Option::None,
        }
    }
    fn values() -> &'static [Self] {
        &[
            Self::DEPTH_UNSPECIFIED,
            Self::DEPTH_1,
            Self::DEPTH_5,
            Self::DEPTH_10,
            Self::DEPTH_20,
            Self::DEPTH_50,
            Self::DEPTH_100,
            Self::DEPTH_200,
            Self::DEPTH_500,
            Self::DEPTH_1000,
        ]
    }
}
/// GetOrderBookRequest describes a snapshot view request.
#[derive(Clone, PartialEq, Default)]
#[derive(::serde::Serialize, ::serde::Deserialize)]
#[serde(default)]
pub struct GetOrderBookRequest {
    /// e.g. "BTC-USDT"; resolved to symbol_id server-side.
    ///
    /// Field 1: `symbol`
    #[serde(
        rename = "symbol",
        with = "::buffa::json_helpers::proto_string",
        skip_serializing_if = "::buffa::json_helpers::skip_if::is_empty_str"
    )]
    pub symbol: ::buffa::alloc::string::String,
    /// Requested depth per side (number of price levels). Default is 50.
    ///
    /// Field 2: `depth`
    #[serde(
        rename = "depth",
        with = "::buffa::json_helpers::proto_enum",
        skip_serializing_if = "::buffa::json_helpers::skip_if::is_default_enum_value"
    )]
    pub depth: ::buffa::EnumValue<Depth>,
    #[serde(skip)]
    #[doc(hidden)]
    pub __buffa_unknown_fields: ::buffa::UnknownFields,
}
impl ::core::fmt::Debug for GetOrderBookRequest {
    fn fmt(&self, f: &mut ::core::fmt::Formatter<'_>) -> ::core::fmt::Result {
        f.debug_struct("GetOrderBookRequest")
            .field("symbol", &self.symbol)
            .field("depth", &self.depth)
            .finish()
    }
}
impl GetOrderBookRequest {
    /// 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/orderbook.v1.GetOrderBookRequest";
}
::buffa::impl_default_instance!(GetOrderBookRequest);
impl ::buffa::MessageName for GetOrderBookRequest {
    const PACKAGE: &'static str = "orderbook.v1";
    const NAME: &'static str = "GetOrderBookRequest";
    const FULL_NAME: &'static str = "orderbook.v1.GetOrderBookRequest";
    const TYPE_URL: &'static str = "type.googleapis.com/orderbook.v1.GetOrderBookRequest";
}
impl ::buffa::Message for GetOrderBookRequest {
    /// 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.symbol.is_empty() {
            size += 1u32 + ::buffa::types::string_encoded_len(&self.symbol) as u32;
        }
        {
            let val = self.depth.to_i32();
            if val != 0 {
                size += 1u32 + ::buffa::types::int32_encoded_len(val) 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.symbol.is_empty() {
            ::buffa::types::put_string_field(1u32, &self.symbol, buf);
        }
        {
            let val = self.depth.to_i32();
            if val != 0 {
                ::buffa::types::put_int32_field(2u32, val, 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.symbol, buf)?;
            }
            2u32 => {
                ::buffa::encoding::check_wire_type(
                    tag,
                    ::buffa::encoding::WireType::Varint,
                )?;
                self.depth = ::buffa::EnumValue::from(
                    ::buffa::types::decode_int32(buf)?,
                );
            }
            _ => {
                self.__buffa_unknown_fields
                    .push(::buffa::encoding::decode_unknown_field(tag, buf, ctx)?);
            }
        }
        ::core::result::Result::Ok(())
    }
    fn clear(&mut self) {
        self.symbol.clear();
        self.depth = ::buffa::EnumValue::from(0);
        self.__buffa_unknown_fields.clear();
    }
}
impl ::buffa::ExtensionSet for GetOrderBookRequest {
    const PROTO_FQN: &'static str = "orderbook.v1.GetOrderBookRequest";
    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 GetOrderBookRequest {
    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 __GET_ORDER_BOOK_REQUEST_JSON_ANY: ::buffa::type_registry::JsonAnyEntry = ::buffa::type_registry::JsonAnyEntry {
    type_url: "type.googleapis.com/orderbook.v1.GetOrderBookRequest",
    to_json: ::buffa::type_registry::any_to_json::<GetOrderBookRequest>,
    from_json: ::buffa::type_registry::any_from_json::<GetOrderBookRequest>,
    is_wkt: false,
};
/// PriceLevel uses scaled integers for the binary (protobuf) API (low-latency).
/// REST surfaces expose decimal strings via DTO conversion.
#[derive(Clone, PartialEq, Default)]
#[derive(::serde::Serialize, ::serde::Deserialize)]
#[serde(default)]
pub struct PriceLevel {
    /// Price in quote units scaled by 1e6.
    ///
    /// Field 1: `price_ticks`
    #[serde(
        rename = "priceTicks",
        alias = "price_ticks",
        with = "::buffa::json_helpers::int64",
        skip_serializing_if = "::buffa::json_helpers::skip_if::is_zero_i64"
    )]
    pub price_ticks: i64,
    /// Quantity scaled by the pair's base_quantity_scale from GetSpotConfig.
    ///
    /// Field 2: `qty_scaled`
    #[serde(
        rename = "qtyScaled",
        alias = "qty_scaled",
        with = "::buffa::json_helpers::int64",
        skip_serializing_if = "::buffa::json_helpers::skip_if::is_zero_i64"
    )]
    pub qty_scaled: i64,
    #[serde(skip)]
    #[doc(hidden)]
    pub __buffa_unknown_fields: ::buffa::UnknownFields,
}
impl ::core::fmt::Debug for PriceLevel {
    fn fmt(&self, f: &mut ::core::fmt::Formatter<'_>) -> ::core::fmt::Result {
        f.debug_struct("PriceLevel")
            .field("price_ticks", &self.price_ticks)
            .field("qty_scaled", &self.qty_scaled)
            .finish()
    }
}
impl PriceLevel {
    /// 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/orderbook.v1.PriceLevel";
}
::buffa::impl_default_instance!(PriceLevel);
impl ::buffa::MessageName for PriceLevel {
    const PACKAGE: &'static str = "orderbook.v1";
    const NAME: &'static str = "PriceLevel";
    const FULL_NAME: &'static str = "orderbook.v1.PriceLevel";
    const TYPE_URL: &'static str = "type.googleapis.com/orderbook.v1.PriceLevel";
}
impl ::buffa::Message for PriceLevel {
    /// 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.price_ticks != 0i64 {
            size += 1u32 + ::buffa::types::int64_encoded_len(self.price_ticks) as u32;
        }
        if self.qty_scaled != 0i64 {
            size += 1u32 + ::buffa::types::int64_encoded_len(self.qty_scaled) 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.price_ticks != 0i64 {
            ::buffa::types::put_int64_field(1u32, self.price_ticks, buf);
        }
        if self.qty_scaled != 0i64 {
            ::buffa::types::put_int64_field(2u32, self.qty_scaled, 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.price_ticks = ::buffa::types::decode_int64(buf)?;
            }
            2u32 => {
                ::buffa::encoding::check_wire_type(
                    tag,
                    ::buffa::encoding::WireType::Varint,
                )?;
                self.qty_scaled = ::buffa::types::decode_int64(buf)?;
            }
            _ => {
                self.__buffa_unknown_fields
                    .push(::buffa::encoding::decode_unknown_field(tag, buf, ctx)?);
            }
        }
        ::core::result::Result::Ok(())
    }
    fn clear(&mut self) {
        self.price_ticks = 0i64;
        self.qty_scaled = 0i64;
        self.__buffa_unknown_fields.clear();
    }
}
impl ::buffa::ExtensionSet for PriceLevel {
    const PROTO_FQN: &'static str = "orderbook.v1.PriceLevel";
    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 PriceLevel {
    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 __PRICE_LEVEL_JSON_ANY: ::buffa::type_registry::JsonAnyEntry = ::buffa::type_registry::JsonAnyEntry {
    type_url: "type.googleapis.com/orderbook.v1.PriceLevel",
    to_json: ::buffa::type_registry::any_to_json::<PriceLevel>,
    from_json: ::buffa::type_registry::any_from_json::<PriceLevel>,
    is_wkt: false,
};
/// GetOrderBookResponse is a depth snapshot for the binary (protobuf) API (scaled integers).
/// REST surfaces expose decimal strings via DTO conversion.
#[derive(Clone, PartialEq, Default)]
#[derive(::serde::Serialize, ::serde::Deserialize)]
#[serde(default)]
pub struct GetOrderBookResponse {
    /// Numeric symbol identifier (client resolves to symbol string).
    ///
    /// Field 1: `symbol_id`
    #[serde(
        rename = "symbolId",
        alias = "symbol_id",
        with = "::buffa::json_helpers::uint32",
        skip_serializing_if = "::buffa::json_helpers::skip_if::is_zero_u32"
    )]
    pub symbol_id: u32,
    /// Monotonic book sequence for this symbol.
    ///
    /// Field 2: `book_seq`
    #[serde(
        rename = "bookSeq",
        alias = "book_seq",
        with = "::buffa::json_helpers::uint64",
        skip_serializing_if = "::buffa::json_helpers::skip_if::is_zero_u64"
    )]
    pub book_seq: u64,
    /// Best bid first; descending price.
    ///
    /// Field 3: `bids`
    #[serde(
        rename = "bids",
        skip_serializing_if = "::buffa::json_helpers::skip_if::is_empty_vec",
        deserialize_with = "::buffa::json_helpers::null_as_default"
    )]
    pub bids: ::buffa::alloc::vec::Vec<PriceLevel>,
    /// Best ask first; ascending price.
    ///
    /// Field 4: `asks`
    #[serde(
        rename = "asks",
        skip_serializing_if = "::buffa::json_helpers::skip_if::is_empty_vec",
        deserialize_with = "::buffa::json_helpers::null_as_default"
    )]
    pub asks: ::buffa::alloc::vec::Vec<PriceLevel>,
    /// Timestamp associated with this snapshot (best-effort).
    ///
    /// Field 5: `ts`
    #[serde(
        rename = "ts",
        skip_serializing_if = "::buffa::json_helpers::skip_if::is_unset_message_field"
    )]
    pub ts: ::buffa::MessageField<::buffa_types::google::protobuf::Timestamp>,
    #[serde(skip)]
    #[doc(hidden)]
    pub __buffa_unknown_fields: ::buffa::UnknownFields,
}
impl ::core::fmt::Debug for GetOrderBookResponse {
    fn fmt(&self, f: &mut ::core::fmt::Formatter<'_>) -> ::core::fmt::Result {
        f.debug_struct("GetOrderBookResponse")
            .field("symbol_id", &self.symbol_id)
            .field("book_seq", &self.book_seq)
            .field("bids", &self.bids)
            .field("asks", &self.asks)
            .field("ts", &self.ts)
            .finish()
    }
}
impl GetOrderBookResponse {
    /// 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/orderbook.v1.GetOrderBookResponse";
}
::buffa::impl_default_instance!(GetOrderBookResponse);
impl ::buffa::MessageName for GetOrderBookResponse {
    const PACKAGE: &'static str = "orderbook.v1";
    const NAME: &'static str = "GetOrderBookResponse";
    const FULL_NAME: &'static str = "orderbook.v1.GetOrderBookResponse";
    const TYPE_URL: &'static str = "type.googleapis.com/orderbook.v1.GetOrderBookResponse";
}
impl ::buffa::Message for GetOrderBookResponse {
    /// 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.symbol_id != 0u32 {
            size += 1u32 + ::buffa::types::uint32_encoded_len(self.symbol_id) as u32;
        }
        if self.book_seq != 0u64 {
            size += 1u32 + ::buffa::types::uint64_encoded_len(self.book_seq) as u32;
        }
        for v in &self.bids {
            let __slot = __cache.reserve();
            let inner_size = v.compute_size(__cache);
            __cache.set(__slot, inner_size);
            size
                += 1u32 + ::buffa::encoding::varint_len(inner_size as u64) as u32
                    + inner_size;
        }
        for v in &self.asks {
            let __slot = __cache.reserve();
            let inner_size = v.compute_size(__cache);
            __cache.set(__slot, inner_size);
            size
                += 1u32 + ::buffa::encoding::varint_len(inner_size as u64) as u32
                    + inner_size;
        }
        if self.ts.is_set() {
            let __slot = __cache.reserve();
            let inner_size = self.ts.compute_size(__cache);
            __cache.set(__slot, inner_size);
            size
                += 1u32 + ::buffa::encoding::varint_len(inner_size as u64) as u32
                    + inner_size;
        }
        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.symbol_id != 0u32 {
            ::buffa::types::put_uint32_field(1u32, self.symbol_id, buf);
        }
        if self.book_seq != 0u64 {
            ::buffa::types::put_uint64_field(2u32, self.book_seq, buf);
        }
        for v in &self.bids {
            ::buffa::types::put_len_delimited_header(3u32, __cache.consume_next(), buf);
            v.write_to(__cache, buf);
        }
        for v in &self.asks {
            ::buffa::types::put_len_delimited_header(4u32, __cache.consume_next(), buf);
            v.write_to(__cache, buf);
        }
        if self.ts.is_set() {
            ::buffa::types::put_len_delimited_header(5u32, __cache.consume_next(), buf);
            self.ts.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.symbol_id = ::buffa::types::decode_uint32(buf)?;
            }
            2u32 => {
                ::buffa::encoding::check_wire_type(
                    tag,
                    ::buffa::encoding::WireType::Varint,
                )?;
                self.book_seq = ::buffa::types::decode_uint64(buf)?;
            }
            3u32 => {
                ::buffa::encoding::check_wire_type(
                    tag,
                    ::buffa::encoding::WireType::LengthDelimited,
                )?;
                let mut elem = ::core::default::Default::default();
                ::buffa::Message::merge_length_delimited(&mut elem, buf, ctx)?;
                self.bids.push(elem);
            }
            4u32 => {
                ::buffa::encoding::check_wire_type(
                    tag,
                    ::buffa::encoding::WireType::LengthDelimited,
                )?;
                let mut elem = ::core::default::Default::default();
                ::buffa::Message::merge_length_delimited(&mut elem, buf, ctx)?;
                self.asks.push(elem);
            }
            5u32 => {
                ::buffa::encoding::check_wire_type(
                    tag,
                    ::buffa::encoding::WireType::LengthDelimited,
                )?;
                ::buffa::Message::merge_length_delimited(
                    self.ts.get_or_insert_default(),
                    buf,
                    ctx,
                )?;
            }
            _ => {
                self.__buffa_unknown_fields
                    .push(::buffa::encoding::decode_unknown_field(tag, buf, ctx)?);
            }
        }
        ::core::result::Result::Ok(())
    }
    fn clear(&mut self) {
        self.symbol_id = 0u32;
        self.book_seq = 0u64;
        self.bids.clear();
        self.asks.clear();
        self.ts = ::buffa::MessageField::none();
        self.__buffa_unknown_fields.clear();
    }
}
impl ::buffa::ExtensionSet for GetOrderBookResponse {
    const PROTO_FQN: &'static str = "orderbook.v1.GetOrderBookResponse";
    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 GetOrderBookResponse {
    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 __GET_ORDER_BOOK_RESPONSE_JSON_ANY: ::buffa::type_registry::JsonAnyEntry = ::buffa::type_registry::JsonAnyEntry {
    type_url: "type.googleapis.com/orderbook.v1.GetOrderBookResponse",
    to_json: ::buffa::type_registry::any_to_json::<GetOrderBookResponse>,
    from_json: ::buffa::type_registry::any_from_json::<GetOrderBookResponse>,
    is_wkt: false,
};
/// OrderBookDelta is an incremental update to the orderbook state.
/// Uses scaled integers (binary protobuf) for realtime streaming performance.
///
/// Semantics:
/// - For each side, each \[price_ticks\] entry is a SET at that price:
///   - qty_scaled \> 0 =\> set/replace that level quantity
///   - qty_scaled == 0 =\> delete that level
/// - reset=true indicates the book should be cleared before applying any levels.
///
/// Clients are expected to initialize from GetOrderBook (snapshot) and then
/// apply deltas in order. If a gap is detected, clients should refetch a
/// snapshot.
#[derive(Clone, PartialEq, Default)]
#[derive(::serde::Serialize, ::serde::Deserialize)]
#[serde(default)]
pub struct OrderBookDelta {
    /// Numeric symbol identifier.
    ///
    /// Field 1: `symbol_id`
    #[serde(
        rename = "symbolId",
        alias = "symbol_id",
        with = "::buffa::json_helpers::uint32",
        skip_serializing_if = "::buffa::json_helpers::skip_if::is_zero_u32"
    )]
    pub symbol_id: u32,
    /// Monotonic book sequence range covered by this update.
    /// When reset=true, book_seq_start may be 0.
    ///
    /// Field 2: `book_seq_start`
    #[serde(
        rename = "bookSeqStart",
        alias = "book_seq_start",
        with = "::buffa::json_helpers::uint64",
        skip_serializing_if = "::buffa::json_helpers::skip_if::is_zero_u64"
    )]
    pub book_seq_start: u64,
    /// Monotonic book sequence at the end of this update's range. Consumers can
    /// retain it as the last applied sequence and ignore updates that do not advance it.
    ///
    /// Field 3: `book_seq_end`
    #[serde(
        rename = "bookSeqEnd",
        alias = "book_seq_end",
        with = "::buffa::json_helpers::uint64",
        skip_serializing_if = "::buffa::json_helpers::skip_if::is_zero_u64"
    )]
    pub book_seq_end: u64,
    /// Bid-side updates (SET semantics at price_ticks).
    ///
    /// Field 4: `bids`
    #[serde(
        rename = "bids",
        skip_serializing_if = "::buffa::json_helpers::skip_if::is_empty_vec",
        deserialize_with = "::buffa::json_helpers::null_as_default"
    )]
    pub bids: ::buffa::alloc::vec::Vec<PriceLevel>,
    /// Ask-side updates (SET semantics at price_ticks).
    ///
    /// Field 5: `asks`
    #[serde(
        rename = "asks",
        skip_serializing_if = "::buffa::json_helpers::skip_if::is_empty_vec",
        deserialize_with = "::buffa::json_helpers::null_as_default"
    )]
    pub asks: ::buffa::alloc::vec::Vec<PriceLevel>,
    /// If true, consumers should clear their local book state before applying
    /// updates.
    ///
    /// Field 6: `reset`
    #[serde(
        rename = "reset",
        with = "::buffa::json_helpers::proto_bool",
        skip_serializing_if = "::buffa::json_helpers::skip_if::is_false"
    )]
    pub reset: bool,
    /// Timestamp associated with this update (best-effort).
    ///
    /// Field 7: `ts`
    #[serde(
        rename = "ts",
        skip_serializing_if = "::buffa::json_helpers::skip_if::is_unset_message_field"
    )]
    pub ts: ::buffa::MessageField<::buffa_types::google::protobuf::Timestamp>,
    #[serde(skip)]
    #[doc(hidden)]
    pub __buffa_unknown_fields: ::buffa::UnknownFields,
}
impl ::core::fmt::Debug for OrderBookDelta {
    fn fmt(&self, f: &mut ::core::fmt::Formatter<'_>) -> ::core::fmt::Result {
        f.debug_struct("OrderBookDelta")
            .field("symbol_id", &self.symbol_id)
            .field("book_seq_start", &self.book_seq_start)
            .field("book_seq_end", &self.book_seq_end)
            .field("bids", &self.bids)
            .field("asks", &self.asks)
            .field("reset", &self.reset)
            .field("ts", &self.ts)
            .finish()
    }
}
impl OrderBookDelta {
    /// 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/orderbook.v1.OrderBookDelta";
}
::buffa::impl_default_instance!(OrderBookDelta);
impl ::buffa::MessageName for OrderBookDelta {
    const PACKAGE: &'static str = "orderbook.v1";
    const NAME: &'static str = "OrderBookDelta";
    const FULL_NAME: &'static str = "orderbook.v1.OrderBookDelta";
    const TYPE_URL: &'static str = "type.googleapis.com/orderbook.v1.OrderBookDelta";
}
impl ::buffa::Message for OrderBookDelta {
    /// 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.symbol_id != 0u32 {
            size += 1u32 + ::buffa::types::uint32_encoded_len(self.symbol_id) as u32;
        }
        if self.book_seq_start != 0u64 {
            size
                += 1u32 + ::buffa::types::uint64_encoded_len(self.book_seq_start) as u32;
        }
        if self.book_seq_end != 0u64 {
            size += 1u32 + ::buffa::types::uint64_encoded_len(self.book_seq_end) as u32;
        }
        for v in &self.bids {
            let __slot = __cache.reserve();
            let inner_size = v.compute_size(__cache);
            __cache.set(__slot, inner_size);
            size
                += 1u32 + ::buffa::encoding::varint_len(inner_size as u64) as u32
                    + inner_size;
        }
        for v in &self.asks {
            let __slot = __cache.reserve();
            let inner_size = v.compute_size(__cache);
            __cache.set(__slot, inner_size);
            size
                += 1u32 + ::buffa::encoding::varint_len(inner_size as u64) as u32
                    + inner_size;
        }
        if self.reset {
            size += 1u32 + ::buffa::types::BOOL_ENCODED_LEN as u32;
        }
        if self.ts.is_set() {
            let __slot = __cache.reserve();
            let inner_size = self.ts.compute_size(__cache);
            __cache.set(__slot, inner_size);
            size
                += 1u32 + ::buffa::encoding::varint_len(inner_size as u64) as u32
                    + inner_size;
        }
        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.symbol_id != 0u32 {
            ::buffa::types::put_uint32_field(1u32, self.symbol_id, buf);
        }
        if self.book_seq_start != 0u64 {
            ::buffa::types::put_uint64_field(2u32, self.book_seq_start, buf);
        }
        if self.book_seq_end != 0u64 {
            ::buffa::types::put_uint64_field(3u32, self.book_seq_end, buf);
        }
        for v in &self.bids {
            ::buffa::types::put_len_delimited_header(4u32, __cache.consume_next(), buf);
            v.write_to(__cache, buf);
        }
        for v in &self.asks {
            ::buffa::types::put_len_delimited_header(5u32, __cache.consume_next(), buf);
            v.write_to(__cache, buf);
        }
        if self.reset {
            ::buffa::types::put_bool_field(6u32, self.reset, buf);
        }
        if self.ts.is_set() {
            ::buffa::types::put_len_delimited_header(7u32, __cache.consume_next(), buf);
            self.ts.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.symbol_id = ::buffa::types::decode_uint32(buf)?;
            }
            2u32 => {
                ::buffa::encoding::check_wire_type(
                    tag,
                    ::buffa::encoding::WireType::Varint,
                )?;
                self.book_seq_start = ::buffa::types::decode_uint64(buf)?;
            }
            3u32 => {
                ::buffa::encoding::check_wire_type(
                    tag,
                    ::buffa::encoding::WireType::Varint,
                )?;
                self.book_seq_end = ::buffa::types::decode_uint64(buf)?;
            }
            4u32 => {
                ::buffa::encoding::check_wire_type(
                    tag,
                    ::buffa::encoding::WireType::LengthDelimited,
                )?;
                let mut elem = ::core::default::Default::default();
                ::buffa::Message::merge_length_delimited(&mut elem, buf, ctx)?;
                self.bids.push(elem);
            }
            5u32 => {
                ::buffa::encoding::check_wire_type(
                    tag,
                    ::buffa::encoding::WireType::LengthDelimited,
                )?;
                let mut elem = ::core::default::Default::default();
                ::buffa::Message::merge_length_delimited(&mut elem, buf, ctx)?;
                self.asks.push(elem);
            }
            6u32 => {
                ::buffa::encoding::check_wire_type(
                    tag,
                    ::buffa::encoding::WireType::Varint,
                )?;
                self.reset = ::buffa::types::decode_bool(buf)?;
            }
            7u32 => {
                ::buffa::encoding::check_wire_type(
                    tag,
                    ::buffa::encoding::WireType::LengthDelimited,
                )?;
                ::buffa::Message::merge_length_delimited(
                    self.ts.get_or_insert_default(),
                    buf,
                    ctx,
                )?;
            }
            _ => {
                self.__buffa_unknown_fields
                    .push(::buffa::encoding::decode_unknown_field(tag, buf, ctx)?);
            }
        }
        ::core::result::Result::Ok(())
    }
    fn clear(&mut self) {
        self.symbol_id = 0u32;
        self.book_seq_start = 0u64;
        self.book_seq_end = 0u64;
        self.bids.clear();
        self.asks.clear();
        self.reset = false;
        self.ts = ::buffa::MessageField::none();
        self.__buffa_unknown_fields.clear();
    }
}
impl ::buffa::ExtensionSet for OrderBookDelta {
    const PROTO_FQN: &'static str = "orderbook.v1.OrderBookDelta";
    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 OrderBookDelta {
    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 __ORDER_BOOK_DELTA_JSON_ANY: ::buffa::type_registry::JsonAnyEntry = ::buffa::type_registry::JsonAnyEntry {
    type_url: "type.googleapis.com/orderbook.v1.OrderBookDelta",
    to_json: ::buffa::type_registry::any_to_json::<OrderBookDelta>,
    from_json: ::buffa::type_registry::any_from_json::<OrderBookDelta>,
    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::*;
        /// GetOrderBookRequest describes a snapshot view request.
        #[derive(Clone, Debug, Default)]
        pub struct GetOrderBookRequestView<'a> {
            /// e.g. "BTC-USDT"; resolved to symbol_id server-side.
            ///
            /// Field 1: `symbol`
            pub symbol: &'a str,
            /// Requested depth per side (number of price levels). Default is 50.
            ///
            /// Field 2: `depth`
            pub depth: ::buffa::EnumValue<super::super::Depth>,
            pub __buffa_unknown_fields: ::buffa::UnknownFieldsView<'a>,
        }
        impl<'a> ::buffa::MessageView<'a> for GetOrderBookRequestView<'a> {
            type Owned = super::super::GetOrderBookRequest;
            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.symbol = ::buffa::types::borrow_str(&mut cur)?;
                    }
                    2u32 => {
                        ::buffa::encoding::check_wire_type(
                            tag,
                            ::buffa::encoding::WireType::Varint,
                        )?;
                        view.depth = ::buffa::EnumValue::from(
                            ::buffa::types::decode_int32(&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::GetOrderBookRequest,
                ::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::GetOrderBookRequest,
                ::buffa::DecodeError,
            > {
                #[allow(unused_imports)]
                use ::buffa::alloc::string::ToString as _;
                let _ = __buffa_src;
                ::core::result::Result::Ok(super::super::GetOrderBookRequest {
                    symbol: self.symbol.to_string(),
                    depth: self.depth,
                    __buffa_unknown_fields: self
                        .__buffa_unknown_fields
                        .to_owned()?
                        .into(),
                    ..::core::default::Default::default()
                })
            }
        }
        impl<'a> ::buffa::ViewEncode<'a> for GetOrderBookRequestView<'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.symbol.is_empty() {
                    size
                        += 1u32
                            + ::buffa::types::string_encoded_len(&self.symbol) as u32;
                }
                {
                    let val = self.depth.to_i32();
                    if val != 0 {
                        size += 1u32 + ::buffa::types::int32_encoded_len(val) 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.symbol.is_empty() {
                    ::buffa::types::put_string_field(1u32, &self.symbol, buf);
                }
                {
                    let val = self.depth.to_i32();
                    if val != 0 {
                        ::buffa::types::put_int32_field(2u32, val, 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 GetOrderBookRequestView<'__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.symbol) {
                    __map.serialize_entry("symbol", self.symbol)?;
                }
                if !::buffa::json_helpers::skip_if::is_default_enum_value(&self.depth) {
                    __map.serialize_entry("depth", &self.depth)?;
                }
                __map.end()
            }
        }
        impl<'a> ::buffa::MessageName for GetOrderBookRequestView<'a> {
            const PACKAGE: &'static str = "orderbook.v1";
            const NAME: &'static str = "GetOrderBookRequest";
            const FULL_NAME: &'static str = "orderbook.v1.GetOrderBookRequest";
            const TYPE_URL: &'static str = "type.googleapis.com/orderbook.v1.GetOrderBookRequest";
        }
        ::buffa::impl_default_view_instance!(GetOrderBookRequestView);
        ::buffa::impl_view_reborrow!(GetOrderBookRequestView);
        /** Self-contained, `'static` owned view of a `GetOrderBookRequest` message.

 Wraps [`::buffa::OwnedView`]`<`[`GetOrderBookRequestView`]`<'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 [`GetOrderBookRequestView`] when you need struct patterns, iteration helpers, or to pass the view to lifetime-parameterised code.*/
        #[derive(Clone, Debug)]
        pub struct GetOrderBookRequestOwnedView(
            ::buffa::OwnedView<GetOrderBookRequestView<'static>>,
        );
        impl GetOrderBookRequestOwnedView {
            /// 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(
                    GetOrderBookRequestOwnedView(::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(
                    GetOrderBookRequestOwnedView(
                        ::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::GetOrderBookRequest,
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                ::core::result::Result::Ok(
                    GetOrderBookRequestOwnedView(::buffa::OwnedView::from_owned(msg)?),
                )
            }
            /// Borrow the full [`GetOrderBookRequestView`] with its lifetime tied to `&self`.
            #[must_use]
            pub fn view(&self) -> &GetOrderBookRequestView<'_> {
                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::GetOrderBookRequest,
                ::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()
            }
            /// e.g. "BTC-USDT"; resolved to symbol_id server-side.
            ///
            /// Field 1: `symbol`
            #[must_use]
            pub fn symbol(&self) -> &'_ str {
                self.0.reborrow().symbol
            }
            /// Requested depth per side (number of price levels). Default is 50.
            ///
            /// Field 2: `depth`
            #[must_use]
            pub fn depth(&self) -> ::buffa::EnumValue<super::super::Depth> {
                self.0.reborrow().depth
            }
        }
        impl ::core::convert::From<::buffa::OwnedView<GetOrderBookRequestView<'static>>>
        for GetOrderBookRequestOwnedView {
            fn from(
                inner: ::buffa::OwnedView<GetOrderBookRequestView<'static>>,
            ) -> Self {
                GetOrderBookRequestOwnedView(inner)
            }
        }
        impl ::core::convert::From<GetOrderBookRequestOwnedView>
        for ::buffa::OwnedView<GetOrderBookRequestView<'static>> {
            fn from(wrapper: GetOrderBookRequestOwnedView) -> Self {
                wrapper.0
            }
        }
        impl ::core::convert::AsRef<::buffa::OwnedView<GetOrderBookRequestView<'static>>>
        for GetOrderBookRequestOwnedView {
            fn as_ref(&self) -> &::buffa::OwnedView<GetOrderBookRequestView<'static>> {
                &self.0
            }
        }
        impl ::buffa::HasMessageView for super::super::GetOrderBookRequest {
            type View<'a> = GetOrderBookRequestView<'a>;
            type ViewHandle = GetOrderBookRequestOwnedView;
        }
        impl ::serde::Serialize for GetOrderBookRequestOwnedView {
            fn serialize<__S: ::serde::Serializer>(
                &self,
                __s: __S,
            ) -> ::core::result::Result<__S::Ok, __S::Error> {
                ::serde::Serialize::serialize(&self.0, __s)
            }
        }
        /// PriceLevel uses scaled integers for the binary (protobuf) API (low-latency).
        /// REST surfaces expose decimal strings via DTO conversion.
        #[derive(Clone, Debug, Default)]
        pub struct PriceLevelView<'a> {
            /// Price in quote units scaled by 1e6.
            ///
            /// Field 1: `price_ticks`
            pub price_ticks: i64,
            /// Quantity scaled by the pair's base_quantity_scale from GetSpotConfig.
            ///
            /// Field 2: `qty_scaled`
            pub qty_scaled: i64,
            pub __buffa_unknown_fields: ::buffa::UnknownFieldsView<'a>,
        }
        impl<'a> ::buffa::MessageView<'a> for PriceLevelView<'a> {
            type Owned = super::super::PriceLevel;
            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.price_ticks = ::buffa::types::decode_int64(&mut cur)?;
                    }
                    2u32 => {
                        ::buffa::encoding::check_wire_type(
                            tag,
                            ::buffa::encoding::WireType::Varint,
                        )?;
                        view.qty_scaled = ::buffa::types::decode_int64(&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::PriceLevel, ::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::PriceLevel, ::buffa::DecodeError> {
                #[allow(unused_imports)]
                use ::buffa::alloc::string::ToString as _;
                let _ = __buffa_src;
                ::core::result::Result::Ok(super::super::PriceLevel {
                    price_ticks: self.price_ticks,
                    qty_scaled: self.qty_scaled,
                    __buffa_unknown_fields: self
                        .__buffa_unknown_fields
                        .to_owned()?
                        .into(),
                    ..::core::default::Default::default()
                })
            }
        }
        impl<'a> ::buffa::ViewEncode<'a> for PriceLevelView<'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.price_ticks != 0i64 {
                    size
                        += 1u32
                            + ::buffa::types::int64_encoded_len(self.price_ticks) as u32;
                }
                if self.qty_scaled != 0i64 {
                    size
                        += 1u32
                            + ::buffa::types::int64_encoded_len(self.qty_scaled) 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.price_ticks != 0i64 {
                    ::buffa::types::put_int64_field(1u32, self.price_ticks, buf);
                }
                if self.qty_scaled != 0i64 {
                    ::buffa::types::put_int64_field(2u32, self.qty_scaled, 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 PriceLevelView<'__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_i64(&self.price_ticks) {
                    __map
                        .serialize_entry(
                            "priceTicks",
                            &::buffa::json_helpers::ProtoJson(&self.price_ticks),
                        )?;
                }
                if !::buffa::json_helpers::skip_if::is_zero_i64(&self.qty_scaled) {
                    __map
                        .serialize_entry(
                            "qtyScaled",
                            &::buffa::json_helpers::ProtoJson(&self.qty_scaled),
                        )?;
                }
                __map.end()
            }
        }
        impl<'a> ::buffa::MessageName for PriceLevelView<'a> {
            const PACKAGE: &'static str = "orderbook.v1";
            const NAME: &'static str = "PriceLevel";
            const FULL_NAME: &'static str = "orderbook.v1.PriceLevel";
            const TYPE_URL: &'static str = "type.googleapis.com/orderbook.v1.PriceLevel";
        }
        ::buffa::impl_default_view_instance!(PriceLevelView);
        ::buffa::impl_view_reborrow!(PriceLevelView);
        /** Self-contained, `'static` owned view of a `PriceLevel` message.

 Wraps [`::buffa::OwnedView`]`<`[`PriceLevelView`]`<'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 [`PriceLevelView`] when you need struct patterns, iteration helpers, or to pass the view to lifetime-parameterised code.*/
        #[derive(Clone, Debug)]
        pub struct PriceLevelOwnedView(::buffa::OwnedView<PriceLevelView<'static>>);
        impl PriceLevelOwnedView {
            /// 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(
                    PriceLevelOwnedView(::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(
                    PriceLevelOwnedView(
                        ::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::PriceLevel,
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                ::core::result::Result::Ok(
                    PriceLevelOwnedView(::buffa::OwnedView::from_owned(msg)?),
                )
            }
            /// Borrow the full [`PriceLevelView`] with its lifetime tied to `&self`.
            #[must_use]
            pub fn view(&self) -> &PriceLevelView<'_> {
                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::PriceLevel, ::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()
            }
            /// Price in quote units scaled by 1e6.
            ///
            /// Field 1: `price_ticks`
            #[must_use]
            pub fn price_ticks(&self) -> i64 {
                self.0.reborrow().price_ticks
            }
            /// Quantity scaled by the pair's base_quantity_scale from GetSpotConfig.
            ///
            /// Field 2: `qty_scaled`
            #[must_use]
            pub fn qty_scaled(&self) -> i64 {
                self.0.reborrow().qty_scaled
            }
        }
        impl ::core::convert::From<::buffa::OwnedView<PriceLevelView<'static>>>
        for PriceLevelOwnedView {
            fn from(inner: ::buffa::OwnedView<PriceLevelView<'static>>) -> Self {
                PriceLevelOwnedView(inner)
            }
        }
        impl ::core::convert::From<PriceLevelOwnedView>
        for ::buffa::OwnedView<PriceLevelView<'static>> {
            fn from(wrapper: PriceLevelOwnedView) -> Self {
                wrapper.0
            }
        }
        impl ::core::convert::AsRef<::buffa::OwnedView<PriceLevelView<'static>>>
        for PriceLevelOwnedView {
            fn as_ref(&self) -> &::buffa::OwnedView<PriceLevelView<'static>> {
                &self.0
            }
        }
        impl ::buffa::HasMessageView for super::super::PriceLevel {
            type View<'a> = PriceLevelView<'a>;
            type ViewHandle = PriceLevelOwnedView;
        }
        impl ::serde::Serialize for PriceLevelOwnedView {
            fn serialize<__S: ::serde::Serializer>(
                &self,
                __s: __S,
            ) -> ::core::result::Result<__S::Ok, __S::Error> {
                ::serde::Serialize::serialize(&self.0, __s)
            }
        }
        /// GetOrderBookResponse is a depth snapshot for the binary (protobuf) API (scaled integers).
        /// REST surfaces expose decimal strings via DTO conversion.
        #[derive(Clone, Debug, Default)]
        pub struct GetOrderBookResponseView<'a> {
            /// Numeric symbol identifier (client resolves to symbol string).
            ///
            /// Field 1: `symbol_id`
            pub symbol_id: u32,
            /// Monotonic book sequence for this symbol.
            ///
            /// Field 2: `book_seq`
            pub book_seq: u64,
            /// Best bid first; descending price.
            ///
            /// Field 3: `bids`
            pub bids: ::buffa::RepeatedView<
                'a,
                super::super::__buffa::view::PriceLevelView<'a>,
            >,
            /// Best ask first; ascending price.
            ///
            /// Field 4: `asks`
            pub asks: ::buffa::RepeatedView<
                'a,
                super::super::__buffa::view::PriceLevelView<'a>,
            >,
            /// Timestamp associated with this snapshot (best-effort).
            ///
            /// Field 5: `ts`
            pub ts: ::buffa::MessageFieldView<
                ::buffa_types::google::protobuf::__buffa::view::TimestampView<'a>,
            >,
            pub __buffa_unknown_fields: ::buffa::UnknownFieldsView<'a>,
        }
        impl<'a> ::buffa::MessageView<'a> for GetOrderBookResponseView<'a> {
            type Owned = super::super::GetOrderBookResponse;
            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.symbol_id = ::buffa::types::decode_uint32(&mut cur)?;
                    }
                    2u32 => {
                        ::buffa::encoding::check_wire_type(
                            tag,
                            ::buffa::encoding::WireType::Varint,
                        )?;
                        view.book_seq = ::buffa::types::decode_uint64(&mut cur)?;
                    }
                    5u32 => {
                        ::buffa::encoding::check_wire_type(
                            tag,
                            ::buffa::encoding::WireType::LengthDelimited,
                        )?;
                        let __sub_ctx = ctx.descend()?;
                        let sub = ::buffa::types::borrow_bytes(&mut cur)?;
                        match view.ts.as_mut() {
                            Some(existing) => {
                                ::buffa::MessageView::merge_into_view(
                                    existing,
                                    sub,
                                    __sub_ctx,
                                )?
                            }
                            None => {
                                view.ts = ::buffa::MessageFieldView::set(
                                    <::buffa_types::google::protobuf::__buffa::view::TimestampView 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)?;
                        view.bids
                            .push(
                                <super::super::__buffa::view::PriceLevelView 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)?;
                        view.asks
                            .push(
                                <super::super::__buffa::view::PriceLevelView 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::GetOrderBookResponse,
                ::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::GetOrderBookResponse,
                ::buffa::DecodeError,
            > {
                #[allow(unused_imports)]
                use ::buffa::alloc::string::ToString as _;
                let _ = __buffa_src;
                ::core::result::Result::Ok(super::super::GetOrderBookResponse {
                    symbol_id: self.symbol_id,
                    book_seq: self.book_seq,
                    bids: self
                        .bids
                        .iter()
                        .map(|v| v.to_owned_from_source(__buffa_src))
                        .collect::<::core::result::Result<_, ::buffa::DecodeError>>()?,
                    asks: self
                        .asks
                        .iter()
                        .map(|v| v.to_owned_from_source(__buffa_src))
                        .collect::<::core::result::Result<_, ::buffa::DecodeError>>()?,
                    ts: match self.ts.as_option() {
                        Some(v) => {
                            ::buffa::MessageField::<
                                ::buffa_types::google::protobuf::Timestamp,
                            >::some(v.to_owned_from_source(__buffa_src)?)
                        }
                        None => ::buffa::MessageField::none(),
                    },
                    __buffa_unknown_fields: self
                        .__buffa_unknown_fields
                        .to_owned()?
                        .into(),
                    ..::core::default::Default::default()
                })
            }
        }
        impl<'a> ::buffa::ViewEncode<'a> for GetOrderBookResponseView<'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.symbol_id != 0u32 {
                    size
                        += 1u32
                            + ::buffa::types::uint32_encoded_len(self.symbol_id) as u32;
                }
                if self.book_seq != 0u64 {
                    size
                        += 1u32
                            + ::buffa::types::uint64_encoded_len(self.book_seq) as u32;
                }
                for v in &self.bids {
                    let __slot = __cache.reserve();
                    let inner_size = v.compute_size(__cache);
                    __cache.set(__slot, inner_size);
                    size
                        += 1u32 + ::buffa::encoding::varint_len(inner_size as u64) as u32
                            + inner_size;
                }
                for v in &self.asks {
                    let __slot = __cache.reserve();
                    let inner_size = v.compute_size(__cache);
                    __cache.set(__slot, inner_size);
                    size
                        += 1u32 + ::buffa::encoding::varint_len(inner_size as u64) as u32
                            + inner_size;
                }
                if self.ts.is_set() {
                    let __slot = __cache.reserve();
                    let inner_size = self.ts.compute_size(__cache);
                    __cache.set(__slot, inner_size);
                    size
                        += 1u32 + ::buffa::encoding::varint_len(inner_size as u64) as u32
                            + inner_size;
                }
                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.symbol_id != 0u32 {
                    ::buffa::types::put_uint32_field(1u32, self.symbol_id, buf);
                }
                if self.book_seq != 0u64 {
                    ::buffa::types::put_uint64_field(2u32, self.book_seq, buf);
                }
                for v in &self.bids {
                    ::buffa::types::put_len_delimited_header(
                        3u32,
                        __cache.consume_next(),
                        buf,
                    );
                    v.write_to(__cache, buf);
                }
                for v in &self.asks {
                    ::buffa::types::put_len_delimited_header(
                        4u32,
                        __cache.consume_next(),
                        buf,
                    );
                    v.write_to(__cache, buf);
                }
                if self.ts.is_set() {
                    ::buffa::types::put_len_delimited_header(
                        5u32,
                        __cache.consume_next(),
                        buf,
                    );
                    self.ts.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 GetOrderBookResponseView<'__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_u32(&self.symbol_id) {
                    __map
                        .serialize_entry(
                            "symbolId",
                            &::buffa::json_helpers::ProtoJson(&self.symbol_id),
                        )?;
                }
                if !::buffa::json_helpers::skip_if::is_zero_u64(&self.book_seq) {
                    __map
                        .serialize_entry(
                            "bookSeq",
                            &::buffa::json_helpers::ProtoJson(&self.book_seq),
                        )?;
                }
                if !self.bids.is_empty() {
                    __map.serialize_entry("bids", &*self.bids)?;
                }
                if !self.asks.is_empty() {
                    __map.serialize_entry("asks", &*self.asks)?;
                }
                {
                    if let ::core::option::Option::Some(__v) = self.ts.as_option() {
                        __map.serialize_entry("ts", __v)?;
                    }
                }
                __map.end()
            }
        }
        impl<'a> ::buffa::MessageName for GetOrderBookResponseView<'a> {
            const PACKAGE: &'static str = "orderbook.v1";
            const NAME: &'static str = "GetOrderBookResponse";
            const FULL_NAME: &'static str = "orderbook.v1.GetOrderBookResponse";
            const TYPE_URL: &'static str = "type.googleapis.com/orderbook.v1.GetOrderBookResponse";
        }
        ::buffa::impl_default_view_instance!(GetOrderBookResponseView);
        ::buffa::impl_view_reborrow!(GetOrderBookResponseView);
        /** Self-contained, `'static` owned view of a `GetOrderBookResponse` message.

 Wraps [`::buffa::OwnedView`]`<`[`GetOrderBookResponseView`]`<'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 [`GetOrderBookResponseView`] when you need struct patterns, iteration helpers, or to pass the view to lifetime-parameterised code.*/
        #[derive(Clone, Debug)]
        pub struct GetOrderBookResponseOwnedView(
            ::buffa::OwnedView<GetOrderBookResponseView<'static>>,
        );
        impl GetOrderBookResponseOwnedView {
            /// 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(
                    GetOrderBookResponseOwnedView(::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(
                    GetOrderBookResponseOwnedView(
                        ::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::GetOrderBookResponse,
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                ::core::result::Result::Ok(
                    GetOrderBookResponseOwnedView(::buffa::OwnedView::from_owned(msg)?),
                )
            }
            /// Borrow the full [`GetOrderBookResponseView`] with its lifetime tied to `&self`.
            #[must_use]
            pub fn view(&self) -> &GetOrderBookResponseView<'_> {
                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::GetOrderBookResponse,
                ::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()
            }
            /// Numeric symbol identifier (client resolves to symbol string).
            ///
            /// Field 1: `symbol_id`
            #[must_use]
            pub fn symbol_id(&self) -> u32 {
                self.0.reborrow().symbol_id
            }
            /// Monotonic book sequence for this symbol.
            ///
            /// Field 2: `book_seq`
            #[must_use]
            pub fn book_seq(&self) -> u64 {
                self.0.reborrow().book_seq
            }
            /// Best bid first; descending price.
            ///
            /// Field 3: `bids`
            #[must_use]
            pub fn bids(
                &self,
            ) -> &::buffa::RepeatedView<
                '_,
                super::super::__buffa::view::PriceLevelView<'_>,
            > {
                &self.0.reborrow().bids
            }
            /// Best ask first; ascending price.
            ///
            /// Field 4: `asks`
            #[must_use]
            pub fn asks(
                &self,
            ) -> &::buffa::RepeatedView<
                '_,
                super::super::__buffa::view::PriceLevelView<'_>,
            > {
                &self.0.reborrow().asks
            }
            /// Timestamp associated with this snapshot (best-effort).
            ///
            /// Field 5: `ts`
            #[must_use]
            pub fn ts(
                &self,
            ) -> &::buffa::MessageFieldView<
                ::buffa_types::google::protobuf::__buffa::view::TimestampView<'_>,
            > {
                &self.0.reborrow().ts
            }
        }
        impl ::core::convert::From<::buffa::OwnedView<GetOrderBookResponseView<'static>>>
        for GetOrderBookResponseOwnedView {
            fn from(
                inner: ::buffa::OwnedView<GetOrderBookResponseView<'static>>,
            ) -> Self {
                GetOrderBookResponseOwnedView(inner)
            }
        }
        impl ::core::convert::From<GetOrderBookResponseOwnedView>
        for ::buffa::OwnedView<GetOrderBookResponseView<'static>> {
            fn from(wrapper: GetOrderBookResponseOwnedView) -> Self {
                wrapper.0
            }
        }
        impl ::core::convert::AsRef<
            ::buffa::OwnedView<GetOrderBookResponseView<'static>>,
        > for GetOrderBookResponseOwnedView {
            fn as_ref(&self) -> &::buffa::OwnedView<GetOrderBookResponseView<'static>> {
                &self.0
            }
        }
        impl ::buffa::HasMessageView for super::super::GetOrderBookResponse {
            type View<'a> = GetOrderBookResponseView<'a>;
            type ViewHandle = GetOrderBookResponseOwnedView;
        }
        impl ::serde::Serialize for GetOrderBookResponseOwnedView {
            fn serialize<__S: ::serde::Serializer>(
                &self,
                __s: __S,
            ) -> ::core::result::Result<__S::Ok, __S::Error> {
                ::serde::Serialize::serialize(&self.0, __s)
            }
        }
        /// OrderBookDelta is an incremental update to the orderbook state.
        /// Uses scaled integers (binary protobuf) for realtime streaming performance.
        ///
        /// Semantics:
        /// - For each side, each \[price_ticks\] entry is a SET at that price:
        ///   - qty_scaled \> 0 =\> set/replace that level quantity
        ///   - qty_scaled == 0 =\> delete that level
        /// - reset=true indicates the book should be cleared before applying any levels.
        ///
        /// Clients are expected to initialize from GetOrderBook (snapshot) and then
        /// apply deltas in order. If a gap is detected, clients should refetch a
        /// snapshot.
        #[derive(Clone, Debug, Default)]
        pub struct OrderBookDeltaView<'a> {
            /// Numeric symbol identifier.
            ///
            /// Field 1: `symbol_id`
            pub symbol_id: u32,
            /// Monotonic book sequence range covered by this update.
            /// When reset=true, book_seq_start may be 0.
            ///
            /// Field 2: `book_seq_start`
            pub book_seq_start: u64,
            /// Monotonic book sequence at the end of this update's range. Consumers can
            /// retain it as the last applied sequence and ignore updates that do not advance it.
            ///
            /// Field 3: `book_seq_end`
            pub book_seq_end: u64,
            /// Bid-side updates (SET semantics at price_ticks).
            ///
            /// Field 4: `bids`
            pub bids: ::buffa::RepeatedView<
                'a,
                super::super::__buffa::view::PriceLevelView<'a>,
            >,
            /// Ask-side updates (SET semantics at price_ticks).
            ///
            /// Field 5: `asks`
            pub asks: ::buffa::RepeatedView<
                'a,
                super::super::__buffa::view::PriceLevelView<'a>,
            >,
            /// If true, consumers should clear their local book state before applying
            /// updates.
            ///
            /// Field 6: `reset`
            pub reset: bool,
            /// Timestamp associated with this update (best-effort).
            ///
            /// Field 7: `ts`
            pub ts: ::buffa::MessageFieldView<
                ::buffa_types::google::protobuf::__buffa::view::TimestampView<'a>,
            >,
            pub __buffa_unknown_fields: ::buffa::UnknownFieldsView<'a>,
        }
        impl<'a> ::buffa::MessageView<'a> for OrderBookDeltaView<'a> {
            type Owned = super::super::OrderBookDelta;
            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.symbol_id = ::buffa::types::decode_uint32(&mut cur)?;
                    }
                    2u32 => {
                        ::buffa::encoding::check_wire_type(
                            tag,
                            ::buffa::encoding::WireType::Varint,
                        )?;
                        view.book_seq_start = ::buffa::types::decode_uint64(&mut cur)?;
                    }
                    3u32 => {
                        ::buffa::encoding::check_wire_type(
                            tag,
                            ::buffa::encoding::WireType::Varint,
                        )?;
                        view.book_seq_end = ::buffa::types::decode_uint64(&mut cur)?;
                    }
                    6u32 => {
                        ::buffa::encoding::check_wire_type(
                            tag,
                            ::buffa::encoding::WireType::Varint,
                        )?;
                        view.reset = ::buffa::types::decode_bool(&mut cur)?;
                    }
                    7u32 => {
                        ::buffa::encoding::check_wire_type(
                            tag,
                            ::buffa::encoding::WireType::LengthDelimited,
                        )?;
                        let __sub_ctx = ctx.descend()?;
                        let sub = ::buffa::types::borrow_bytes(&mut cur)?;
                        match view.ts.as_mut() {
                            Some(existing) => {
                                ::buffa::MessageView::merge_into_view(
                                    existing,
                                    sub,
                                    __sub_ctx,
                                )?
                            }
                            None => {
                                view.ts = ::buffa::MessageFieldView::set(
                                    <::buffa_types::google::protobuf::__buffa::view::TimestampView 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)?;
                        view.bids
                            .push(
                                <super::super::__buffa::view::PriceLevelView as ::buffa::MessageView>::decode_view_ctx(
                                    sub,
                                    __sub_ctx,
                                )?,
                            );
                    }
                    5u32 => {
                        ::buffa::encoding::check_wire_type(
                            tag,
                            ::buffa::encoding::WireType::LengthDelimited,
                        )?;
                        let __sub_ctx = ctx.descend()?;
                        let sub = ::buffa::types::borrow_bytes(&mut cur)?;
                        view.asks
                            .push(
                                <super::super::__buffa::view::PriceLevelView 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::OrderBookDelta,
                ::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::OrderBookDelta,
                ::buffa::DecodeError,
            > {
                #[allow(unused_imports)]
                use ::buffa::alloc::string::ToString as _;
                let _ = __buffa_src;
                ::core::result::Result::Ok(super::super::OrderBookDelta {
                    symbol_id: self.symbol_id,
                    book_seq_start: self.book_seq_start,
                    book_seq_end: self.book_seq_end,
                    bids: self
                        .bids
                        .iter()
                        .map(|v| v.to_owned_from_source(__buffa_src))
                        .collect::<::core::result::Result<_, ::buffa::DecodeError>>()?,
                    asks: self
                        .asks
                        .iter()
                        .map(|v| v.to_owned_from_source(__buffa_src))
                        .collect::<::core::result::Result<_, ::buffa::DecodeError>>()?,
                    reset: self.reset,
                    ts: match self.ts.as_option() {
                        Some(v) => {
                            ::buffa::MessageField::<
                                ::buffa_types::google::protobuf::Timestamp,
                            >::some(v.to_owned_from_source(__buffa_src)?)
                        }
                        None => ::buffa::MessageField::none(),
                    },
                    __buffa_unknown_fields: self
                        .__buffa_unknown_fields
                        .to_owned()?
                        .into(),
                    ..::core::default::Default::default()
                })
            }
        }
        impl<'a> ::buffa::ViewEncode<'a> for OrderBookDeltaView<'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.symbol_id != 0u32 {
                    size
                        += 1u32
                            + ::buffa::types::uint32_encoded_len(self.symbol_id) as u32;
                }
                if self.book_seq_start != 0u64 {
                    size
                        += 1u32
                            + ::buffa::types::uint64_encoded_len(self.book_seq_start)
                                as u32;
                }
                if self.book_seq_end != 0u64 {
                    size
                        += 1u32
                            + ::buffa::types::uint64_encoded_len(self.book_seq_end)
                                as u32;
                }
                for v in &self.bids {
                    let __slot = __cache.reserve();
                    let inner_size = v.compute_size(__cache);
                    __cache.set(__slot, inner_size);
                    size
                        += 1u32 + ::buffa::encoding::varint_len(inner_size as u64) as u32
                            + inner_size;
                }
                for v in &self.asks {
                    let __slot = __cache.reserve();
                    let inner_size = v.compute_size(__cache);
                    __cache.set(__slot, inner_size);
                    size
                        += 1u32 + ::buffa::encoding::varint_len(inner_size as u64) as u32
                            + inner_size;
                }
                if self.reset {
                    size += 1u32 + ::buffa::types::BOOL_ENCODED_LEN as u32;
                }
                if self.ts.is_set() {
                    let __slot = __cache.reserve();
                    let inner_size = self.ts.compute_size(__cache);
                    __cache.set(__slot, inner_size);
                    size
                        += 1u32 + ::buffa::encoding::varint_len(inner_size as u64) as u32
                            + inner_size;
                }
                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.symbol_id != 0u32 {
                    ::buffa::types::put_uint32_field(1u32, self.symbol_id, buf);
                }
                if self.book_seq_start != 0u64 {
                    ::buffa::types::put_uint64_field(2u32, self.book_seq_start, buf);
                }
                if self.book_seq_end != 0u64 {
                    ::buffa::types::put_uint64_field(3u32, self.book_seq_end, buf);
                }
                for v in &self.bids {
                    ::buffa::types::put_len_delimited_header(
                        4u32,
                        __cache.consume_next(),
                        buf,
                    );
                    v.write_to(__cache, buf);
                }
                for v in &self.asks {
                    ::buffa::types::put_len_delimited_header(
                        5u32,
                        __cache.consume_next(),
                        buf,
                    );
                    v.write_to(__cache, buf);
                }
                if self.reset {
                    ::buffa::types::put_bool_field(6u32, self.reset, buf);
                }
                if self.ts.is_set() {
                    ::buffa::types::put_len_delimited_header(
                        7u32,
                        __cache.consume_next(),
                        buf,
                    );
                    self.ts.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 OrderBookDeltaView<'__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_u32(&self.symbol_id) {
                    __map
                        .serialize_entry(
                            "symbolId",
                            &::buffa::json_helpers::ProtoJson(&self.symbol_id),
                        )?;
                }
                if !::buffa::json_helpers::skip_if::is_zero_u64(&self.book_seq_start) {
                    __map
                        .serialize_entry(
                            "bookSeqStart",
                            &::buffa::json_helpers::ProtoJson(&self.book_seq_start),
                        )?;
                }
                if !::buffa::json_helpers::skip_if::is_zero_u64(&self.book_seq_end) {
                    __map
                        .serialize_entry(
                            "bookSeqEnd",
                            &::buffa::json_helpers::ProtoJson(&self.book_seq_end),
                        )?;
                }
                if !self.bids.is_empty() {
                    __map.serialize_entry("bids", &*self.bids)?;
                }
                if !self.asks.is_empty() {
                    __map.serialize_entry("asks", &*self.asks)?;
                }
                if self.reset {
                    __map.serialize_entry("reset", &self.reset)?;
                }
                {
                    if let ::core::option::Option::Some(__v) = self.ts.as_option() {
                        __map.serialize_entry("ts", __v)?;
                    }
                }
                __map.end()
            }
        }
        impl<'a> ::buffa::MessageName for OrderBookDeltaView<'a> {
            const PACKAGE: &'static str = "orderbook.v1";
            const NAME: &'static str = "OrderBookDelta";
            const FULL_NAME: &'static str = "orderbook.v1.OrderBookDelta";
            const TYPE_URL: &'static str = "type.googleapis.com/orderbook.v1.OrderBookDelta";
        }
        ::buffa::impl_default_view_instance!(OrderBookDeltaView);
        ::buffa::impl_view_reborrow!(OrderBookDeltaView);
        /** Self-contained, `'static` owned view of a `OrderBookDelta` message.

 Wraps [`::buffa::OwnedView`]`<`[`OrderBookDeltaView`]`<'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 [`OrderBookDeltaView`] when you need struct patterns, iteration helpers, or to pass the view to lifetime-parameterised code.*/
        #[derive(Clone, Debug)]
        pub struct OrderBookDeltaOwnedView(
            ::buffa::OwnedView<OrderBookDeltaView<'static>>,
        );
        impl OrderBookDeltaOwnedView {
            /// 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(
                    OrderBookDeltaOwnedView(::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(
                    OrderBookDeltaOwnedView(
                        ::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::OrderBookDelta,
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                ::core::result::Result::Ok(
                    OrderBookDeltaOwnedView(::buffa::OwnedView::from_owned(msg)?),
                )
            }
            /// Borrow the full [`OrderBookDeltaView`] with its lifetime tied to `&self`.
            #[must_use]
            pub fn view(&self) -> &OrderBookDeltaView<'_> {
                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::OrderBookDelta,
                ::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()
            }
            /// Numeric symbol identifier.
            ///
            /// Field 1: `symbol_id`
            #[must_use]
            pub fn symbol_id(&self) -> u32 {
                self.0.reborrow().symbol_id
            }
            /// Monotonic book sequence range covered by this update.
            /// When reset=true, book_seq_start may be 0.
            ///
            /// Field 2: `book_seq_start`
            #[must_use]
            pub fn book_seq_start(&self) -> u64 {
                self.0.reborrow().book_seq_start
            }
            /// Monotonic book sequence at the end of this update's range. Consumers can
            /// retain it as the last applied sequence and ignore updates that do not advance it.
            ///
            /// Field 3: `book_seq_end`
            #[must_use]
            pub fn book_seq_end(&self) -> u64 {
                self.0.reborrow().book_seq_end
            }
            /// Bid-side updates (SET semantics at price_ticks).
            ///
            /// Field 4: `bids`
            #[must_use]
            pub fn bids(
                &self,
            ) -> &::buffa::RepeatedView<
                '_,
                super::super::__buffa::view::PriceLevelView<'_>,
            > {
                &self.0.reborrow().bids
            }
            /// Ask-side updates (SET semantics at price_ticks).
            ///
            /// Field 5: `asks`
            #[must_use]
            pub fn asks(
                &self,
            ) -> &::buffa::RepeatedView<
                '_,
                super::super::__buffa::view::PriceLevelView<'_>,
            > {
                &self.0.reborrow().asks
            }
            /// If true, consumers should clear their local book state before applying
            /// updates.
            ///
            /// Field 6: `reset`
            #[must_use]
            pub fn reset(&self) -> bool {
                self.0.reborrow().reset
            }
            /// Timestamp associated with this update (best-effort).
            ///
            /// Field 7: `ts`
            #[must_use]
            pub fn ts(
                &self,
            ) -> &::buffa::MessageFieldView<
                ::buffa_types::google::protobuf::__buffa::view::TimestampView<'_>,
            > {
                &self.0.reborrow().ts
            }
        }
        impl ::core::convert::From<::buffa::OwnedView<OrderBookDeltaView<'static>>>
        for OrderBookDeltaOwnedView {
            fn from(inner: ::buffa::OwnedView<OrderBookDeltaView<'static>>) -> Self {
                OrderBookDeltaOwnedView(inner)
            }
        }
        impl ::core::convert::From<OrderBookDeltaOwnedView>
        for ::buffa::OwnedView<OrderBookDeltaView<'static>> {
            fn from(wrapper: OrderBookDeltaOwnedView) -> Self {
                wrapper.0
            }
        }
        impl ::core::convert::AsRef<::buffa::OwnedView<OrderBookDeltaView<'static>>>
        for OrderBookDeltaOwnedView {
            fn as_ref(&self) -> &::buffa::OwnedView<OrderBookDeltaView<'static>> {
                &self.0
            }
        }
        impl ::buffa::HasMessageView for super::super::OrderBookDelta {
            type View<'a> = OrderBookDeltaView<'a>;
            type ViewHandle = OrderBookDeltaOwnedView;
        }
        impl ::serde::Serialize for OrderBookDeltaOwnedView {
            fn serialize<__S: ::serde::Serializer>(
                &self,
                __s: __S,
            ) -> ::core::result::Result<__S::Ok, __S::Error> {
                ::serde::Serialize::serialize(&self.0, __s)
            }
        }
    }
    /// 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::__GET_ORDER_BOOK_REQUEST_JSON_ANY);
        reg.register_json_any(super::__PRICE_LEVEL_JSON_ANY);
        reg.register_json_any(super::__GET_ORDER_BOOK_RESPONSE_JSON_ANY);
        reg.register_json_any(super::__ORDER_BOOK_DELTA_JSON_ANY);
    }
}
#[doc(inline)]
pub use self::__buffa::view::GetOrderBookRequestView;
#[doc(inline)]
pub use self::__buffa::view::GetOrderBookRequestOwnedView;
#[doc(inline)]
pub use self::__buffa::view::PriceLevelView;
#[doc(inline)]
pub use self::__buffa::view::PriceLevelOwnedView;
#[doc(inline)]
pub use self::__buffa::view::GetOrderBookResponseView;
#[doc(inline)]
pub use self::__buffa::view::GetOrderBookResponseOwnedView;
#[doc(inline)]
pub use self::__buffa::view::OrderBookDeltaView;
#[doc(inline)]
pub use self::__buffa::view::OrderBookDeltaOwnedView;
#[doc(inline)]
pub use self::__buffa::register_types;