#[derive(Clone, Debug, Default)]
pub struct ServerReflectionRequestView<'a> {
pub host: &'a str,
pub message_request: ::core::option::Option<
super::super::__buffa::view::oneof::server_reflection_request::MessageRequest<'a>,
>,
pub __buffa_unknown_fields: ::buffa::UnknownFieldsView<'a>,
}
impl<'a> ::buffa::MessageView<'a> for ServerReflectionRequestView<'a> {
type Owned = super::super::ServerReflectionRequest;
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.host = ::buffa::types::borrow_str(&mut cur)?;
}
3u32 => {
::buffa::encoding::check_wire_type(
tag,
::buffa::encoding::WireType::LengthDelimited,
)?;
view.message_request = Some(
super::super::__buffa::view::oneof::server_reflection_request::MessageRequest::FileByFilename(
::buffa::types::borrow_str(&mut cur)?,
),
);
}
4u32 => {
::buffa::encoding::check_wire_type(
tag,
::buffa::encoding::WireType::LengthDelimited,
)?;
view.message_request = Some(
super::super::__buffa::view::oneof::server_reflection_request::MessageRequest::FileContainingSymbol(
::buffa::types::borrow_str(&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::server_reflection_request::MessageRequest::FileContainingExtension(
ref mut existing,
),
) = view.message_request
{
::buffa::MessageView::merge_into_view(
&mut **existing,
sub,
__sub_ctx,
)?;
} else {
view.message_request = Some(
super::super::__buffa::view::oneof::server_reflection_request::MessageRequest::FileContainingExtension(
::buffa::alloc::boxed::Box::new(
<super::super::__buffa::view::ExtensionRequestView as ::buffa::MessageView>::decode_view_ctx(
sub,
__sub_ctx,
)?,
),
),
);
}
}
6u32 => {
::buffa::encoding::check_wire_type(
tag,
::buffa::encoding::WireType::LengthDelimited,
)?;
view.message_request = Some(
super::super::__buffa::view::oneof::server_reflection_request::MessageRequest::AllExtensionNumbersOfType(
::buffa::types::borrow_str(&mut cur)?,
),
);
}
7u32 => {
::buffa::encoding::check_wire_type(
tag,
::buffa::encoding::WireType::LengthDelimited,
)?;
view.message_request = Some(
super::super::__buffa::view::oneof::server_reflection_request::MessageRequest::ListServices(
::buffa::types::borrow_str(&mut cur)?,
),
);
}
_ => {
::buffa::encoding::skip_field_depth(tag, &mut cur, ctx.depth())?;
let span_len = before_tag.len() - cur.len();
view.__buffa_unknown_fields.push_record(before_tag, span_len, ctx)?;
}
}
::core::result::Result::Ok(cur)
}
fn to_owned_message(
&self,
) -> ::core::result::Result<
super::super::ServerReflectionRequest,
::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::ServerReflectionRequest,
::buffa::DecodeError,
> {
#[allow(unused_imports)]
use ::buffa::alloc::string::ToString as _;
let _ = __buffa_src;
::core::result::Result::Ok(super::super::ServerReflectionRequest {
host: self.host.to_string(),
message_request: match self.message_request.as_ref() {
::core::option::Option::Some(v) => {
::core::option::Option::Some(
match v {
super::super::__buffa::view::oneof::server_reflection_request::MessageRequest::FileByFilename(
v,
) => {
super::super::__buffa::oneof::server_reflection_request::MessageRequest::FileByFilename(
v.to_string(),
)
}
super::super::__buffa::view::oneof::server_reflection_request::MessageRequest::FileContainingSymbol(
v,
) => {
super::super::__buffa::oneof::server_reflection_request::MessageRequest::FileContainingSymbol(
v.to_string(),
)
}
super::super::__buffa::view::oneof::server_reflection_request::MessageRequest::FileContainingExtension(
v,
) => {
super::super::__buffa::oneof::server_reflection_request::MessageRequest::FileContainingExtension(
::buffa::alloc::boxed::Box::new(
v.to_owned_from_source(__buffa_src)?,
),
)
}
super::super::__buffa::view::oneof::server_reflection_request::MessageRequest::AllExtensionNumbersOfType(
v,
) => {
super::super::__buffa::oneof::server_reflection_request::MessageRequest::AllExtensionNumbersOfType(
v.to_string(),
)
}
super::super::__buffa::view::oneof::server_reflection_request::MessageRequest::ListServices(
v,
) => {
super::super::__buffa::oneof::server_reflection_request::MessageRequest::ListServices(
v.to_string(),
)
}
},
)
}
::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 ServerReflectionRequestView<'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.host.is_empty() {
size += 1u32 + ::buffa::types::string_encoded_len(&self.host) as u32;
}
if let ::core::option::Option::Some(ref v) = self.message_request {
match v {
super::super::__buffa::view::oneof::server_reflection_request::MessageRequest::FileByFilename(
x,
) => {
size += 1u32 + ::buffa::types::string_encoded_len(x) as u32;
}
super::super::__buffa::view::oneof::server_reflection_request::MessageRequest::FileContainingSymbol(
x,
) => {
size += 1u32 + ::buffa::types::string_encoded_len(x) as u32;
}
super::super::__buffa::view::oneof::server_reflection_request::MessageRequest::FileContainingExtension(
x,
) => {
let __slot = __cache.reserve();
let inner = x.compute_size(__cache);
__cache.set(__slot, inner);
size
+= 1u32 + ::buffa::encoding::varint_len(inner as u64) as u32
+ inner;
}
super::super::__buffa::view::oneof::server_reflection_request::MessageRequest::AllExtensionNumbersOfType(
x,
) => {
size += 1u32 + ::buffa::types::string_encoded_len(x) as u32;
}
super::super::__buffa::view::oneof::server_reflection_request::MessageRequest::ListServices(
x,
) => {
size += 1u32 + ::buffa::types::string_encoded_len(x) 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.host.is_empty() {
::buffa::types::put_string_field(1u32, &self.host, buf);
}
if let ::core::option::Option::Some(ref v) = self.message_request {
match v {
super::super::__buffa::view::oneof::server_reflection_request::MessageRequest::FileByFilename(
x,
) => {
::buffa::types::put_string_field(3u32, x, buf);
}
super::super::__buffa::view::oneof::server_reflection_request::MessageRequest::FileContainingSymbol(
x,
) => {
::buffa::types::put_string_field(4u32, x, buf);
}
super::super::__buffa::view::oneof::server_reflection_request::MessageRequest::FileContainingExtension(
x,
) => {
::buffa::types::put_len_delimited_header(
5u32,
__cache.consume_next(),
buf,
);
x.write_to(__cache, buf);
}
super::super::__buffa::view::oneof::server_reflection_request::MessageRequest::AllExtensionNumbersOfType(
x,
) => {
::buffa::types::put_string_field(6u32, x, buf);
}
super::super::__buffa::view::oneof::server_reflection_request::MessageRequest::ListServices(
x,
) => {
::buffa::types::put_string_field(7u32, x, buf);
}
}
}
self.__buffa_unknown_fields.write_to(buf);
}
}
impl<'__a> ::serde::Serialize for ServerReflectionRequestView<'__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.host) {
__map.serialize_entry("host", self.host)?;
}
if let ::core::option::Option::Some(ref __ov) = self.message_request {
match __ov {
super::super::__buffa::view::oneof::server_reflection_request::MessageRequest::FileByFilename(
v,
) => {
__map.serialize_entry("fileByFilename", v)?;
}
super::super::__buffa::view::oneof::server_reflection_request::MessageRequest::FileContainingSymbol(
v,
) => {
__map.serialize_entry("fileContainingSymbol", v)?;
}
super::super::__buffa::view::oneof::server_reflection_request::MessageRequest::FileContainingExtension(
v,
) => {
__map.serialize_entry("fileContainingExtension", v)?;
}
super::super::__buffa::view::oneof::server_reflection_request::MessageRequest::AllExtensionNumbersOfType(
v,
) => {
__map.serialize_entry("allExtensionNumbersOfType", v)?;
}
super::super::__buffa::view::oneof::server_reflection_request::MessageRequest::ListServices(
v,
) => {
__map.serialize_entry("listServices", v)?;
}
}
}
__map.end()
}
}
impl<'a> ::buffa::MessageName for ServerReflectionRequestView<'a> {
const PACKAGE: &'static str = "grpc.reflection.v1alpha";
const NAME: &'static str = "ServerReflectionRequest";
const FULL_NAME: &'static str = "grpc.reflection.v1alpha.ServerReflectionRequest";
const TYPE_URL: &'static str = "type.googleapis.com/grpc.reflection.v1alpha.ServerReflectionRequest";
}
::buffa::impl_default_view_instance!(ServerReflectionRequestView);
::buffa::impl_view_reborrow!(ServerReflectionRequestView);
#[derive(Clone, Debug)]
pub struct ServerReflectionRequestOwnedView(
::buffa::OwnedView<ServerReflectionRequestView<'static>>,
);
impl ServerReflectionRequestOwnedView {
pub fn decode(
bytes: ::buffa::bytes::Bytes,
) -> ::core::result::Result<Self, ::buffa::DecodeError> {
::core::result::Result::Ok(
ServerReflectionRequestOwnedView(::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(
ServerReflectionRequestOwnedView(
::buffa::OwnedView::decode_with_options(bytes, opts)?,
),
)
}
pub fn from_owned(
msg: &super::super::ServerReflectionRequest,
) -> ::core::result::Result<Self, ::buffa::DecodeError> {
::core::result::Result::Ok(
ServerReflectionRequestOwnedView(::buffa::OwnedView::from_owned(msg)?),
)
}
#[must_use]
pub fn view(&self) -> &ServerReflectionRequestView<'_> {
self.0.reborrow()
}
pub fn to_owned_message(
&self,
) -> ::core::result::Result<
super::super::ServerReflectionRequest,
::buffa::DecodeError,
> {
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 host(&self) -> &'_ str {
self.0.reborrow().host
}
#[must_use]
pub fn message_request(
&self,
) -> ::core::option::Option<
&super::super::__buffa::view::oneof::server_reflection_request::MessageRequest<
'_,
>,
> {
self.0.reborrow().message_request.as_ref()
}
}
impl ::core::convert::From<::buffa::OwnedView<ServerReflectionRequestView<'static>>>
for ServerReflectionRequestOwnedView {
fn from(inner: ::buffa::OwnedView<ServerReflectionRequestView<'static>>) -> Self {
ServerReflectionRequestOwnedView(inner)
}
}
impl ::core::convert::From<ServerReflectionRequestOwnedView>
for ::buffa::OwnedView<ServerReflectionRequestView<'static>> {
fn from(wrapper: ServerReflectionRequestOwnedView) -> Self {
wrapper.0
}
}
impl ::core::convert::AsRef<::buffa::OwnedView<ServerReflectionRequestView<'static>>>
for ServerReflectionRequestOwnedView {
fn as_ref(&self) -> &::buffa::OwnedView<ServerReflectionRequestView<'static>> {
&self.0
}
}
impl ::buffa::HasMessageView for super::super::ServerReflectionRequest {
type View<'a> = ServerReflectionRequestView<'a>;
type ViewHandle = ServerReflectionRequestOwnedView;
}
impl ::serde::Serialize for ServerReflectionRequestOwnedView {
fn serialize<__S: ::serde::Serializer>(
&self,
__s: __S,
) -> ::core::result::Result<__S::Ok, __S::Error> {
::serde::Serialize::serialize(&self.0, __s)
}
}
#[derive(Clone, Debug, Default)]
pub struct ExtensionRequestView<'a> {
pub containing_type: &'a str,
pub extension_number: i32,
pub __buffa_unknown_fields: ::buffa::UnknownFieldsView<'a>,
}
impl<'a> ::buffa::MessageView<'a> for ExtensionRequestView<'a> {
type Owned = super::super::ExtensionRequest;
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.containing_type = ::buffa::types::borrow_str(&mut cur)?;
}
2u32 => {
::buffa::encoding::check_wire_type(
tag,
::buffa::encoding::WireType::Varint,
)?;
view.extension_number = ::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::ExtensionRequest, ::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::ExtensionRequest, ::buffa::DecodeError> {
#[allow(unused_imports)]
use ::buffa::alloc::string::ToString as _;
let _ = __buffa_src;
::core::result::Result::Ok(super::super::ExtensionRequest {
containing_type: self.containing_type.to_string(),
extension_number: self.extension_number,
__buffa_unknown_fields: self.__buffa_unknown_fields.to_owned()?.into(),
..::core::default::Default::default()
})
}
}
impl<'a> ::buffa::ViewEncode<'a> for ExtensionRequestView<'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.containing_type.is_empty() {
size
+= 1u32
+ ::buffa::types::string_encoded_len(&self.containing_type) as u32;
}
if self.extension_number != 0i32 {
size
+= 1u32
+ ::buffa::types::int32_encoded_len(self.extension_number) 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.containing_type.is_empty() {
::buffa::types::put_string_field(1u32, &self.containing_type, buf);
}
if self.extension_number != 0i32 {
::buffa::types::put_int32_field(2u32, self.extension_number, buf);
}
self.__buffa_unknown_fields.write_to(buf);
}
}
impl<'__a> ::serde::Serialize for ExtensionRequestView<'__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.containing_type) {
__map.serialize_entry("containingType", self.containing_type)?;
}
if !::buffa::json_helpers::skip_if::is_zero_i32(&self.extension_number) {
__map
.serialize_entry(
"extensionNumber",
&::buffa::json_helpers::ProtoJson(&self.extension_number),
)?;
}
__map.end()
}
}
impl<'a> ::buffa::MessageName for ExtensionRequestView<'a> {
const PACKAGE: &'static str = "grpc.reflection.v1alpha";
const NAME: &'static str = "ExtensionRequest";
const FULL_NAME: &'static str = "grpc.reflection.v1alpha.ExtensionRequest";
const TYPE_URL: &'static str = "type.googleapis.com/grpc.reflection.v1alpha.ExtensionRequest";
}
::buffa::impl_default_view_instance!(ExtensionRequestView);
::buffa::impl_view_reborrow!(ExtensionRequestView);
#[derive(Clone, Debug)]
pub struct ExtensionRequestOwnedView(::buffa::OwnedView<ExtensionRequestView<'static>>);
impl ExtensionRequestOwnedView {
pub fn decode(
bytes: ::buffa::bytes::Bytes,
) -> ::core::result::Result<Self, ::buffa::DecodeError> {
::core::result::Result::Ok(
ExtensionRequestOwnedView(::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(
ExtensionRequestOwnedView(
::buffa::OwnedView::decode_with_options(bytes, opts)?,
),
)
}
pub fn from_owned(
msg: &super::super::ExtensionRequest,
) -> ::core::result::Result<Self, ::buffa::DecodeError> {
::core::result::Result::Ok(
ExtensionRequestOwnedView(::buffa::OwnedView::from_owned(msg)?),
)
}
#[must_use]
pub fn view(&self) -> &ExtensionRequestView<'_> {
self.0.reborrow()
}
pub fn to_owned_message(
&self,
) -> ::core::result::Result<super::super::ExtensionRequest, ::buffa::DecodeError> {
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 containing_type(&self) -> &'_ str {
self.0.reborrow().containing_type
}
#[must_use]
pub fn extension_number(&self) -> i32 {
self.0.reborrow().extension_number
}
}
impl ::core::convert::From<::buffa::OwnedView<ExtensionRequestView<'static>>>
for ExtensionRequestOwnedView {
fn from(inner: ::buffa::OwnedView<ExtensionRequestView<'static>>) -> Self {
ExtensionRequestOwnedView(inner)
}
}
impl ::core::convert::From<ExtensionRequestOwnedView>
for ::buffa::OwnedView<ExtensionRequestView<'static>> {
fn from(wrapper: ExtensionRequestOwnedView) -> Self {
wrapper.0
}
}
impl ::core::convert::AsRef<::buffa::OwnedView<ExtensionRequestView<'static>>>
for ExtensionRequestOwnedView {
fn as_ref(&self) -> &::buffa::OwnedView<ExtensionRequestView<'static>> {
&self.0
}
}
impl ::buffa::HasMessageView for super::super::ExtensionRequest {
type View<'a> = ExtensionRequestView<'a>;
type ViewHandle = ExtensionRequestOwnedView;
}
impl ::serde::Serialize for ExtensionRequestOwnedView {
fn serialize<__S: ::serde::Serializer>(
&self,
__s: __S,
) -> ::core::result::Result<__S::Ok, __S::Error> {
::serde::Serialize::serialize(&self.0, __s)
}
}
#[derive(Clone, Debug, Default)]
pub struct ServerReflectionResponseView<'a> {
pub valid_host: &'a str,
pub original_request: ::buffa::MessageFieldView<
super::super::__buffa::view::ServerReflectionRequestView<'a>,
>,
pub message_response: ::core::option::Option<
super::super::__buffa::view::oneof::server_reflection_response::MessageResponse<
'a,
>,
>,
pub __buffa_unknown_fields: ::buffa::UnknownFieldsView<'a>,
}
impl<'a> ::buffa::MessageView<'a> for ServerReflectionResponseView<'a> {
type Owned = super::super::ServerReflectionResponse;
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.valid_host = ::buffa::types::borrow_str(&mut cur)?;
}
2u32 => {
::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.original_request.as_mut() {
Some(existing) => {
::buffa::MessageView::merge_into_view(existing, sub, __sub_ctx)?
}
None => {
view.original_request = ::buffa::MessageFieldView::set(
<super::super::__buffa::view::ServerReflectionRequestView as ::buffa::MessageView>::decode_view_ctx(
sub,
__sub_ctx,
)?,
);
}
}
}
4u32 => {
::buffa::encoding::check_wire_type(
tag,
::buffa::encoding::WireType::LengthDelimited,
)?;
let __sub_ctx = ctx.descend()?;
let sub = ::buffa::types::borrow_bytes(&mut cur)?;
if let Some(
super::super::__buffa::view::oneof::server_reflection_response::MessageResponse::FileDescriptorResponse(
ref mut existing,
),
) = view.message_response
{
::buffa::MessageView::merge_into_view(
&mut **existing,
sub,
__sub_ctx,
)?;
} else {
view.message_response = Some(
super::super::__buffa::view::oneof::server_reflection_response::MessageResponse::FileDescriptorResponse(
::buffa::alloc::boxed::Box::new(
<super::super::__buffa::view::FileDescriptorResponseView 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)?;
if let Some(
super::super::__buffa::view::oneof::server_reflection_response::MessageResponse::AllExtensionNumbersResponse(
ref mut existing,
),
) = view.message_response
{
::buffa::MessageView::merge_into_view(
&mut **existing,
sub,
__sub_ctx,
)?;
} else {
view.message_response = Some(
super::super::__buffa::view::oneof::server_reflection_response::MessageResponse::AllExtensionNumbersResponse(
::buffa::alloc::boxed::Box::new(
<super::super::__buffa::view::ExtensionNumberResponseView 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::server_reflection_response::MessageResponse::ListServicesResponse(
ref mut existing,
),
) = view.message_response
{
::buffa::MessageView::merge_into_view(
&mut **existing,
sub,
__sub_ctx,
)?;
} else {
view.message_response = Some(
super::super::__buffa::view::oneof::server_reflection_response::MessageResponse::ListServicesResponse(
::buffa::alloc::boxed::Box::new(
<super::super::__buffa::view::ListServiceResponseView as ::buffa::MessageView>::decode_view_ctx(
sub,
__sub_ctx,
)?,
),
),
);
}
}
7u32 => {
::buffa::encoding::check_wire_type(
tag,
::buffa::encoding::WireType::LengthDelimited,
)?;
let __sub_ctx = ctx.descend()?;
let sub = ::buffa::types::borrow_bytes(&mut cur)?;
if let Some(
super::super::__buffa::view::oneof::server_reflection_response::MessageResponse::ErrorResponse(
ref mut existing,
),
) = view.message_response
{
::buffa::MessageView::merge_into_view(
&mut **existing,
sub,
__sub_ctx,
)?;
} else {
view.message_response = Some(
super::super::__buffa::view::oneof::server_reflection_response::MessageResponse::ErrorResponse(
::buffa::alloc::boxed::Box::new(
<super::super::__buffa::view::ErrorResponseView 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::ServerReflectionResponse,
::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::ServerReflectionResponse,
::buffa::DecodeError,
> {
#[allow(unused_imports)]
use ::buffa::alloc::string::ToString as _;
let _ = __buffa_src;
::core::result::Result::Ok(super::super::ServerReflectionResponse {
valid_host: self.valid_host.to_string(),
original_request: match self.original_request.as_option() {
Some(v) => {
::buffa::MessageField::<
super::super::ServerReflectionRequest,
>::some(v.to_owned_from_source(__buffa_src)?)
}
None => ::buffa::MessageField::none(),
},
message_response: match self.message_response.as_ref() {
::core::option::Option::Some(v) => {
::core::option::Option::Some(
match v {
super::super::__buffa::view::oneof::server_reflection_response::MessageResponse::FileDescriptorResponse(
v,
) => {
super::super::__buffa::oneof::server_reflection_response::MessageResponse::FileDescriptorResponse(
::buffa::alloc::boxed::Box::new(
v.to_owned_from_source(__buffa_src)?,
),
)
}
super::super::__buffa::view::oneof::server_reflection_response::MessageResponse::AllExtensionNumbersResponse(
v,
) => {
super::super::__buffa::oneof::server_reflection_response::MessageResponse::AllExtensionNumbersResponse(
::buffa::alloc::boxed::Box::new(
v.to_owned_from_source(__buffa_src)?,
),
)
}
super::super::__buffa::view::oneof::server_reflection_response::MessageResponse::ListServicesResponse(
v,
) => {
super::super::__buffa::oneof::server_reflection_response::MessageResponse::ListServicesResponse(
::buffa::alloc::boxed::Box::new(
v.to_owned_from_source(__buffa_src)?,
),
)
}
super::super::__buffa::view::oneof::server_reflection_response::MessageResponse::ErrorResponse(
v,
) => {
super::super::__buffa::oneof::server_reflection_response::MessageResponse::ErrorResponse(
::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 ServerReflectionResponseView<'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.valid_host.is_empty() {
size += 1u32 + ::buffa::types::string_encoded_len(&self.valid_host) as u32;
}
if self.original_request.is_set() {
let __slot = __cache.reserve();
let inner_size = self.original_request.compute_size(__cache);
__cache.set(__slot, inner_size);
size
+= 1u32 + ::buffa::encoding::varint_len(inner_size as u64) as u32
+ inner_size;
}
if let ::core::option::Option::Some(ref v) = self.message_response {
match v {
super::super::__buffa::view::oneof::server_reflection_response::MessageResponse::FileDescriptorResponse(
x,
) => {
let __slot = __cache.reserve();
let inner = x.compute_size(__cache);
__cache.set(__slot, inner);
size
+= 1u32 + ::buffa::encoding::varint_len(inner as u64) as u32
+ inner;
}
super::super::__buffa::view::oneof::server_reflection_response::MessageResponse::AllExtensionNumbersResponse(
x,
) => {
let __slot = __cache.reserve();
let inner = x.compute_size(__cache);
__cache.set(__slot, inner);
size
+= 1u32 + ::buffa::encoding::varint_len(inner as u64) as u32
+ inner;
}
super::super::__buffa::view::oneof::server_reflection_response::MessageResponse::ListServicesResponse(
x,
) => {
let __slot = __cache.reserve();
let inner = x.compute_size(__cache);
__cache.set(__slot, inner);
size
+= 1u32 + ::buffa::encoding::varint_len(inner as u64) as u32
+ inner;
}
super::super::__buffa::view::oneof::server_reflection_response::MessageResponse::ErrorResponse(
x,
) => {
let __slot = __cache.reserve();
let inner = x.compute_size(__cache);
__cache.set(__slot, inner);
size
+= 1u32 + ::buffa::encoding::varint_len(inner as u64) as u32
+ inner;
}
}
}
size += self.__buffa_unknown_fields.encoded_len() as u32;
size
}
#[allow(clippy::needless_borrow)]
fn write_to(
&self,
__cache: &mut ::buffa::SizeCache,
buf: &mut impl ::buffa::bytes::BufMut,
) {
#[allow(unused_imports)]
use ::buffa::Enumeration as _;
if !self.valid_host.is_empty() {
::buffa::types::put_string_field(1u32, &self.valid_host, buf);
}
if self.original_request.is_set() {
::buffa::types::put_len_delimited_header(2u32, __cache.consume_next(), buf);
self.original_request.write_to(__cache, buf);
}
if let ::core::option::Option::Some(ref v) = self.message_response {
match v {
super::super::__buffa::view::oneof::server_reflection_response::MessageResponse::FileDescriptorResponse(
x,
) => {
::buffa::types::put_len_delimited_header(
4u32,
__cache.consume_next(),
buf,
);
x.write_to(__cache, buf);
}
super::super::__buffa::view::oneof::server_reflection_response::MessageResponse::AllExtensionNumbersResponse(
x,
) => {
::buffa::types::put_len_delimited_header(
5u32,
__cache.consume_next(),
buf,
);
x.write_to(__cache, buf);
}
super::super::__buffa::view::oneof::server_reflection_response::MessageResponse::ListServicesResponse(
x,
) => {
::buffa::types::put_len_delimited_header(
6u32,
__cache.consume_next(),
buf,
);
x.write_to(__cache, buf);
}
super::super::__buffa::view::oneof::server_reflection_response::MessageResponse::ErrorResponse(
x,
) => {
::buffa::types::put_len_delimited_header(
7u32,
__cache.consume_next(),
buf,
);
x.write_to(__cache, buf);
}
}
}
self.__buffa_unknown_fields.write_to(buf);
}
}
impl<'__a> ::serde::Serialize for ServerReflectionResponseView<'__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.valid_host) {
__map.serialize_entry("validHost", self.valid_host)?;
}
{
if let ::core::option::Option::Some(__v) = self.original_request.as_option()
{
__map.serialize_entry("originalRequest", __v)?;
}
}
if let ::core::option::Option::Some(ref __ov) = self.message_response {
match __ov {
super::super::__buffa::view::oneof::server_reflection_response::MessageResponse::FileDescriptorResponse(
v,
) => {
__map.serialize_entry("fileDescriptorResponse", v)?;
}
super::super::__buffa::view::oneof::server_reflection_response::MessageResponse::AllExtensionNumbersResponse(
v,
) => {
__map.serialize_entry("allExtensionNumbersResponse", v)?;
}
super::super::__buffa::view::oneof::server_reflection_response::MessageResponse::ListServicesResponse(
v,
) => {
__map.serialize_entry("listServicesResponse", v)?;
}
super::super::__buffa::view::oneof::server_reflection_response::MessageResponse::ErrorResponse(
v,
) => {
__map.serialize_entry("errorResponse", v)?;
}
}
}
__map.end()
}
}
impl<'a> ::buffa::MessageName for ServerReflectionResponseView<'a> {
const PACKAGE: &'static str = "grpc.reflection.v1alpha";
const NAME: &'static str = "ServerReflectionResponse";
const FULL_NAME: &'static str = "grpc.reflection.v1alpha.ServerReflectionResponse";
const TYPE_URL: &'static str = "type.googleapis.com/grpc.reflection.v1alpha.ServerReflectionResponse";
}
::buffa::impl_default_view_instance!(ServerReflectionResponseView);
::buffa::impl_view_reborrow!(ServerReflectionResponseView);
#[derive(Clone, Debug)]
pub struct ServerReflectionResponseOwnedView(
::buffa::OwnedView<ServerReflectionResponseView<'static>>,
);
impl ServerReflectionResponseOwnedView {
pub fn decode(
bytes: ::buffa::bytes::Bytes,
) -> ::core::result::Result<Self, ::buffa::DecodeError> {
::core::result::Result::Ok(
ServerReflectionResponseOwnedView(::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(
ServerReflectionResponseOwnedView(
::buffa::OwnedView::decode_with_options(bytes, opts)?,
),
)
}
pub fn from_owned(
msg: &super::super::ServerReflectionResponse,
) -> ::core::result::Result<Self, ::buffa::DecodeError> {
::core::result::Result::Ok(
ServerReflectionResponseOwnedView(::buffa::OwnedView::from_owned(msg)?),
)
}
#[must_use]
pub fn view(&self) -> &ServerReflectionResponseView<'_> {
self.0.reborrow()
}
pub fn to_owned_message(
&self,
) -> ::core::result::Result<
super::super::ServerReflectionResponse,
::buffa::DecodeError,
> {
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 valid_host(&self) -> &'_ str {
self.0.reborrow().valid_host
}
#[must_use]
pub fn original_request(
&self,
) -> &::buffa::MessageFieldView<
super::super::__buffa::view::ServerReflectionRequestView<'_>,
> {
&self.0.reborrow().original_request
}
#[must_use]
pub fn message_response(
&self,
) -> ::core::option::Option<
&super::super::__buffa::view::oneof::server_reflection_response::MessageResponse<
'_,
>,
> {
self.0.reborrow().message_response.as_ref()
}
}
impl ::core::convert::From<::buffa::OwnedView<ServerReflectionResponseView<'static>>>
for ServerReflectionResponseOwnedView {
fn from(inner: ::buffa::OwnedView<ServerReflectionResponseView<'static>>) -> Self {
ServerReflectionResponseOwnedView(inner)
}
}
impl ::core::convert::From<ServerReflectionResponseOwnedView>
for ::buffa::OwnedView<ServerReflectionResponseView<'static>> {
fn from(wrapper: ServerReflectionResponseOwnedView) -> Self {
wrapper.0
}
}
impl ::core::convert::AsRef<::buffa::OwnedView<ServerReflectionResponseView<'static>>>
for ServerReflectionResponseOwnedView {
fn as_ref(&self) -> &::buffa::OwnedView<ServerReflectionResponseView<'static>> {
&self.0
}
}
impl ::buffa::HasMessageView for super::super::ServerReflectionResponse {
type View<'a> = ServerReflectionResponseView<'a>;
type ViewHandle = ServerReflectionResponseOwnedView;
}
impl ::serde::Serialize for ServerReflectionResponseOwnedView {
fn serialize<__S: ::serde::Serializer>(
&self,
__s: __S,
) -> ::core::result::Result<__S::Ok, __S::Error> {
::serde::Serialize::serialize(&self.0, __s)
}
}
#[derive(Clone, Debug, Default)]
pub struct FileDescriptorResponseView<'a> {
pub file_descriptor_proto: ::buffa::RepeatedView<'a, &'a [u8]>,
pub __buffa_unknown_fields: ::buffa::UnknownFieldsView<'a>,
}
impl<'a> ::buffa::MessageView<'a> for FileDescriptorResponseView<'a> {
type Owned = super::super::FileDescriptorResponse;
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.file_descriptor_proto.push(::buffa::types::borrow_bytes(&mut cur)?);
}
_ => {
::buffa::encoding::skip_field_depth(tag, &mut cur, ctx.depth())?;
let span_len = before_tag.len() - cur.len();
view.__buffa_unknown_fields.push_record(before_tag, span_len, ctx)?;
}
}
::core::result::Result::Ok(cur)
}
fn to_owned_message(
&self,
) -> ::core::result::Result<
super::super::FileDescriptorResponse,
::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::FileDescriptorResponse,
::buffa::DecodeError,
> {
#[allow(unused_imports)]
use ::buffa::alloc::string::ToString as _;
let _ = __buffa_src;
::core::result::Result::Ok(super::super::FileDescriptorResponse {
file_descriptor_proto: self
.file_descriptor_proto
.iter()
.map(|b| (b).to_vec())
.collect(),
__buffa_unknown_fields: self.__buffa_unknown_fields.to_owned()?.into(),
..::core::default::Default::default()
})
}
}
impl<'a> ::buffa::ViewEncode<'a> for FileDescriptorResponseView<'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;
for v in &self.file_descriptor_proto {
size += 1u32 + ::buffa::types::bytes_encoded_len(v) 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 _;
for v in &self.file_descriptor_proto {
::buffa::types::put_bytes_field(1u32, v, buf);
}
self.__buffa_unknown_fields.write_to(buf);
}
}
impl<'__a> ::serde::Serialize for FileDescriptorResponseView<'__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 !self.file_descriptor_proto.is_empty() {
__map
.serialize_entry(
"fileDescriptorProto",
&::buffa::json_helpers::BytesSeqJson(&self.file_descriptor_proto),
)?;
}
__map.end()
}
}
impl<'a> ::buffa::MessageName for FileDescriptorResponseView<'a> {
const PACKAGE: &'static str = "grpc.reflection.v1alpha";
const NAME: &'static str = "FileDescriptorResponse";
const FULL_NAME: &'static str = "grpc.reflection.v1alpha.FileDescriptorResponse";
const TYPE_URL: &'static str = "type.googleapis.com/grpc.reflection.v1alpha.FileDescriptorResponse";
}
::buffa::impl_default_view_instance!(FileDescriptorResponseView);
::buffa::impl_view_reborrow!(FileDescriptorResponseView);
#[derive(Clone, Debug)]
pub struct FileDescriptorResponseOwnedView(
::buffa::OwnedView<FileDescriptorResponseView<'static>>,
);
impl FileDescriptorResponseOwnedView {
pub fn decode(
bytes: ::buffa::bytes::Bytes,
) -> ::core::result::Result<Self, ::buffa::DecodeError> {
::core::result::Result::Ok(
FileDescriptorResponseOwnedView(::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(
FileDescriptorResponseOwnedView(
::buffa::OwnedView::decode_with_options(bytes, opts)?,
),
)
}
pub fn from_owned(
msg: &super::super::FileDescriptorResponse,
) -> ::core::result::Result<Self, ::buffa::DecodeError> {
::core::result::Result::Ok(
FileDescriptorResponseOwnedView(::buffa::OwnedView::from_owned(msg)?),
)
}
#[must_use]
pub fn view(&self) -> &FileDescriptorResponseView<'_> {
self.0.reborrow()
}
pub fn to_owned_message(
&self,
) -> ::core::result::Result<
super::super::FileDescriptorResponse,
::buffa::DecodeError,
> {
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 file_descriptor_proto(&self) -> &::buffa::RepeatedView<'_, &'_ [u8]> {
&self.0.reborrow().file_descriptor_proto
}
}
impl ::core::convert::From<::buffa::OwnedView<FileDescriptorResponseView<'static>>>
for FileDescriptorResponseOwnedView {
fn from(inner: ::buffa::OwnedView<FileDescriptorResponseView<'static>>) -> Self {
FileDescriptorResponseOwnedView(inner)
}
}
impl ::core::convert::From<FileDescriptorResponseOwnedView>
for ::buffa::OwnedView<FileDescriptorResponseView<'static>> {
fn from(wrapper: FileDescriptorResponseOwnedView) -> Self {
wrapper.0
}
}
impl ::core::convert::AsRef<::buffa::OwnedView<FileDescriptorResponseView<'static>>>
for FileDescriptorResponseOwnedView {
fn as_ref(&self) -> &::buffa::OwnedView<FileDescriptorResponseView<'static>> {
&self.0
}
}
impl ::buffa::HasMessageView for super::super::FileDescriptorResponse {
type View<'a> = FileDescriptorResponseView<'a>;
type ViewHandle = FileDescriptorResponseOwnedView;
}
impl ::serde::Serialize for FileDescriptorResponseOwnedView {
fn serialize<__S: ::serde::Serializer>(
&self,
__s: __S,
) -> ::core::result::Result<__S::Ok, __S::Error> {
::serde::Serialize::serialize(&self.0, __s)
}
}
#[derive(Clone, Debug, Default)]
pub struct ExtensionNumberResponseView<'a> {
pub base_type_name: &'a str,
pub extension_number: ::buffa::RepeatedView<'a, i32>,
pub __buffa_unknown_fields: ::buffa::UnknownFieldsView<'a>,
}
impl<'a> ::buffa::MessageView<'a> for ExtensionNumberResponseView<'a> {
type Owned = super::super::ExtensionNumberResponse;
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.base_type_name = ::buffa::types::borrow_str(&mut cur)?;
}
2u32 => {
if tag.wire_type() == ::buffa::encoding::WireType::LengthDelimited {
let payload = ::buffa::types::borrow_bytes(&mut cur)?;
view.extension_number
.reserve(::buffa::encoding::count_varints(payload));
let mut pcur: &[u8] = payload;
while !pcur.is_empty() {
view.extension_number
.push(::buffa::types::decode_int32(&mut pcur)?);
}
} else if tag.wire_type() == ::buffa::encoding::WireType::Varint {
view.extension_number.push(::buffa::types::decode_int32(&mut cur)?);
} else {
return Err(
::buffa::encoding::wire_type_mismatch(
tag,
::buffa::encoding::WireType::LengthDelimited,
),
);
}
}
_ => {
::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::ExtensionNumberResponse,
::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::ExtensionNumberResponse,
::buffa::DecodeError,
> {
#[allow(unused_imports)]
use ::buffa::alloc::string::ToString as _;
let _ = __buffa_src;
::core::result::Result::Ok(super::super::ExtensionNumberResponse {
base_type_name: self.base_type_name.to_string(),
extension_number: self.extension_number.to_vec(),
__buffa_unknown_fields: self.__buffa_unknown_fields.to_owned()?.into(),
..::core::default::Default::default()
})
}
}
impl<'a> ::buffa::ViewEncode<'a> for ExtensionNumberResponseView<'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.base_type_name.is_empty() {
size
+= 1u32
+ ::buffa::types::string_encoded_len(&self.base_type_name) as u32;
}
if !self.extension_number.is_empty() {
let payload: u32 = self
.extension_number
.iter()
.map(|&v| ::buffa::types::int32_encoded_len(v) as u32)
.sum::<u32>();
size
+= 1u32 + ::buffa::encoding::varint_len(payload as u64) as u32 + payload;
}
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.base_type_name.is_empty() {
::buffa::types::put_string_field(1u32, &self.base_type_name, buf);
}
if !self.extension_number.is_empty() {
let payload: u32 = self
.extension_number
.iter()
.map(|&v| ::buffa::types::int32_encoded_len(v) as u32)
.sum::<u32>();
::buffa::types::put_len_delimited_header(2u32, payload, buf);
for &v in &self.extension_number {
::buffa::types::encode_int32(v, buf);
}
}
self.__buffa_unknown_fields.write_to(buf);
}
}
impl<'__a> ::serde::Serialize for ExtensionNumberResponseView<'__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.base_type_name) {
__map.serialize_entry("baseTypeName", self.base_type_name)?;
}
if !self.extension_number.is_empty() {
__map
.serialize_entry(
"extensionNumber",
&::buffa::json_helpers::RepeatedJson(&self.extension_number),
)?;
}
__map.end()
}
}
impl<'a> ::buffa::MessageName for ExtensionNumberResponseView<'a> {
const PACKAGE: &'static str = "grpc.reflection.v1alpha";
const NAME: &'static str = "ExtensionNumberResponse";
const FULL_NAME: &'static str = "grpc.reflection.v1alpha.ExtensionNumberResponse";
const TYPE_URL: &'static str = "type.googleapis.com/grpc.reflection.v1alpha.ExtensionNumberResponse";
}
::buffa::impl_default_view_instance!(ExtensionNumberResponseView);
::buffa::impl_view_reborrow!(ExtensionNumberResponseView);
#[derive(Clone, Debug)]
pub struct ExtensionNumberResponseOwnedView(
::buffa::OwnedView<ExtensionNumberResponseView<'static>>,
);
impl ExtensionNumberResponseOwnedView {
pub fn decode(
bytes: ::buffa::bytes::Bytes,
) -> ::core::result::Result<Self, ::buffa::DecodeError> {
::core::result::Result::Ok(
ExtensionNumberResponseOwnedView(::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(
ExtensionNumberResponseOwnedView(
::buffa::OwnedView::decode_with_options(bytes, opts)?,
),
)
}
pub fn from_owned(
msg: &super::super::ExtensionNumberResponse,
) -> ::core::result::Result<Self, ::buffa::DecodeError> {
::core::result::Result::Ok(
ExtensionNumberResponseOwnedView(::buffa::OwnedView::from_owned(msg)?),
)
}
#[must_use]
pub fn view(&self) -> &ExtensionNumberResponseView<'_> {
self.0.reborrow()
}
pub fn to_owned_message(
&self,
) -> ::core::result::Result<
super::super::ExtensionNumberResponse,
::buffa::DecodeError,
> {
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 base_type_name(&self) -> &'_ str {
self.0.reborrow().base_type_name
}
#[must_use]
pub fn extension_number(&self) -> &::buffa::RepeatedView<'_, i32> {
&self.0.reborrow().extension_number
}
}
impl ::core::convert::From<::buffa::OwnedView<ExtensionNumberResponseView<'static>>>
for ExtensionNumberResponseOwnedView {
fn from(inner: ::buffa::OwnedView<ExtensionNumberResponseView<'static>>) -> Self {
ExtensionNumberResponseOwnedView(inner)
}
}
impl ::core::convert::From<ExtensionNumberResponseOwnedView>
for ::buffa::OwnedView<ExtensionNumberResponseView<'static>> {
fn from(wrapper: ExtensionNumberResponseOwnedView) -> Self {
wrapper.0
}
}
impl ::core::convert::AsRef<::buffa::OwnedView<ExtensionNumberResponseView<'static>>>
for ExtensionNumberResponseOwnedView {
fn as_ref(&self) -> &::buffa::OwnedView<ExtensionNumberResponseView<'static>> {
&self.0
}
}
impl ::buffa::HasMessageView for super::super::ExtensionNumberResponse {
type View<'a> = ExtensionNumberResponseView<'a>;
type ViewHandle = ExtensionNumberResponseOwnedView;
}
impl ::serde::Serialize for ExtensionNumberResponseOwnedView {
fn serialize<__S: ::serde::Serializer>(
&self,
__s: __S,
) -> ::core::result::Result<__S::Ok, __S::Error> {
::serde::Serialize::serialize(&self.0, __s)
}
}
#[derive(Clone, Debug, Default)]
pub struct ListServiceResponseView<'a> {
pub service: ::buffa::RepeatedView<
'a,
super::super::__buffa::view::ServiceResponseView<'a>,
>,
pub __buffa_unknown_fields: ::buffa::UnknownFieldsView<'a>,
}
impl<'a> ::buffa::MessageView<'a> for ListServiceResponseView<'a> {
type Owned = super::super::ListServiceResponse;
fn decode_view(buf: &'a [u8]) -> ::core::result::Result<Self, ::buffa::DecodeError> {
let __limit = ::core::cell::Cell::new(::buffa::DEFAULT_UNKNOWN_FIELD_LIMIT);
<Self as ::buffa::MessageView>::decode_view_ctx(
buf,
::buffa::DecodeContext::new(::buffa::RECURSION_LIMIT, &__limit),
)
}
fn decode_view_with_ctx(
buf: &'a [u8],
ctx: ::buffa::DecodeContext<'_>,
) -> ::core::result::Result<Self, ::buffa::DecodeError> {
<Self as ::buffa::MessageView>::decode_view_ctx(buf, ctx)
}
fn merge_view_field(
&mut self,
tag: ::buffa::encoding::Tag,
cur: &'a [u8],
before_tag: &'a [u8],
ctx: ::buffa::DecodeContext<'_>,
) -> ::core::result::Result<&'a [u8], ::buffa::DecodeError> {
let _ = ctx;
#[allow(unused_variables)]
let view = self;
let mut cur = cur;
match tag.field_number() {
1u32 => {
::buffa::encoding::check_wire_type(
tag,
::buffa::encoding::WireType::LengthDelimited,
)?;
let __sub_ctx = ctx.descend()?;
let sub = ::buffa::types::borrow_bytes(&mut cur)?;
view.service
.push(
<super::super::__buffa::view::ServiceResponseView 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::ListServiceResponse,
::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::ListServiceResponse,
::buffa::DecodeError,
> {
#[allow(unused_imports)]
use ::buffa::alloc::string::ToString as _;
let _ = __buffa_src;
::core::result::Result::Ok(super::super::ListServiceResponse {
service: self
.service
.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 ListServiceResponseView<'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;
for v in &self.service {
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;
}
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 _;
for v in &self.service {
::buffa::types::put_len_delimited_header(1u32, __cache.consume_next(), buf);
v.write_to(__cache, buf);
}
self.__buffa_unknown_fields.write_to(buf);
}
}
impl<'__a> ::serde::Serialize for ListServiceResponseView<'__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 !self.service.is_empty() {
__map.serialize_entry("service", &*self.service)?;
}
__map.end()
}
}
impl<'a> ::buffa::MessageName for ListServiceResponseView<'a> {
const PACKAGE: &'static str = "grpc.reflection.v1alpha";
const NAME: &'static str = "ListServiceResponse";
const FULL_NAME: &'static str = "grpc.reflection.v1alpha.ListServiceResponse";
const TYPE_URL: &'static str = "type.googleapis.com/grpc.reflection.v1alpha.ListServiceResponse";
}
::buffa::impl_default_view_instance!(ListServiceResponseView);
::buffa::impl_view_reborrow!(ListServiceResponseView);
#[derive(Clone, Debug)]
pub struct ListServiceResponseOwnedView(
::buffa::OwnedView<ListServiceResponseView<'static>>,
);
impl ListServiceResponseOwnedView {
pub fn decode(
bytes: ::buffa::bytes::Bytes,
) -> ::core::result::Result<Self, ::buffa::DecodeError> {
::core::result::Result::Ok(
ListServiceResponseOwnedView(::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(
ListServiceResponseOwnedView(
::buffa::OwnedView::decode_with_options(bytes, opts)?,
),
)
}
pub fn from_owned(
msg: &super::super::ListServiceResponse,
) -> ::core::result::Result<Self, ::buffa::DecodeError> {
::core::result::Result::Ok(
ListServiceResponseOwnedView(::buffa::OwnedView::from_owned(msg)?),
)
}
#[must_use]
pub fn view(&self) -> &ListServiceResponseView<'_> {
self.0.reborrow()
}
pub fn to_owned_message(
&self,
) -> ::core::result::Result<
super::super::ListServiceResponse,
::buffa::DecodeError,
> {
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 service(
&self,
) -> &::buffa::RepeatedView<
'_,
super::super::__buffa::view::ServiceResponseView<'_>,
> {
&self.0.reborrow().service
}
}
impl ::core::convert::From<::buffa::OwnedView<ListServiceResponseView<'static>>>
for ListServiceResponseOwnedView {
fn from(inner: ::buffa::OwnedView<ListServiceResponseView<'static>>) -> Self {
ListServiceResponseOwnedView(inner)
}
}
impl ::core::convert::From<ListServiceResponseOwnedView>
for ::buffa::OwnedView<ListServiceResponseView<'static>> {
fn from(wrapper: ListServiceResponseOwnedView) -> Self {
wrapper.0
}
}
impl ::core::convert::AsRef<::buffa::OwnedView<ListServiceResponseView<'static>>>
for ListServiceResponseOwnedView {
fn as_ref(&self) -> &::buffa::OwnedView<ListServiceResponseView<'static>> {
&self.0
}
}
impl ::buffa::HasMessageView for super::super::ListServiceResponse {
type View<'a> = ListServiceResponseView<'a>;
type ViewHandle = ListServiceResponseOwnedView;
}
impl ::serde::Serialize for ListServiceResponseOwnedView {
fn serialize<__S: ::serde::Serializer>(
&self,
__s: __S,
) -> ::core::result::Result<__S::Ok, __S::Error> {
::serde::Serialize::serialize(&self.0, __s)
}
}
#[derive(Clone, Debug, Default)]
pub struct ServiceResponseView<'a> {
pub name: &'a str,
pub __buffa_unknown_fields: ::buffa::UnknownFieldsView<'a>,
}
impl<'a> ::buffa::MessageView<'a> for ServiceResponseView<'a> {
type Owned = super::super::ServiceResponse;
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.name = ::buffa::types::borrow_str(&mut cur)?;
}
_ => {
::buffa::encoding::skip_field_depth(tag, &mut cur, ctx.depth())?;
let span_len = before_tag.len() - cur.len();
view.__buffa_unknown_fields.push_record(before_tag, span_len, ctx)?;
}
}
::core::result::Result::Ok(cur)
}
fn to_owned_message(
&self,
) -> ::core::result::Result<super::super::ServiceResponse, ::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::ServiceResponse, ::buffa::DecodeError> {
#[allow(unused_imports)]
use ::buffa::alloc::string::ToString as _;
let _ = __buffa_src;
::core::result::Result::Ok(super::super::ServiceResponse {
name: self.name.to_string(),
__buffa_unknown_fields: self.__buffa_unknown_fields.to_owned()?.into(),
..::core::default::Default::default()
})
}
}
impl<'a> ::buffa::ViewEncode<'a> for ServiceResponseView<'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.name.is_empty() {
size += 1u32 + ::buffa::types::string_encoded_len(&self.name) 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.name.is_empty() {
::buffa::types::put_string_field(1u32, &self.name, buf);
}
self.__buffa_unknown_fields.write_to(buf);
}
}
impl<'__a> ::serde::Serialize for ServiceResponseView<'__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.name) {
__map.serialize_entry("name", self.name)?;
}
__map.end()
}
}
impl<'a> ::buffa::MessageName for ServiceResponseView<'a> {
const PACKAGE: &'static str = "grpc.reflection.v1alpha";
const NAME: &'static str = "ServiceResponse";
const FULL_NAME: &'static str = "grpc.reflection.v1alpha.ServiceResponse";
const TYPE_URL: &'static str = "type.googleapis.com/grpc.reflection.v1alpha.ServiceResponse";
}
::buffa::impl_default_view_instance!(ServiceResponseView);
::buffa::impl_view_reborrow!(ServiceResponseView);
#[derive(Clone, Debug)]
pub struct ServiceResponseOwnedView(::buffa::OwnedView<ServiceResponseView<'static>>);
impl ServiceResponseOwnedView {
pub fn decode(
bytes: ::buffa::bytes::Bytes,
) -> ::core::result::Result<Self, ::buffa::DecodeError> {
::core::result::Result::Ok(
ServiceResponseOwnedView(::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(
ServiceResponseOwnedView(
::buffa::OwnedView::decode_with_options(bytes, opts)?,
),
)
}
pub fn from_owned(
msg: &super::super::ServiceResponse,
) -> ::core::result::Result<Self, ::buffa::DecodeError> {
::core::result::Result::Ok(
ServiceResponseOwnedView(::buffa::OwnedView::from_owned(msg)?),
)
}
#[must_use]
pub fn view(&self) -> &ServiceResponseView<'_> {
self.0.reborrow()
}
pub fn to_owned_message(
&self,
) -> ::core::result::Result<super::super::ServiceResponse, ::buffa::DecodeError> {
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 name(&self) -> &'_ str {
self.0.reborrow().name
}
}
impl ::core::convert::From<::buffa::OwnedView<ServiceResponseView<'static>>>
for ServiceResponseOwnedView {
fn from(inner: ::buffa::OwnedView<ServiceResponseView<'static>>) -> Self {
ServiceResponseOwnedView(inner)
}
}
impl ::core::convert::From<ServiceResponseOwnedView>
for ::buffa::OwnedView<ServiceResponseView<'static>> {
fn from(wrapper: ServiceResponseOwnedView) -> Self {
wrapper.0
}
}
impl ::core::convert::AsRef<::buffa::OwnedView<ServiceResponseView<'static>>>
for ServiceResponseOwnedView {
fn as_ref(&self) -> &::buffa::OwnedView<ServiceResponseView<'static>> {
&self.0
}
}
impl ::buffa::HasMessageView for super::super::ServiceResponse {
type View<'a> = ServiceResponseView<'a>;
type ViewHandle = ServiceResponseOwnedView;
}
impl ::serde::Serialize for ServiceResponseOwnedView {
fn serialize<__S: ::serde::Serializer>(
&self,
__s: __S,
) -> ::core::result::Result<__S::Ok, __S::Error> {
::serde::Serialize::serialize(&self.0, __s)
}
}
#[derive(Clone, Debug, Default)]
pub struct ErrorResponseView<'a> {
pub error_code: i32,
pub error_message: &'a str,
pub __buffa_unknown_fields: ::buffa::UnknownFieldsView<'a>,
}
impl<'a> ::buffa::MessageView<'a> for ErrorResponseView<'a> {
type Owned = super::super::ErrorResponse;
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.error_code = ::buffa::types::decode_int32(&mut cur)?;
}
2u32 => {
::buffa::encoding::check_wire_type(
tag,
::buffa::encoding::WireType::LengthDelimited,
)?;
view.error_message = ::buffa::types::borrow_str(&mut cur)?;
}
_ => {
::buffa::encoding::skip_field_depth(tag, &mut cur, ctx.depth())?;
let span_len = before_tag.len() - cur.len();
view.__buffa_unknown_fields.push_record(before_tag, span_len, ctx)?;
}
}
::core::result::Result::Ok(cur)
}
fn to_owned_message(
&self,
) -> ::core::result::Result<super::super::ErrorResponse, ::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::ErrorResponse, ::buffa::DecodeError> {
#[allow(unused_imports)]
use ::buffa::alloc::string::ToString as _;
let _ = __buffa_src;
::core::result::Result::Ok(super::super::ErrorResponse {
error_code: self.error_code,
error_message: self.error_message.to_string(),
__buffa_unknown_fields: self.__buffa_unknown_fields.to_owned()?.into(),
..::core::default::Default::default()
})
}
}
impl<'a> ::buffa::ViewEncode<'a> for ErrorResponseView<'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.error_code != 0i32 {
size += 1u32 + ::buffa::types::int32_encoded_len(self.error_code) as u32;
}
if !self.error_message.is_empty() {
size
+= 1u32 + ::buffa::types::string_encoded_len(&self.error_message) 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.error_code != 0i32 {
::buffa::types::put_int32_field(1u32, self.error_code, buf);
}
if !self.error_message.is_empty() {
::buffa::types::put_string_field(2u32, &self.error_message, buf);
}
self.__buffa_unknown_fields.write_to(buf);
}
}
impl<'__a> ::serde::Serialize for ErrorResponseView<'__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_i32(&self.error_code) {
__map
.serialize_entry(
"errorCode",
&::buffa::json_helpers::ProtoJson(&self.error_code),
)?;
}
if !::buffa::json_helpers::skip_if::is_empty_str(self.error_message) {
__map.serialize_entry("errorMessage", self.error_message)?;
}
__map.end()
}
}
impl<'a> ::buffa::MessageName for ErrorResponseView<'a> {
const PACKAGE: &'static str = "grpc.reflection.v1alpha";
const NAME: &'static str = "ErrorResponse";
const FULL_NAME: &'static str = "grpc.reflection.v1alpha.ErrorResponse";
const TYPE_URL: &'static str = "type.googleapis.com/grpc.reflection.v1alpha.ErrorResponse";
}
::buffa::impl_default_view_instance!(ErrorResponseView);
::buffa::impl_view_reborrow!(ErrorResponseView);
#[derive(Clone, Debug)]
pub struct ErrorResponseOwnedView(::buffa::OwnedView<ErrorResponseView<'static>>);
impl ErrorResponseOwnedView {
pub fn decode(
bytes: ::buffa::bytes::Bytes,
) -> ::core::result::Result<Self, ::buffa::DecodeError> {
::core::result::Result::Ok(
ErrorResponseOwnedView(::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(
ErrorResponseOwnedView(::buffa::OwnedView::decode_with_options(bytes, opts)?),
)
}
pub fn from_owned(
msg: &super::super::ErrorResponse,
) -> ::core::result::Result<Self, ::buffa::DecodeError> {
::core::result::Result::Ok(
ErrorResponseOwnedView(::buffa::OwnedView::from_owned(msg)?),
)
}
#[must_use]
pub fn view(&self) -> &ErrorResponseView<'_> {
self.0.reborrow()
}
pub fn to_owned_message(
&self,
) -> ::core::result::Result<super::super::ErrorResponse, ::buffa::DecodeError> {
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 error_code(&self) -> i32 {
self.0.reborrow().error_code
}
#[must_use]
pub fn error_message(&self) -> &'_ str {
self.0.reborrow().error_message
}
}
impl ::core::convert::From<::buffa::OwnedView<ErrorResponseView<'static>>>
for ErrorResponseOwnedView {
fn from(inner: ::buffa::OwnedView<ErrorResponseView<'static>>) -> Self {
ErrorResponseOwnedView(inner)
}
}
impl ::core::convert::From<ErrorResponseOwnedView>
for ::buffa::OwnedView<ErrorResponseView<'static>> {
fn from(wrapper: ErrorResponseOwnedView) -> Self {
wrapper.0
}
}
impl ::core::convert::AsRef<::buffa::OwnedView<ErrorResponseView<'static>>>
for ErrorResponseOwnedView {
fn as_ref(&self) -> &::buffa::OwnedView<ErrorResponseView<'static>> {
&self.0
}
}
impl ::buffa::HasMessageView for super::super::ErrorResponse {
type View<'a> = ErrorResponseView<'a>;
type ViewHandle = ErrorResponseOwnedView;
}
impl ::serde::Serialize for ErrorResponseOwnedView {
fn serialize<__S: ::serde::Serializer>(
&self,
__s: __S,
) -> ::core::result::Result<__S::Ok, __S::Error> {
::serde::Serialize::serialize(&self.0, __s)
}
}