#[derive(Clone, Debug, Default)]
pub struct StructView<'a> {
pub fields: ::buffa::MapView<
'a,
&'a str,
super::super::__buffa::view::ValueView<'a>,
>,
pub __buffa_unknown_fields: ::buffa::UnknownFieldsView<'a>,
}
impl<'a> ::buffa::MessageView<'a> for StructView<'a> {
type Owned = super::super::Struct;
fn decode_view(buf: &'a [u8]) -> ::core::result::Result<Self, ::buffa::DecodeError> {
let __limit = ::core::cell::Cell::new(::buffa::DEFAULT_UNKNOWN_FIELD_LIMIT);
let __elem = ::core::cell::Cell::new(::buffa::DEFAULT_ELEMENT_MEMORY_LIMIT);
<Self as ::buffa::MessageView>::decode_view_ctx(
buf,
::buffa::DecodeContext::new(::buffa::RECURSION_LIMIT, &__limit)
.with_element_memory(&__elem),
)
}
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)
}
#[inline]
fn merge_view_field(
&mut self,
tag: ::buffa::encoding::Tag,
cur: &'a [u8],
before_tag: &'a [u8],
ctx: ::buffa::DecodeContext<'_>,
) -> ::core::result::Result<&'a [u8], ::buffa::DecodeError> {
let _ = ctx;
#[allow(unused_variables)]
let view = self;
let mut cur = cur;
match tag.field_number() {
1u32 => {
::buffa::encoding::check_wire_type(
tag,
::buffa::encoding::WireType::LengthDelimited,
)?;
let entry_bytes = ::buffa::types::borrow_bytes(&mut cur)?;
let mut entry_cur: &'a [u8] = entry_bytes;
let mut key = "";
let mut val = ::core::default::Default::default();
ctx.register_element_memory(
::buffa::__private::element_footprint(&key)
+ ::buffa::__private::element_footprint(&val),
)?;
while !entry_cur.is_empty() {
let entry_tag = ::buffa::encoding::Tag::decode(&mut entry_cur)?;
match entry_tag.field_number() {
1 => {
::buffa::encoding::check_wire_type(
entry_tag,
::buffa::encoding::WireType::LengthDelimited,
)?;
key = ::buffa::types::borrow_str(&mut entry_cur)?;
}
2 => {
::buffa::encoding::check_wire_type(
entry_tag,
::buffa::encoding::WireType::LengthDelimited,
)?;
let __sub_ctx = ctx.descend()?;
let sub = ::buffa::types::borrow_bytes(&mut entry_cur)?;
<super::super::__buffa::view::ValueView as ::buffa::MessageView>::merge_into_view(
&mut val,
sub,
__sub_ctx,
)?;
}
_ => {
::buffa::encoding::skip_field_depth(
entry_tag,
&mut entry_cur,
ctx.depth(),
)?;
}
}
}
view.fields.push(key, val);
}
_ => {
::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::Struct, ::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::Struct, ::buffa::DecodeError> {
#[allow(unused_imports)]
use ::buffa::alloc::string::ToString as _;
let _ = __buffa_src;
::core::result::Result::Ok(super::super::Struct {
fields: self
.fields
.iter()
.map(|(k, v)| {
::core::result::Result::<
_,
::buffa::DecodeError,
>::Ok((k.to_string(), v.to_owned_from_source(__buffa_src)?))
})
.collect::<::core::result::Result<_, ::buffa::DecodeError>>()?,
__buffa_unknown_fields: self.__buffa_unknown_fields.to_owned()?.into(),
..::core::default::Default::default()
})
}
}
impl<'a> ::buffa::ViewEncode<'a> for StructView<'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 = 0u64;
#[allow(clippy::for_kv_map)]
for (k, v) in &self.fields {
let entry_size: u64 = 1u64 + ::buffa::types::string_encoded_len(k) as u64
+ 1u64
+ {
let __slot = __cache.reserve();
let inner = v.compute_size(__cache);
__cache.set(__slot, inner);
::buffa::encoding::varint_len(inner as u64) as u64 + inner as u64
};
size += 1u64 + ::buffa::encoding::varint_len(entry_size) as u64 + entry_size;
}
size += self.__buffa_unknown_fields.encoded_len() as u64;
::buffa::saturate_size(size)
}
#[allow(clippy::needless_borrow)]
fn write_to(
&self,
__cache: &mut ::buffa::SizeCache,
buf: &mut impl ::buffa::EncodeSink,
) {
#[allow(unused_imports)]
use ::buffa::Enumeration as _;
for (k, v) in &self.fields {
let __v_len = __cache.consume_next();
let entry_size: u64 = 1u64 + ::buffa::types::string_encoded_len(k) as u64
+ 1u64
+ (::buffa::encoding::varint_len(__v_len as u64) as u64
+ __v_len as u64);
::buffa::encoding::Tag::new(
1u32,
::buffa::encoding::WireType::LengthDelimited,
)
.encode(buf);
::buffa::encoding::encode_varint(entry_size, buf);
::buffa::encoding::Tag::new(
1u32,
::buffa::encoding::WireType::LengthDelimited,
)
.encode(buf);
::buffa::types::encode_string(k, buf);
::buffa::encoding::Tag::new(
2u32,
::buffa::encoding::WireType::LengthDelimited,
)
.encode(buf);
::buffa::encoding::encode_varint(__v_len as u64, buf);
v.write_to(__cache, buf);
}
self.__buffa_unknown_fields.write_to(buf);
}
}
impl<'a> ::buffa::MessageName for StructView<'a> {
const PACKAGE: &'static str = "google.protobuf";
const NAME: &'static str = "Struct";
const FULL_NAME: &'static str = "google.protobuf.Struct";
const TYPE_URL: &'static str = "type.googleapis.com/google.protobuf.Struct";
}
::buffa::impl_default_view_instance!(StructView);
::buffa::impl_view_reborrow!(StructView);
#[derive(Clone, Debug)]
pub struct StructOwnedView(::buffa::OwnedView<StructView<'static>>);
impl StructOwnedView {
pub fn decode(
bytes: ::buffa::bytes::Bytes,
) -> ::core::result::Result<Self, ::buffa::DecodeError> {
::core::result::Result::Ok(StructOwnedView(::buffa::OwnedView::decode(bytes)?))
}
pub fn decode_with_options(
bytes: ::buffa::bytes::Bytes,
opts: &::buffa::DecodeOptions,
) -> ::core::result::Result<Self, ::buffa::DecodeError> {
::core::result::Result::Ok(
StructOwnedView(::buffa::OwnedView::decode_with_options(bytes, opts)?),
)
}
pub fn from_owned(
msg: &super::super::Struct,
) -> ::core::result::Result<Self, ::buffa::DecodeError> {
::core::result::Result::Ok(StructOwnedView(::buffa::OwnedView::from_owned(msg)?))
}
#[must_use]
pub fn view(&self) -> &StructView<'_> {
self.0.reborrow()
}
#[must_use]
pub fn to_owned_message(&self) -> super::super::Struct {
self.0.to_owned_message()
}
#[must_use]
pub fn bytes(&self) -> &::buffa::bytes::Bytes {
self.0.bytes()
}
#[must_use]
pub fn into_bytes(self) -> ::buffa::bytes::Bytes {
self.0.into_bytes()
}
#[must_use]
pub fn fields(
&self,
) -> &::buffa::MapView<'_, &'_ str, super::super::__buffa::view::ValueView<'_>> {
&self.0.reborrow().fields
}
}
impl ::core::convert::From<::buffa::OwnedView<StructView<'static>>> for StructOwnedView {
fn from(inner: ::buffa::OwnedView<StructView<'static>>) -> Self {
StructOwnedView(inner)
}
}
impl ::core::convert::From<StructOwnedView> for ::buffa::OwnedView<StructView<'static>> {
fn from(wrapper: StructOwnedView) -> Self {
wrapper.0
}
}
impl ::core::convert::AsRef<::buffa::OwnedView<StructView<'static>>>
for StructOwnedView {
fn as_ref(&self) -> &::buffa::OwnedView<StructView<'static>> {
&self.0
}
}
impl ::buffa::HasMessageView for super::super::Struct {
type View<'a> = StructView<'a>;
type ViewHandle = StructOwnedView;
}
#[cfg(feature = "reflect")]
const _: () = {
impl<'a> ::buffa_descriptor::reflect::ReflectMessage for StructView<'a> {
fn message_descriptor(&self) -> &::buffa_descriptor::MessageDescriptor {
super::super::__buffa::reflect::descriptor_pool()
.message(Self::__buffa_reflect_message_index())
}
fn pool(
&self,
) -> &::buffa::alloc::sync::Arc<::buffa_descriptor::DescriptorPool> {
super::super::__buffa::reflect::descriptor_pool()
}
fn get(
&self,
field: &::buffa_descriptor::FieldDescriptor,
) -> ::buffa_descriptor::reflect::ValueRef<'_> {
#[allow(unused_imports)]
use ::buffa::Enumeration as _;
match field.number() {
1u32 => ::buffa_descriptor::reflect::ValueRef::Map(&self.fields),
_ => {
::core::debug_assert!(
false,
"field number {} is not a member of this view's reflect get()",
field.number(),
);
::buffa_descriptor::reflect::ValueRef::Bool(false)
}
}
}
fn has(&self, field: &::buffa_descriptor::FieldDescriptor) -> bool {
match field.number() {
1u32 => !::buffa::MapView::is_empty(&self.fields),
_ => false,
}
}
fn for_each_set(
&self,
f: &mut dyn ::core::ops::FnMut(
&::buffa_descriptor::FieldDescriptor,
::buffa_descriptor::reflect::ValueRef<'_>,
),
) {
let md = ::buffa_descriptor::reflect::ReflectMessage::message_descriptor(
self,
);
for fd in md.fields() {
if ::buffa_descriptor::reflect::ReflectMessage::has(self, fd) {
f(fd, ::buffa_descriptor::reflect::ReflectMessage::get(self, fd));
}
}
}
fn to_dynamic(&self) -> ::buffa_descriptor::reflect::DynamicMessage {
let bytes = ::buffa::ViewEncode::encode_to_vec(self);
let options = ::buffa::DecodeOptions::new()
.with_element_memory_limit(
bytes
.len()
.saturating_mul(128)
.max(::buffa::DEFAULT_ELEMENT_MEMORY_LIMIT),
)
.with_unknown_field_limit(
bytes.len().max(::buffa::DEFAULT_UNKNOWN_FIELD_LIMIT),
);
::buffa_descriptor::reflect::DynamicMessage::decode_with_options(
::buffa::alloc::sync::Arc::clone(
super::super::__buffa::reflect::descriptor_pool(),
),
Self::__buffa_reflect_message_index(),
&bytes,
&options,
)
.expect("view re-encodes to bytes decodable against its own descriptor")
}
}
impl<'a> ::buffa_descriptor::reflect::ReflectElement for StructView<'a> {
fn as_value_ref(&self) -> ::buffa_descriptor::reflect::ValueRef<'_> {
::buffa_descriptor::reflect::ValueRef::Message(
::buffa_descriptor::reflect::ReflectCow::Borrowed(self),
)
}
}
impl<'a> StructView<'a> {
#[doc(hidden)]
fn __buffa_reflect_message_index() -> ::buffa_descriptor::MessageIndex {
static IDX: ::std::sync::OnceLock<::buffa_descriptor::MessageIndex> = ::std::sync::OnceLock::new();
*IDX
.get_or_init(|| {
super::super::__buffa::reflect::descriptor_pool()
.message_index(<Self as ::buffa::MessageName>::FULL_NAME)
.expect(
"generated view type is registered in the embedded descriptor pool",
)
})
}
}
};
#[derive(Clone, Debug, Default)]
pub struct ValueView<'a> {
pub kind: ::core::option::Option<
super::super::__buffa::view::oneof::value::Kind<'a>,
>,
pub __buffa_unknown_fields: ::buffa::UnknownFieldsView<'a>,
}
impl<'a> ::buffa::MessageView<'a> for ValueView<'a> {
type Owned = super::super::Value;
fn decode_view(buf: &'a [u8]) -> ::core::result::Result<Self, ::buffa::DecodeError> {
let __limit = ::core::cell::Cell::new(::buffa::DEFAULT_UNKNOWN_FIELD_LIMIT);
let __elem = ::core::cell::Cell::new(::buffa::DEFAULT_ELEMENT_MEMORY_LIMIT);
<Self as ::buffa::MessageView>::decode_view_ctx(
buf,
::buffa::DecodeContext::new(::buffa::RECURSION_LIMIT, &__limit)
.with_element_memory(&__elem),
)
}
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)
}
#[inline]
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.kind = Some(
super::super::__buffa::view::oneof::value::Kind::NullValue(
::buffa::EnumValue::from(::buffa::types::decode_int32(&mut cur)?),
),
);
}
2u32 => {
::buffa::encoding::check_wire_type(
tag,
::buffa::encoding::WireType::Fixed64,
)?;
view.kind = Some(
super::super::__buffa::view::oneof::value::Kind::NumberValue(
::buffa::types::decode_double(&mut cur)?,
),
);
}
3u32 => {
::buffa::encoding::check_wire_type(
tag,
::buffa::encoding::WireType::LengthDelimited,
)?;
view.kind = Some(
super::super::__buffa::view::oneof::value::Kind::StringValue(
::buffa::types::borrow_str(&mut cur)?,
),
);
}
4u32 => {
::buffa::encoding::check_wire_type(
tag,
::buffa::encoding::WireType::Varint,
)?;
view.kind = Some(
super::super::__buffa::view::oneof::value::Kind::BoolValue(
::buffa::types::decode_bool(&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)?;
if let Some(
super::super::__buffa::view::oneof::value::Kind::StructValue(
ref mut existing,
),
) = view.kind
{
::buffa::MessageView::merge_into_view(
&mut **existing,
sub,
__sub_ctx,
)?;
} else {
view.kind = Some(
super::super::__buffa::view::oneof::value::Kind::StructValue(
::buffa::alloc::boxed::Box::new(
<super::super::__buffa::view::StructView as ::buffa::MessageView>::decode_view_ctx(
sub,
__sub_ctx,
)?,
),
),
);
}
}
6u32 => {
::buffa::encoding::check_wire_type(
tag,
::buffa::encoding::WireType::LengthDelimited,
)?;
let __sub_ctx = ctx.descend()?;
let sub = ::buffa::types::borrow_bytes(&mut cur)?;
if let Some(
super::super::__buffa::view::oneof::value::Kind::ListValue(
ref mut existing,
),
) = view.kind
{
::buffa::MessageView::merge_into_view(
&mut **existing,
sub,
__sub_ctx,
)?;
} else {
view.kind = Some(
super::super::__buffa::view::oneof::value::Kind::ListValue(
::buffa::alloc::boxed::Box::new(
<super::super::__buffa::view::ListValueView 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::Value, ::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::Value, ::buffa::DecodeError> {
#[allow(unused_imports)]
use ::buffa::alloc::string::ToString as _;
let _ = __buffa_src;
::core::result::Result::Ok(super::super::Value {
kind: match self.kind.as_ref() {
::core::option::Option::Some(v) => {
::core::option::Option::Some(
match v {
super::super::__buffa::view::oneof::value::Kind::NullValue(
v,
) => super::super::__buffa::oneof::value::Kind::NullValue(*v),
super::super::__buffa::view::oneof::value::Kind::NumberValue(
v,
) => {
super::super::__buffa::oneof::value::Kind::NumberValue(*v)
}
super::super::__buffa::view::oneof::value::Kind::StringValue(
v,
) => {
super::super::__buffa::oneof::value::Kind::StringValue(
v.to_string(),
)
}
super::super::__buffa::view::oneof::value::Kind::BoolValue(
v,
) => super::super::__buffa::oneof::value::Kind::BoolValue(*v),
super::super::__buffa::view::oneof::value::Kind::StructValue(
v,
) => {
super::super::__buffa::oneof::value::Kind::StructValue(
::buffa::alloc::boxed::Box::new(
v.to_owned_from_source(__buffa_src)?,
),
)
}
super::super::__buffa::view::oneof::value::Kind::ListValue(
v,
) => {
super::super::__buffa::oneof::value::Kind::ListValue(
::buffa::alloc::boxed::Box::new(
v.to_owned_from_source(__buffa_src)?,
),
)
}
},
)
}
::core::option::Option::None => ::core::option::Option::None,
},
__buffa_unknown_fields: self.__buffa_unknown_fields.to_owned()?.into(),
..::core::default::Default::default()
})
}
}
impl<'a> ::buffa::ViewEncode<'a> for ValueView<'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 = 0u64;
if let ::core::option::Option::Some(ref v) = self.kind {
match v {
super::super::__buffa::view::oneof::value::Kind::NullValue(x) => {
size += 1u64 + ::buffa::types::int32_encoded_len(x.to_i32()) as u64;
}
super::super::__buffa::view::oneof::value::Kind::NumberValue(_x) => {
size += 1u64 + ::buffa::types::FIXED64_ENCODED_LEN as u64;
}
super::super::__buffa::view::oneof::value::Kind::StringValue(x) => {
size += 1u64 + ::buffa::types::string_encoded_len(x) as u64;
}
super::super::__buffa::view::oneof::value::Kind::BoolValue(_x) => {
size += 1u64 + ::buffa::types::BOOL_ENCODED_LEN as u64;
}
super::super::__buffa::view::oneof::value::Kind::StructValue(x) => {
let __slot = __cache.reserve();
let inner = x.compute_size(__cache);
__cache.set(__slot, inner);
size
+= 1u64 + ::buffa::encoding::varint_len(inner as u64) as u64
+ inner as u64;
}
super::super::__buffa::view::oneof::value::Kind::ListValue(x) => {
let __slot = __cache.reserve();
let inner = x.compute_size(__cache);
__cache.set(__slot, inner);
size
+= 1u64 + ::buffa::encoding::varint_len(inner as u64) as u64
+ inner as u64;
}
}
}
size += self.__buffa_unknown_fields.encoded_len() as u64;
::buffa::saturate_size(size)
}
#[allow(clippy::needless_borrow)]
fn write_to(
&self,
__cache: &mut ::buffa::SizeCache,
buf: &mut impl ::buffa::EncodeSink,
) {
#[allow(unused_imports)]
use ::buffa::Enumeration as _;
if let ::core::option::Option::Some(ref v) = self.kind {
match v {
super::super::__buffa::view::oneof::value::Kind::NullValue(x) => {
::buffa::types::put_int32_field(1u32, x.to_i32(), buf);
}
super::super::__buffa::view::oneof::value::Kind::NumberValue(x) => {
::buffa::types::put_double_field(2u32, *x, buf);
}
super::super::__buffa::view::oneof::value::Kind::StringValue(x) => {
::buffa::types::put_string_field(3u32, x, buf);
}
super::super::__buffa::view::oneof::value::Kind::BoolValue(x) => {
::buffa::types::put_bool_field(4u32, *x, buf);
}
super::super::__buffa::view::oneof::value::Kind::StructValue(x) => {
::buffa::types::put_len_delimited_header(
5u32,
u64::from(__cache.consume_next()),
buf,
);
x.write_to(__cache, buf);
}
super::super::__buffa::view::oneof::value::Kind::ListValue(x) => {
::buffa::types::put_len_delimited_header(
6u32,
u64::from(__cache.consume_next()),
buf,
);
x.write_to(__cache, buf);
}
}
}
self.__buffa_unknown_fields.write_to(buf);
}
}
impl<'a> ::buffa::MessageName for ValueView<'a> {
const PACKAGE: &'static str = "google.protobuf";
const NAME: &'static str = "Value";
const FULL_NAME: &'static str = "google.protobuf.Value";
const TYPE_URL: &'static str = "type.googleapis.com/google.protobuf.Value";
}
::buffa::impl_default_view_instance!(ValueView);
::buffa::impl_view_reborrow!(ValueView);
#[derive(Clone, Debug)]
pub struct ValueOwnedView(::buffa::OwnedView<ValueView<'static>>);
impl ValueOwnedView {
pub fn decode(
bytes: ::buffa::bytes::Bytes,
) -> ::core::result::Result<Self, ::buffa::DecodeError> {
::core::result::Result::Ok(ValueOwnedView(::buffa::OwnedView::decode(bytes)?))
}
pub fn decode_with_options(
bytes: ::buffa::bytes::Bytes,
opts: &::buffa::DecodeOptions,
) -> ::core::result::Result<Self, ::buffa::DecodeError> {
::core::result::Result::Ok(
ValueOwnedView(::buffa::OwnedView::decode_with_options(bytes, opts)?),
)
}
pub fn from_owned(
msg: &super::super::Value,
) -> ::core::result::Result<Self, ::buffa::DecodeError> {
::core::result::Result::Ok(ValueOwnedView(::buffa::OwnedView::from_owned(msg)?))
}
#[must_use]
pub fn view(&self) -> &ValueView<'_> {
self.0.reborrow()
}
#[must_use]
pub fn to_owned_message(&self) -> super::super::Value {
self.0.to_owned_message()
}
#[must_use]
pub fn bytes(&self) -> &::buffa::bytes::Bytes {
self.0.bytes()
}
#[must_use]
pub fn into_bytes(self) -> ::buffa::bytes::Bytes {
self.0.into_bytes()
}
#[must_use]
pub fn kind(
&self,
) -> ::core::option::Option<&super::super::__buffa::view::oneof::value::Kind<'_>> {
self.0.reborrow().kind.as_ref()
}
}
impl ::core::convert::From<::buffa::OwnedView<ValueView<'static>>> for ValueOwnedView {
fn from(inner: ::buffa::OwnedView<ValueView<'static>>) -> Self {
ValueOwnedView(inner)
}
}
impl ::core::convert::From<ValueOwnedView> for ::buffa::OwnedView<ValueView<'static>> {
fn from(wrapper: ValueOwnedView) -> Self {
wrapper.0
}
}
impl ::core::convert::AsRef<::buffa::OwnedView<ValueView<'static>>> for ValueOwnedView {
fn as_ref(&self) -> &::buffa::OwnedView<ValueView<'static>> {
&self.0
}
}
impl ::buffa::HasMessageView for super::super::Value {
type View<'a> = ValueView<'a>;
type ViewHandle = ValueOwnedView;
}
#[cfg(feature = "reflect")]
const _: () = {
impl<'a> ::buffa_descriptor::reflect::ReflectMessage for ValueView<'a> {
fn message_descriptor(&self) -> &::buffa_descriptor::MessageDescriptor {
super::super::__buffa::reflect::descriptor_pool()
.message(Self::__buffa_reflect_message_index())
}
fn pool(
&self,
) -> &::buffa::alloc::sync::Arc<::buffa_descriptor::DescriptorPool> {
super::super::__buffa::reflect::descriptor_pool()
}
fn get(
&self,
field: &::buffa_descriptor::FieldDescriptor,
) -> ::buffa_descriptor::reflect::ValueRef<'_> {
#[allow(unused_imports)]
use ::buffa::Enumeration as _;
match field.number() {
1u32 => {
match &self.kind {
::core::option::Option::Some(
super::super::__buffa::view::oneof::value::Kind::NullValue(v),
) => {
::buffa_descriptor::reflect::ValueRef::EnumNumber(v.to_i32())
}
_ => ::buffa_descriptor::reflect::ValueRef::EnumNumber(0),
}
}
2u32 => {
match &self.kind {
::core::option::Option::Some(
super::super::__buffa::view::oneof::value::Kind::NumberValue(
v,
),
) => ::buffa_descriptor::reflect::ValueRef::F64(*v),
_ => ::buffa_descriptor::reflect::ValueRef::F64(0.0),
}
}
3u32 => {
match &self.kind {
::core::option::Option::Some(
super::super::__buffa::view::oneof::value::Kind::StringValue(
v,
),
) => ::buffa_descriptor::reflect::ValueRef::String(v),
_ => ::buffa_descriptor::reflect::ValueRef::String(""),
}
}
4u32 => {
match &self.kind {
::core::option::Option::Some(
super::super::__buffa::view::oneof::value::Kind::BoolValue(v),
) => ::buffa_descriptor::reflect::ValueRef::Bool(*v),
_ => ::buffa_descriptor::reflect::ValueRef::Bool(false),
}
}
5u32 => {
match &self.kind {
::core::option::Option::Some(
super::super::__buffa::view::oneof::value::Kind::StructValue(
v,
),
) => {
::buffa_descriptor::reflect::ValueRef::Message(
::buffa_descriptor::reflect::ReflectCow::Borrowed(&**v),
)
}
_ => {
::buffa_descriptor::reflect::ValueRef::Message(
::buffa_descriptor::reflect::ReflectCow::Borrowed(
<super::super::__buffa::view::StructView<
'a,
> as ::buffa::view::DefaultViewInstance>::default_view_instance(),
),
)
}
}
}
6u32 => {
match &self.kind {
::core::option::Option::Some(
super::super::__buffa::view::oneof::value::Kind::ListValue(v),
) => {
::buffa_descriptor::reflect::ValueRef::Message(
::buffa_descriptor::reflect::ReflectCow::Borrowed(&**v),
)
}
_ => {
::buffa_descriptor::reflect::ValueRef::Message(
::buffa_descriptor::reflect::ReflectCow::Borrowed(
<super::super::__buffa::view::ListValueView<
'a,
> as ::buffa::view::DefaultViewInstance>::default_view_instance(),
),
)
}
}
}
_ => {
::core::debug_assert!(
false,
"field number {} is not a member of this view's reflect get()",
field.number(),
);
::buffa_descriptor::reflect::ValueRef::Bool(false)
}
}
}
fn has(&self, field: &::buffa_descriptor::FieldDescriptor) -> bool {
match field.number() {
1u32 => {
::core::matches!(
& self.kind,
::core::option::Option::Some(super::super::__buffa::view::oneof::value::Kind::NullValue(_))
)
}
2u32 => {
::core::matches!(
& self.kind,
::core::option::Option::Some(super::super::__buffa::view::oneof::value::Kind::NumberValue(_))
)
}
3u32 => {
::core::matches!(
& self.kind,
::core::option::Option::Some(super::super::__buffa::view::oneof::value::Kind::StringValue(_))
)
}
4u32 => {
::core::matches!(
& self.kind,
::core::option::Option::Some(super::super::__buffa::view::oneof::value::Kind::BoolValue(_))
)
}
5u32 => {
::core::matches!(
& self.kind,
::core::option::Option::Some(super::super::__buffa::view::oneof::value::Kind::StructValue(_))
)
}
6u32 => {
::core::matches!(
& self.kind,
::core::option::Option::Some(super::super::__buffa::view::oneof::value::Kind::ListValue(_))
)
}
_ => false,
}
}
fn for_each_set(
&self,
f: &mut dyn ::core::ops::FnMut(
&::buffa_descriptor::FieldDescriptor,
::buffa_descriptor::reflect::ValueRef<'_>,
),
) {
let md = ::buffa_descriptor::reflect::ReflectMessage::message_descriptor(
self,
);
for fd in md.fields() {
if ::buffa_descriptor::reflect::ReflectMessage::has(self, fd) {
f(fd, ::buffa_descriptor::reflect::ReflectMessage::get(self, fd));
}
}
}
fn to_dynamic(&self) -> ::buffa_descriptor::reflect::DynamicMessage {
let bytes = ::buffa::ViewEncode::encode_to_vec(self);
let options = ::buffa::DecodeOptions::new()
.with_element_memory_limit(
bytes
.len()
.saturating_mul(128)
.max(::buffa::DEFAULT_ELEMENT_MEMORY_LIMIT),
)
.with_unknown_field_limit(
bytes.len().max(::buffa::DEFAULT_UNKNOWN_FIELD_LIMIT),
);
::buffa_descriptor::reflect::DynamicMessage::decode_with_options(
::buffa::alloc::sync::Arc::clone(
super::super::__buffa::reflect::descriptor_pool(),
),
Self::__buffa_reflect_message_index(),
&bytes,
&options,
)
.expect("view re-encodes to bytes decodable against its own descriptor")
}
}
impl<'a> ::buffa_descriptor::reflect::ReflectElement for ValueView<'a> {
fn as_value_ref(&self) -> ::buffa_descriptor::reflect::ValueRef<'_> {
::buffa_descriptor::reflect::ValueRef::Message(
::buffa_descriptor::reflect::ReflectCow::Borrowed(self),
)
}
}
impl<'a> ValueView<'a> {
#[doc(hidden)]
fn __buffa_reflect_message_index() -> ::buffa_descriptor::MessageIndex {
static IDX: ::std::sync::OnceLock<::buffa_descriptor::MessageIndex> = ::std::sync::OnceLock::new();
*IDX
.get_or_init(|| {
super::super::__buffa::reflect::descriptor_pool()
.message_index(<Self as ::buffa::MessageName>::FULL_NAME)
.expect(
"generated view type is registered in the embedded descriptor pool",
)
})
}
}
};
#[derive(Clone, Debug, Default)]
pub struct ListValueView<'a> {
pub values: ::buffa::RepeatedView<'a, super::super::__buffa::view::ValueView<'a>>,
pub __buffa_unknown_fields: ::buffa::UnknownFieldsView<'a>,
}
impl<'a> ::buffa::MessageView<'a> for ListValueView<'a> {
type Owned = super::super::ListValue;
fn decode_view(buf: &'a [u8]) -> ::core::result::Result<Self, ::buffa::DecodeError> {
let __limit = ::core::cell::Cell::new(::buffa::DEFAULT_UNKNOWN_FIELD_LIMIT);
let __elem = ::core::cell::Cell::new(::buffa::DEFAULT_ELEMENT_MEMORY_LIMIT);
<Self as ::buffa::MessageView>::decode_view_ctx(
buf,
::buffa::DecodeContext::new(::buffa::RECURSION_LIMIT, &__limit)
.with_element_memory(&__elem),
)
}
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)
}
#[inline]
fn merge_view_field(
&mut self,
tag: ::buffa::encoding::Tag,
cur: &'a [u8],
before_tag: &'a [u8],
ctx: ::buffa::DecodeContext<'_>,
) -> ::core::result::Result<&'a [u8], ::buffa::DecodeError> {
let _ = ctx;
#[allow(unused_variables)]
let view = self;
let mut cur = cur;
match tag.field_number() {
1u32 => {
::buffa::encoding::check_wire_type(
tag,
::buffa::encoding::WireType::LengthDelimited,
)?;
let __sub_ctx = ctx.descend()?;
let sub = ::buffa::types::borrow_bytes(&mut cur)?;
ctx.register_element_memory(
::core::mem::size_of::<super::super::__buffa::view::ValueView>(),
)?;
view.values
.push(
<super::super::__buffa::view::ValueView 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::ListValue, ::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::ListValue, ::buffa::DecodeError> {
#[allow(unused_imports)]
use ::buffa::alloc::string::ToString as _;
let _ = __buffa_src;
::core::result::Result::Ok(super::super::ListValue {
values: self
.values
.iter()
.map(|v| v.to_owned_from_source(__buffa_src))
.collect::<::core::result::Result<_, ::buffa::DecodeError>>()?,
__buffa_unknown_fields: self.__buffa_unknown_fields.to_owned()?.into(),
..::core::default::Default::default()
})
}
}
impl<'a> ::buffa::ViewEncode<'a> for ListValueView<'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 = 0u64;
for v in &self.values {
let __slot = __cache.reserve();
let inner_size = v.compute_size(__cache);
__cache.set(__slot, inner_size);
size
+= 1u64 + ::buffa::encoding::varint_len(inner_size as u64) as u64
+ inner_size as u64;
}
size += self.__buffa_unknown_fields.encoded_len() as u64;
::buffa::saturate_size(size)
}
#[allow(clippy::needless_borrow)]
fn write_to(
&self,
__cache: &mut ::buffa::SizeCache,
buf: &mut impl ::buffa::EncodeSink,
) {
#[allow(unused_imports)]
use ::buffa::Enumeration as _;
for v in &self.values {
::buffa::types::put_len_delimited_header(
1u32,
u64::from(__cache.consume_next()),
buf,
);
v.write_to(__cache, buf);
}
self.__buffa_unknown_fields.write_to(buf);
}
}
impl<'a> ::buffa::MessageName for ListValueView<'a> {
const PACKAGE: &'static str = "google.protobuf";
const NAME: &'static str = "ListValue";
const FULL_NAME: &'static str = "google.protobuf.ListValue";
const TYPE_URL: &'static str = "type.googleapis.com/google.protobuf.ListValue";
}
::buffa::impl_default_view_instance!(ListValueView);
::buffa::impl_view_reborrow!(ListValueView);
#[derive(Clone, Debug)]
pub struct ListValueOwnedView(::buffa::OwnedView<ListValueView<'static>>);
impl ListValueOwnedView {
pub fn decode(
bytes: ::buffa::bytes::Bytes,
) -> ::core::result::Result<Self, ::buffa::DecodeError> {
::core::result::Result::Ok(
ListValueOwnedView(::buffa::OwnedView::decode(bytes)?),
)
}
pub fn decode_with_options(
bytes: ::buffa::bytes::Bytes,
opts: &::buffa::DecodeOptions,
) -> ::core::result::Result<Self, ::buffa::DecodeError> {
::core::result::Result::Ok(
ListValueOwnedView(::buffa::OwnedView::decode_with_options(bytes, opts)?),
)
}
pub fn from_owned(
msg: &super::super::ListValue,
) -> ::core::result::Result<Self, ::buffa::DecodeError> {
::core::result::Result::Ok(
ListValueOwnedView(::buffa::OwnedView::from_owned(msg)?),
)
}
#[must_use]
pub fn view(&self) -> &ListValueView<'_> {
self.0.reborrow()
}
#[must_use]
pub fn to_owned_message(&self) -> super::super::ListValue {
self.0.to_owned_message()
}
#[must_use]
pub fn bytes(&self) -> &::buffa::bytes::Bytes {
self.0.bytes()
}
#[must_use]
pub fn into_bytes(self) -> ::buffa::bytes::Bytes {
self.0.into_bytes()
}
#[must_use]
pub fn values(
&self,
) -> &::buffa::RepeatedView<'_, super::super::__buffa::view::ValueView<'_>> {
&self.0.reborrow().values
}
}
impl ::core::convert::From<::buffa::OwnedView<ListValueView<'static>>>
for ListValueOwnedView {
fn from(inner: ::buffa::OwnedView<ListValueView<'static>>) -> Self {
ListValueOwnedView(inner)
}
}
impl ::core::convert::From<ListValueOwnedView>
for ::buffa::OwnedView<ListValueView<'static>> {
fn from(wrapper: ListValueOwnedView) -> Self {
wrapper.0
}
}
impl ::core::convert::AsRef<::buffa::OwnedView<ListValueView<'static>>>
for ListValueOwnedView {
fn as_ref(&self) -> &::buffa::OwnedView<ListValueView<'static>> {
&self.0
}
}
impl ::buffa::HasMessageView for super::super::ListValue {
type View<'a> = ListValueView<'a>;
type ViewHandle = ListValueOwnedView;
}
#[cfg(feature = "reflect")]
const _: () = {
impl<'a> ::buffa_descriptor::reflect::ReflectMessage for ListValueView<'a> {
fn message_descriptor(&self) -> &::buffa_descriptor::MessageDescriptor {
super::super::__buffa::reflect::descriptor_pool()
.message(Self::__buffa_reflect_message_index())
}
fn pool(
&self,
) -> &::buffa::alloc::sync::Arc<::buffa_descriptor::DescriptorPool> {
super::super::__buffa::reflect::descriptor_pool()
}
fn get(
&self,
field: &::buffa_descriptor::FieldDescriptor,
) -> ::buffa_descriptor::reflect::ValueRef<'_> {
#[allow(unused_imports)]
use ::buffa::Enumeration as _;
match field.number() {
1u32 => ::buffa_descriptor::reflect::ValueRef::List(&self.values),
_ => {
::core::debug_assert!(
false,
"field number {} is not a member of this view's reflect get()",
field.number(),
);
::buffa_descriptor::reflect::ValueRef::Bool(false)
}
}
}
fn has(&self, field: &::buffa_descriptor::FieldDescriptor) -> bool {
match field.number() {
1u32 => !::buffa::RepeatedView::is_empty(&self.values),
_ => false,
}
}
fn for_each_set(
&self,
f: &mut dyn ::core::ops::FnMut(
&::buffa_descriptor::FieldDescriptor,
::buffa_descriptor::reflect::ValueRef<'_>,
),
) {
let md = ::buffa_descriptor::reflect::ReflectMessage::message_descriptor(
self,
);
for fd in md.fields() {
if ::buffa_descriptor::reflect::ReflectMessage::has(self, fd) {
f(fd, ::buffa_descriptor::reflect::ReflectMessage::get(self, fd));
}
}
}
fn to_dynamic(&self) -> ::buffa_descriptor::reflect::DynamicMessage {
let bytes = ::buffa::ViewEncode::encode_to_vec(self);
let options = ::buffa::DecodeOptions::new()
.with_element_memory_limit(
bytes
.len()
.saturating_mul(128)
.max(::buffa::DEFAULT_ELEMENT_MEMORY_LIMIT),
)
.with_unknown_field_limit(
bytes.len().max(::buffa::DEFAULT_UNKNOWN_FIELD_LIMIT),
);
::buffa_descriptor::reflect::DynamicMessage::decode_with_options(
::buffa::alloc::sync::Arc::clone(
super::super::__buffa::reflect::descriptor_pool(),
),
Self::__buffa_reflect_message_index(),
&bytes,
&options,
)
.expect("view re-encodes to bytes decodable against its own descriptor")
}
}
impl<'a> ::buffa_descriptor::reflect::ReflectElement for ListValueView<'a> {
fn as_value_ref(&self) -> ::buffa_descriptor::reflect::ValueRef<'_> {
::buffa_descriptor::reflect::ValueRef::Message(
::buffa_descriptor::reflect::ReflectCow::Borrowed(self),
)
}
}
impl<'a> ListValueView<'a> {
#[doc(hidden)]
fn __buffa_reflect_message_index() -> ::buffa_descriptor::MessageIndex {
static IDX: ::std::sync::OnceLock<::buffa_descriptor::MessageIndex> = ::std::sync::OnceLock::new();
*IDX
.get_or_init(|| {
super::super::__buffa::reflect::descriptor_pool()
.message_index(<Self as ::buffa::MessageName>::FULL_NAME)
.expect(
"generated view type is registered in the embedded descriptor pool",
)
})
}
}
};