#[derive(Clone, PartialEq, Default)]
#[derive(::serde::Serialize)]
#[serde(default)]
pub struct ServerReflectionRequest {
#[serde(
rename = "host",
with = "::buffa::json_helpers::proto_string",
skip_serializing_if = "::buffa::json_helpers::skip_if::is_empty_str"
)]
pub host: ::buffa::alloc::string::String,
#[serde(flatten)]
pub message_request: ::core::option::Option<
__buffa::oneof::server_reflection_request::MessageRequest,
>,
#[serde(skip)]
#[doc(hidden)]
pub __buffa_unknown_fields: ::buffa::UnknownFields,
}
impl ::core::fmt::Debug for ServerReflectionRequest {
fn fmt(&self, f: &mut ::core::fmt::Formatter<'_>) -> ::core::fmt::Result {
f.debug_struct("ServerReflectionRequest")
.field("host", &self.host)
.field("message_request", &self.message_request)
.finish()
}
}
impl ServerReflectionRequest {
pub const TYPE_URL: &'static str = "type.googleapis.com/grpc.reflection.v1alpha.ServerReflectionRequest";
}
impl ::buffa::DefaultInstance for ServerReflectionRequest {
fn default_instance() -> &'static Self {
static VALUE: ::buffa::__private::OnceBox<ServerReflectionRequest> = ::buffa::__private::OnceBox::new();
VALUE.get_or_init(|| ::buffa::alloc::boxed::Box::new(Self::default()))
}
}
impl ::buffa::MessageName for ServerReflectionRequest {
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";
}
impl ::buffa::Message for ServerReflectionRequest {
#[allow(clippy::let_and_return)]
fn compute_size(&self, __cache: &mut ::buffa::SizeCache) -> u32 {
#[allow(unused_imports)]
use ::buffa::Enumeration as _;
let mut size = 0u32;
if !self.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 {
__buffa::oneof::server_reflection_request::MessageRequest::FileByFilename(
x,
) => {
size += 1u32 + ::buffa::types::string_encoded_len(x) as u32;
}
__buffa::oneof::server_reflection_request::MessageRequest::FileContainingSymbol(
x,
) => {
size += 1u32 + ::buffa::types::string_encoded_len(x) as u32;
}
__buffa::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;
}
__buffa::oneof::server_reflection_request::MessageRequest::AllExtensionNumbersOfType(
x,
) => {
size += 1u32 + ::buffa::types::string_encoded_len(x) as u32;
}
__buffa::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
}
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::encoding::Tag::new(
1u32,
::buffa::encoding::WireType::LengthDelimited,
)
.encode(buf);
::buffa::types::encode_string(&self.host, buf);
}
if let ::core::option::Option::Some(ref v) = self.message_request {
match v {
__buffa::oneof::server_reflection_request::MessageRequest::FileByFilename(
x,
) => {
::buffa::encoding::Tag::new(
3u32,
::buffa::encoding::WireType::LengthDelimited,
)
.encode(buf);
::buffa::types::encode_string(x, buf);
}
__buffa::oneof::server_reflection_request::MessageRequest::FileContainingSymbol(
x,
) => {
::buffa::encoding::Tag::new(
4u32,
::buffa::encoding::WireType::LengthDelimited,
)
.encode(buf);
::buffa::types::encode_string(x, buf);
}
__buffa::oneof::server_reflection_request::MessageRequest::FileContainingExtension(
x,
) => {
::buffa::encoding::Tag::new(
5u32,
::buffa::encoding::WireType::LengthDelimited,
)
.encode(buf);
::buffa::encoding::encode_varint(__cache.consume_next() as u64, buf);
x.write_to(__cache, buf);
}
__buffa::oneof::server_reflection_request::MessageRequest::AllExtensionNumbersOfType(
x,
) => {
::buffa::encoding::Tag::new(
6u32,
::buffa::encoding::WireType::LengthDelimited,
)
.encode(buf);
::buffa::types::encode_string(x, buf);
}
__buffa::oneof::server_reflection_request::MessageRequest::ListServices(
x,
) => {
::buffa::encoding::Tag::new(
7u32,
::buffa::encoding::WireType::LengthDelimited,
)
.encode(buf);
::buffa::types::encode_string(x, buf);
}
}
}
self.__buffa_unknown_fields.write_to(buf);
}
fn merge_field(
&mut self,
tag: ::buffa::encoding::Tag,
buf: &mut impl ::buffa::bytes::Buf,
depth: u32,
) -> ::core::result::Result<(), ::buffa::DecodeError> {
#[allow(unused_imports)]
use ::buffa::bytes::Buf as _;
#[allow(unused_imports)]
use ::buffa::Enumeration as _;
match tag.field_number() {
1u32 => {
if tag.wire_type() != ::buffa::encoding::WireType::LengthDelimited {
return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
field_number: 1u32,
expected: 2u8,
actual: tag.wire_type() as u8,
});
}
::buffa::types::merge_string(&mut self.host, buf)?;
}
3u32 => {
if tag.wire_type() != ::buffa::encoding::WireType::LengthDelimited {
return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
field_number: 3u32,
expected: 2u8,
actual: tag.wire_type() as u8,
});
}
self.message_request = ::core::option::Option::Some(
__buffa::oneof::server_reflection_request::MessageRequest::FileByFilename(
::buffa::types::decode_string(buf)?,
),
);
}
4u32 => {
if tag.wire_type() != ::buffa::encoding::WireType::LengthDelimited {
return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
field_number: 4u32,
expected: 2u8,
actual: tag.wire_type() as u8,
});
}
self.message_request = ::core::option::Option::Some(
__buffa::oneof::server_reflection_request::MessageRequest::FileContainingSymbol(
::buffa::types::decode_string(buf)?,
),
);
}
5u32 => {
if tag.wire_type() != ::buffa::encoding::WireType::LengthDelimited {
return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
field_number: 5u32,
expected: 2u8,
actual: tag.wire_type() as u8,
});
}
if let ::core::option::Option::Some(
__buffa::oneof::server_reflection_request::MessageRequest::FileContainingExtension(
ref mut existing,
),
) = self.message_request
{
::buffa::Message::merge_length_delimited(
&mut **existing,
buf,
depth,
)?;
} else {
let mut val = ::core::default::Default::default();
::buffa::Message::merge_length_delimited(&mut val, buf, depth)?;
self.message_request = ::core::option::Option::Some(
__buffa::oneof::server_reflection_request::MessageRequest::FileContainingExtension(
::buffa::alloc::boxed::Box::new(val),
),
);
}
}
6u32 => {
if tag.wire_type() != ::buffa::encoding::WireType::LengthDelimited {
return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
field_number: 6u32,
expected: 2u8,
actual: tag.wire_type() as u8,
});
}
self.message_request = ::core::option::Option::Some(
__buffa::oneof::server_reflection_request::MessageRequest::AllExtensionNumbersOfType(
::buffa::types::decode_string(buf)?,
),
);
}
7u32 => {
if tag.wire_type() != ::buffa::encoding::WireType::LengthDelimited {
return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
field_number: 7u32,
expected: 2u8,
actual: tag.wire_type() as u8,
});
}
self.message_request = ::core::option::Option::Some(
__buffa::oneof::server_reflection_request::MessageRequest::ListServices(
::buffa::types::decode_string(buf)?,
),
);
}
_ => {
self.__buffa_unknown_fields
.push(::buffa::encoding::decode_unknown_field(tag, buf, depth)?);
}
}
::core::result::Result::Ok(())
}
fn clear(&mut self) {
self.host.clear();
self.message_request = ::core::option::Option::None;
self.__buffa_unknown_fields.clear();
}
}
impl ::buffa::ExtensionSet for ServerReflectionRequest {
const PROTO_FQN: &'static str = "grpc.reflection.v1alpha.ServerReflectionRequest";
fn unknown_fields(&self) -> &::buffa::UnknownFields {
&self.__buffa_unknown_fields
}
fn unknown_fields_mut(&mut self) -> &mut ::buffa::UnknownFields {
&mut self.__buffa_unknown_fields
}
}
impl<'de> serde::Deserialize<'de> for ServerReflectionRequest {
fn deserialize<D: serde::Deserializer<'de>>(
d: D,
) -> ::core::result::Result<Self, D::Error> {
struct _V;
impl<'de> serde::de::Visitor<'de> for _V {
type Value = ServerReflectionRequest;
fn expecting(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result {
f.write_str("struct ServerReflectionRequest")
}
#[allow(clippy::field_reassign_with_default)]
fn visit_map<A: serde::de::MapAccess<'de>>(
self,
mut map: A,
) -> ::core::result::Result<ServerReflectionRequest, A::Error> {
let mut __f_host: ::core::option::Option<
::buffa::alloc::string::String,
> = None;
let mut __oneof_message_request: ::core::option::Option<
__buffa::oneof::server_reflection_request::MessageRequest,
> = None;
while let Some(key) = map.next_key::<::buffa::alloc::string::String>()? {
match key.as_str() {
"host" => {
__f_host = Some({
struct _S;
impl<'de> serde::de::DeserializeSeed<'de> for _S {
type Value = ::buffa::alloc::string::String;
fn deserialize<D: serde::Deserializer<'de>>(
self,
d: D,
) -> ::core::result::Result<
::buffa::alloc::string::String,
D::Error,
> {
::buffa::json_helpers::proto_string::deserialize(d)
}
}
map.next_value_seed(_S)?
});
}
"fileByFilename" | "file_by_filename" => {
let v: ::core::option::Option<
::buffa::alloc::string::String,
> = map
.next_value_seed(
::buffa::json_helpers::NullableDeserializeSeed(
::buffa::json_helpers::DefaultDeserializeSeed::<
::buffa::alloc::string::String,
>::new(),
),
)?;
if let Some(v) = v {
if __oneof_message_request.is_some() {
return Err(
serde::de::Error::custom(
"multiple oneof fields set for 'message_request'",
),
);
}
__oneof_message_request = Some(
__buffa::oneof::server_reflection_request::MessageRequest::FileByFilename(
v,
),
);
}
}
"fileContainingSymbol" | "file_containing_symbol" => {
let v: ::core::option::Option<
::buffa::alloc::string::String,
> = map
.next_value_seed(
::buffa::json_helpers::NullableDeserializeSeed(
::buffa::json_helpers::DefaultDeserializeSeed::<
::buffa::alloc::string::String,
>::new(),
),
)?;
if let Some(v) = v {
if __oneof_message_request.is_some() {
return Err(
serde::de::Error::custom(
"multiple oneof fields set for 'message_request'",
),
);
}
__oneof_message_request = Some(
__buffa::oneof::server_reflection_request::MessageRequest::FileContainingSymbol(
v,
),
);
}
}
"fileContainingExtension" | "file_containing_extension" => {
let v: ::core::option::Option<ExtensionRequest> = map
.next_value_seed(
::buffa::json_helpers::NullableDeserializeSeed(
::buffa::json_helpers::DefaultDeserializeSeed::<
ExtensionRequest,
>::new(),
),
)?;
if let Some(v) = v {
if __oneof_message_request.is_some() {
return Err(
serde::de::Error::custom(
"multiple oneof fields set for 'message_request'",
),
);
}
__oneof_message_request = Some(
__buffa::oneof::server_reflection_request::MessageRequest::FileContainingExtension(
::buffa::alloc::boxed::Box::new(v),
),
);
}
}
"allExtensionNumbersOfType"
| "all_extension_numbers_of_type" => {
let v: ::core::option::Option<
::buffa::alloc::string::String,
> = map
.next_value_seed(
::buffa::json_helpers::NullableDeserializeSeed(
::buffa::json_helpers::DefaultDeserializeSeed::<
::buffa::alloc::string::String,
>::new(),
),
)?;
if let Some(v) = v {
if __oneof_message_request.is_some() {
return Err(
serde::de::Error::custom(
"multiple oneof fields set for 'message_request'",
),
);
}
__oneof_message_request = Some(
__buffa::oneof::server_reflection_request::MessageRequest::AllExtensionNumbersOfType(
v,
),
);
}
}
"listServices" | "list_services" => {
let v: ::core::option::Option<
::buffa::alloc::string::String,
> = map
.next_value_seed(
::buffa::json_helpers::NullableDeserializeSeed(
::buffa::json_helpers::DefaultDeserializeSeed::<
::buffa::alloc::string::String,
>::new(),
),
)?;
if let Some(v) = v {
if __oneof_message_request.is_some() {
return Err(
serde::de::Error::custom(
"multiple oneof fields set for 'message_request'",
),
);
}
__oneof_message_request = Some(
__buffa::oneof::server_reflection_request::MessageRequest::ListServices(
v,
),
);
}
}
_ => {
map.next_value::<serde::de::IgnoredAny>()?;
}
}
}
let mut __r = <ServerReflectionRequest as ::core::default::Default>::default();
if let ::core::option::Option::Some(v) = __f_host {
__r.host = v;
}
__r.message_request = __oneof_message_request;
Ok(__r)
}
}
d.deserialize_map(_V)
}
}
impl ::buffa::json_helpers::ProtoElemJson for ServerReflectionRequest {
fn serialize_proto_json<S: ::serde::Serializer>(
v: &Self,
s: S,
) -> ::core::result::Result<S::Ok, S::Error> {
::serde::Serialize::serialize(v, s)
}
fn deserialize_proto_json<'de, D: ::serde::Deserializer<'de>>(
d: D,
) -> ::core::result::Result<Self, D::Error> {
<Self as ::serde::Deserialize>::deserialize(d)
}
}
#[doc(hidden)]
pub const __SERVER_REFLECTION_REQUEST_JSON_ANY: ::buffa::type_registry::JsonAnyEntry = ::buffa::type_registry::JsonAnyEntry {
type_url: "type.googleapis.com/grpc.reflection.v1alpha.ServerReflectionRequest",
to_json: ::buffa::type_registry::any_to_json::<ServerReflectionRequest>,
from_json: ::buffa::type_registry::any_from_json::<ServerReflectionRequest>,
is_wkt: false,
};
pub mod server_reflection_request {
#[allow(unused_imports)]
use super::*;
#[doc(inline)]
pub use super::__buffa::oneof::server_reflection_request::MessageRequest;
#[doc(inline)]
pub use super::__buffa::view::oneof::server_reflection_request::MessageRequest as MessageRequestView;
}
#[derive(Clone, PartialEq, Default)]
#[derive(::serde::Serialize, ::serde::Deserialize)]
#[serde(default)]
pub struct ExtensionRequest {
#[serde(
rename = "containingType",
alias = "containing_type",
with = "::buffa::json_helpers::proto_string",
skip_serializing_if = "::buffa::json_helpers::skip_if::is_empty_str"
)]
pub containing_type: ::buffa::alloc::string::String,
#[serde(
rename = "extensionNumber",
alias = "extension_number",
with = "::buffa::json_helpers::int32",
skip_serializing_if = "::buffa::json_helpers::skip_if::is_zero_i32"
)]
pub extension_number: i32,
#[serde(skip)]
#[doc(hidden)]
pub __buffa_unknown_fields: ::buffa::UnknownFields,
}
impl ::core::fmt::Debug for ExtensionRequest {
fn fmt(&self, f: &mut ::core::fmt::Formatter<'_>) -> ::core::fmt::Result {
f.debug_struct("ExtensionRequest")
.field("containing_type", &self.containing_type)
.field("extension_number", &self.extension_number)
.finish()
}
}
impl ExtensionRequest {
pub const TYPE_URL: &'static str = "type.googleapis.com/grpc.reflection.v1alpha.ExtensionRequest";
}
impl ::buffa::DefaultInstance for ExtensionRequest {
fn default_instance() -> &'static Self {
static VALUE: ::buffa::__private::OnceBox<ExtensionRequest> = ::buffa::__private::OnceBox::new();
VALUE.get_or_init(|| ::buffa::alloc::boxed::Box::new(Self::default()))
}
}
impl ::buffa::MessageName for ExtensionRequest {
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";
}
impl ::buffa::Message for ExtensionRequest {
#[allow(clippy::let_and_return)]
fn compute_size(&self, _cache: &mut ::buffa::SizeCache) -> u32 {
#[allow(unused_imports)]
use ::buffa::Enumeration as _;
let mut size = 0u32;
if !self.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
}
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::encoding::Tag::new(
1u32,
::buffa::encoding::WireType::LengthDelimited,
)
.encode(buf);
::buffa::types::encode_string(&self.containing_type, buf);
}
if self.extension_number != 0i32 {
::buffa::encoding::Tag::new(2u32, ::buffa::encoding::WireType::Varint)
.encode(buf);
::buffa::types::encode_int32(self.extension_number, buf);
}
self.__buffa_unknown_fields.write_to(buf);
}
fn merge_field(
&mut self,
tag: ::buffa::encoding::Tag,
buf: &mut impl ::buffa::bytes::Buf,
depth: u32,
) -> ::core::result::Result<(), ::buffa::DecodeError> {
#[allow(unused_imports)]
use ::buffa::bytes::Buf as _;
#[allow(unused_imports)]
use ::buffa::Enumeration as _;
match tag.field_number() {
1u32 => {
if tag.wire_type() != ::buffa::encoding::WireType::LengthDelimited {
return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
field_number: 1u32,
expected: 2u8,
actual: tag.wire_type() as u8,
});
}
::buffa::types::merge_string(&mut self.containing_type, buf)?;
}
2u32 => {
if tag.wire_type() != ::buffa::encoding::WireType::Varint {
return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
field_number: 2u32,
expected: 0u8,
actual: tag.wire_type() as u8,
});
}
self.extension_number = ::buffa::types::decode_int32(buf)?;
}
_ => {
self.__buffa_unknown_fields
.push(::buffa::encoding::decode_unknown_field(tag, buf, depth)?);
}
}
::core::result::Result::Ok(())
}
fn clear(&mut self) {
self.containing_type.clear();
self.extension_number = 0i32;
self.__buffa_unknown_fields.clear();
}
}
impl ::buffa::ExtensionSet for ExtensionRequest {
const PROTO_FQN: &'static str = "grpc.reflection.v1alpha.ExtensionRequest";
fn unknown_fields(&self) -> &::buffa::UnknownFields {
&self.__buffa_unknown_fields
}
fn unknown_fields_mut(&mut self) -> &mut ::buffa::UnknownFields {
&mut self.__buffa_unknown_fields
}
}
impl ::buffa::json_helpers::ProtoElemJson for ExtensionRequest {
fn serialize_proto_json<S: ::serde::Serializer>(
v: &Self,
s: S,
) -> ::core::result::Result<S::Ok, S::Error> {
::serde::Serialize::serialize(v, s)
}
fn deserialize_proto_json<'de, D: ::serde::Deserializer<'de>>(
d: D,
) -> ::core::result::Result<Self, D::Error> {
<Self as ::serde::Deserialize>::deserialize(d)
}
}
#[doc(hidden)]
pub const __EXTENSION_REQUEST_JSON_ANY: ::buffa::type_registry::JsonAnyEntry = ::buffa::type_registry::JsonAnyEntry {
type_url: "type.googleapis.com/grpc.reflection.v1alpha.ExtensionRequest",
to_json: ::buffa::type_registry::any_to_json::<ExtensionRequest>,
from_json: ::buffa::type_registry::any_from_json::<ExtensionRequest>,
is_wkt: false,
};
#[derive(Clone, PartialEq, Default)]
#[derive(::serde::Serialize)]
#[serde(default)]
pub struct ServerReflectionResponse {
#[serde(
rename = "validHost",
alias = "valid_host",
with = "::buffa::json_helpers::proto_string",
skip_serializing_if = "::buffa::json_helpers::skip_if::is_empty_str"
)]
pub valid_host: ::buffa::alloc::string::String,
#[serde(
rename = "originalRequest",
alias = "original_request",
skip_serializing_if = "::buffa::json_helpers::skip_if::is_unset_message_field"
)]
pub original_request: ::buffa::MessageField<ServerReflectionRequest>,
#[serde(flatten)]
pub message_response: ::core::option::Option<
__buffa::oneof::server_reflection_response::MessageResponse,
>,
#[serde(skip)]
#[doc(hidden)]
pub __buffa_unknown_fields: ::buffa::UnknownFields,
}
impl ::core::fmt::Debug for ServerReflectionResponse {
fn fmt(&self, f: &mut ::core::fmt::Formatter<'_>) -> ::core::fmt::Result {
f.debug_struct("ServerReflectionResponse")
.field("valid_host", &self.valid_host)
.field("original_request", &self.original_request)
.field("message_response", &self.message_response)
.finish()
}
}
impl ServerReflectionResponse {
pub const TYPE_URL: &'static str = "type.googleapis.com/grpc.reflection.v1alpha.ServerReflectionResponse";
}
impl ::buffa::DefaultInstance for ServerReflectionResponse {
fn default_instance() -> &'static Self {
static VALUE: ::buffa::__private::OnceBox<ServerReflectionResponse> = ::buffa::__private::OnceBox::new();
VALUE.get_or_init(|| ::buffa::alloc::boxed::Box::new(Self::default()))
}
}
impl ::buffa::MessageName for ServerReflectionResponse {
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";
}
impl ::buffa::Message for ServerReflectionResponse {
#[allow(clippy::let_and_return)]
fn compute_size(&self, __cache: &mut ::buffa::SizeCache) -> u32 {
#[allow(unused_imports)]
use ::buffa::Enumeration as _;
let mut size = 0u32;
if !self.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 {
__buffa::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;
}
__buffa::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;
}
__buffa::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;
}
__buffa::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
}
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::encoding::Tag::new(
1u32,
::buffa::encoding::WireType::LengthDelimited,
)
.encode(buf);
::buffa::types::encode_string(&self.valid_host, buf);
}
if self.original_request.is_set() {
::buffa::encoding::Tag::new(
2u32,
::buffa::encoding::WireType::LengthDelimited,
)
.encode(buf);
::buffa::encoding::encode_varint(__cache.consume_next() as u64, buf);
self.original_request.write_to(__cache, buf);
}
if let ::core::option::Option::Some(ref v) = self.message_response {
match v {
__buffa::oneof::server_reflection_response::MessageResponse::FileDescriptorResponse(
x,
) => {
::buffa::encoding::Tag::new(
4u32,
::buffa::encoding::WireType::LengthDelimited,
)
.encode(buf);
::buffa::encoding::encode_varint(__cache.consume_next() as u64, buf);
x.write_to(__cache, buf);
}
__buffa::oneof::server_reflection_response::MessageResponse::AllExtensionNumbersResponse(
x,
) => {
::buffa::encoding::Tag::new(
5u32,
::buffa::encoding::WireType::LengthDelimited,
)
.encode(buf);
::buffa::encoding::encode_varint(__cache.consume_next() as u64, buf);
x.write_to(__cache, buf);
}
__buffa::oneof::server_reflection_response::MessageResponse::ListServicesResponse(
x,
) => {
::buffa::encoding::Tag::new(
6u32,
::buffa::encoding::WireType::LengthDelimited,
)
.encode(buf);
::buffa::encoding::encode_varint(__cache.consume_next() as u64, buf);
x.write_to(__cache, buf);
}
__buffa::oneof::server_reflection_response::MessageResponse::ErrorResponse(
x,
) => {
::buffa::encoding::Tag::new(
7u32,
::buffa::encoding::WireType::LengthDelimited,
)
.encode(buf);
::buffa::encoding::encode_varint(__cache.consume_next() as u64, buf);
x.write_to(__cache, buf);
}
}
}
self.__buffa_unknown_fields.write_to(buf);
}
fn merge_field(
&mut self,
tag: ::buffa::encoding::Tag,
buf: &mut impl ::buffa::bytes::Buf,
depth: u32,
) -> ::core::result::Result<(), ::buffa::DecodeError> {
#[allow(unused_imports)]
use ::buffa::bytes::Buf as _;
#[allow(unused_imports)]
use ::buffa::Enumeration as _;
match tag.field_number() {
1u32 => {
if tag.wire_type() != ::buffa::encoding::WireType::LengthDelimited {
return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
field_number: 1u32,
expected: 2u8,
actual: tag.wire_type() as u8,
});
}
::buffa::types::merge_string(&mut self.valid_host, buf)?;
}
2u32 => {
if tag.wire_type() != ::buffa::encoding::WireType::LengthDelimited {
return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
field_number: 2u32,
expected: 2u8,
actual: tag.wire_type() as u8,
});
}
::buffa::Message::merge_length_delimited(
self.original_request.get_or_insert_default(),
buf,
depth,
)?;
}
4u32 => {
if tag.wire_type() != ::buffa::encoding::WireType::LengthDelimited {
return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
field_number: 4u32,
expected: 2u8,
actual: tag.wire_type() as u8,
});
}
if let ::core::option::Option::Some(
__buffa::oneof::server_reflection_response::MessageResponse::FileDescriptorResponse(
ref mut existing,
),
) = self.message_response
{
::buffa::Message::merge_length_delimited(
&mut **existing,
buf,
depth,
)?;
} else {
let mut val = ::core::default::Default::default();
::buffa::Message::merge_length_delimited(&mut val, buf, depth)?;
self.message_response = ::core::option::Option::Some(
__buffa::oneof::server_reflection_response::MessageResponse::FileDescriptorResponse(
::buffa::alloc::boxed::Box::new(val),
),
);
}
}
5u32 => {
if tag.wire_type() != ::buffa::encoding::WireType::LengthDelimited {
return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
field_number: 5u32,
expected: 2u8,
actual: tag.wire_type() as u8,
});
}
if let ::core::option::Option::Some(
__buffa::oneof::server_reflection_response::MessageResponse::AllExtensionNumbersResponse(
ref mut existing,
),
) = self.message_response
{
::buffa::Message::merge_length_delimited(
&mut **existing,
buf,
depth,
)?;
} else {
let mut val = ::core::default::Default::default();
::buffa::Message::merge_length_delimited(&mut val, buf, depth)?;
self.message_response = ::core::option::Option::Some(
__buffa::oneof::server_reflection_response::MessageResponse::AllExtensionNumbersResponse(
::buffa::alloc::boxed::Box::new(val),
),
);
}
}
6u32 => {
if tag.wire_type() != ::buffa::encoding::WireType::LengthDelimited {
return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
field_number: 6u32,
expected: 2u8,
actual: tag.wire_type() as u8,
});
}
if let ::core::option::Option::Some(
__buffa::oneof::server_reflection_response::MessageResponse::ListServicesResponse(
ref mut existing,
),
) = self.message_response
{
::buffa::Message::merge_length_delimited(
&mut **existing,
buf,
depth,
)?;
} else {
let mut val = ::core::default::Default::default();
::buffa::Message::merge_length_delimited(&mut val, buf, depth)?;
self.message_response = ::core::option::Option::Some(
__buffa::oneof::server_reflection_response::MessageResponse::ListServicesResponse(
::buffa::alloc::boxed::Box::new(val),
),
);
}
}
7u32 => {
if tag.wire_type() != ::buffa::encoding::WireType::LengthDelimited {
return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
field_number: 7u32,
expected: 2u8,
actual: tag.wire_type() as u8,
});
}
if let ::core::option::Option::Some(
__buffa::oneof::server_reflection_response::MessageResponse::ErrorResponse(
ref mut existing,
),
) = self.message_response
{
::buffa::Message::merge_length_delimited(
&mut **existing,
buf,
depth,
)?;
} else {
let mut val = ::core::default::Default::default();
::buffa::Message::merge_length_delimited(&mut val, buf, depth)?;
self.message_response = ::core::option::Option::Some(
__buffa::oneof::server_reflection_response::MessageResponse::ErrorResponse(
::buffa::alloc::boxed::Box::new(val),
),
);
}
}
_ => {
self.__buffa_unknown_fields
.push(::buffa::encoding::decode_unknown_field(tag, buf, depth)?);
}
}
::core::result::Result::Ok(())
}
fn clear(&mut self) {
self.valid_host.clear();
self.original_request = ::buffa::MessageField::none();
self.message_response = ::core::option::Option::None;
self.__buffa_unknown_fields.clear();
}
}
impl ::buffa::ExtensionSet for ServerReflectionResponse {
const PROTO_FQN: &'static str = "grpc.reflection.v1alpha.ServerReflectionResponse";
fn unknown_fields(&self) -> &::buffa::UnknownFields {
&self.__buffa_unknown_fields
}
fn unknown_fields_mut(&mut self) -> &mut ::buffa::UnknownFields {
&mut self.__buffa_unknown_fields
}
}
impl<'de> serde::Deserialize<'de> for ServerReflectionResponse {
fn deserialize<D: serde::Deserializer<'de>>(
d: D,
) -> ::core::result::Result<Self, D::Error> {
struct _V;
impl<'de> serde::de::Visitor<'de> for _V {
type Value = ServerReflectionResponse;
fn expecting(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result {
f.write_str("struct ServerReflectionResponse")
}
#[allow(clippy::field_reassign_with_default)]
fn visit_map<A: serde::de::MapAccess<'de>>(
self,
mut map: A,
) -> ::core::result::Result<ServerReflectionResponse, A::Error> {
let mut __f_valid_host: ::core::option::Option<
::buffa::alloc::string::String,
> = None;
let mut __f_original_request: ::core::option::Option<
::buffa::MessageField<ServerReflectionRequest>,
> = None;
let mut __oneof_message_response: ::core::option::Option<
__buffa::oneof::server_reflection_response::MessageResponse,
> = None;
while let Some(key) = map.next_key::<::buffa::alloc::string::String>()? {
match key.as_str() {
"validHost" | "valid_host" => {
__f_valid_host = Some({
struct _S;
impl<'de> serde::de::DeserializeSeed<'de> for _S {
type Value = ::buffa::alloc::string::String;
fn deserialize<D: serde::Deserializer<'de>>(
self,
d: D,
) -> ::core::result::Result<
::buffa::alloc::string::String,
D::Error,
> {
::buffa::json_helpers::proto_string::deserialize(d)
}
}
map.next_value_seed(_S)?
});
}
"originalRequest" | "original_request" => {
__f_original_request = Some(
map
.next_value::<
::buffa::MessageField<ServerReflectionRequest>,
>()?,
);
}
"fileDescriptorResponse" | "file_descriptor_response" => {
let v: ::core::option::Option<FileDescriptorResponse> = map
.next_value_seed(
::buffa::json_helpers::NullableDeserializeSeed(
::buffa::json_helpers::DefaultDeserializeSeed::<
FileDescriptorResponse,
>::new(),
),
)?;
if let Some(v) = v {
if __oneof_message_response.is_some() {
return Err(
serde::de::Error::custom(
"multiple oneof fields set for 'message_response'",
),
);
}
__oneof_message_response = Some(
__buffa::oneof::server_reflection_response::MessageResponse::FileDescriptorResponse(
::buffa::alloc::boxed::Box::new(v),
),
);
}
}
"allExtensionNumbersResponse"
| "all_extension_numbers_response" => {
let v: ::core::option::Option<ExtensionNumberResponse> = map
.next_value_seed(
::buffa::json_helpers::NullableDeserializeSeed(
::buffa::json_helpers::DefaultDeserializeSeed::<
ExtensionNumberResponse,
>::new(),
),
)?;
if let Some(v) = v {
if __oneof_message_response.is_some() {
return Err(
serde::de::Error::custom(
"multiple oneof fields set for 'message_response'",
),
);
}
__oneof_message_response = Some(
__buffa::oneof::server_reflection_response::MessageResponse::AllExtensionNumbersResponse(
::buffa::alloc::boxed::Box::new(v),
),
);
}
}
"listServicesResponse" | "list_services_response" => {
let v: ::core::option::Option<ListServiceResponse> = map
.next_value_seed(
::buffa::json_helpers::NullableDeserializeSeed(
::buffa::json_helpers::DefaultDeserializeSeed::<
ListServiceResponse,
>::new(),
),
)?;
if let Some(v) = v {
if __oneof_message_response.is_some() {
return Err(
serde::de::Error::custom(
"multiple oneof fields set for 'message_response'",
),
);
}
__oneof_message_response = Some(
__buffa::oneof::server_reflection_response::MessageResponse::ListServicesResponse(
::buffa::alloc::boxed::Box::new(v),
),
);
}
}
"errorResponse" | "error_response" => {
let v: ::core::option::Option<ErrorResponse> = map
.next_value_seed(
::buffa::json_helpers::NullableDeserializeSeed(
::buffa::json_helpers::DefaultDeserializeSeed::<
ErrorResponse,
>::new(),
),
)?;
if let Some(v) = v {
if __oneof_message_response.is_some() {
return Err(
serde::de::Error::custom(
"multiple oneof fields set for 'message_response'",
),
);
}
__oneof_message_response = Some(
__buffa::oneof::server_reflection_response::MessageResponse::ErrorResponse(
::buffa::alloc::boxed::Box::new(v),
),
);
}
}
_ => {
map.next_value::<serde::de::IgnoredAny>()?;
}
}
}
let mut __r = <ServerReflectionResponse as ::core::default::Default>::default();
if let ::core::option::Option::Some(v) = __f_valid_host {
__r.valid_host = v;
}
if let ::core::option::Option::Some(v) = __f_original_request {
__r.original_request = v;
}
__r.message_response = __oneof_message_response;
Ok(__r)
}
}
d.deserialize_map(_V)
}
}
impl ::buffa::json_helpers::ProtoElemJson for ServerReflectionResponse {
fn serialize_proto_json<S: ::serde::Serializer>(
v: &Self,
s: S,
) -> ::core::result::Result<S::Ok, S::Error> {
::serde::Serialize::serialize(v, s)
}
fn deserialize_proto_json<'de, D: ::serde::Deserializer<'de>>(
d: D,
) -> ::core::result::Result<Self, D::Error> {
<Self as ::serde::Deserialize>::deserialize(d)
}
}
#[doc(hidden)]
pub const __SERVER_REFLECTION_RESPONSE_JSON_ANY: ::buffa::type_registry::JsonAnyEntry = ::buffa::type_registry::JsonAnyEntry {
type_url: "type.googleapis.com/grpc.reflection.v1alpha.ServerReflectionResponse",
to_json: ::buffa::type_registry::any_to_json::<ServerReflectionResponse>,
from_json: ::buffa::type_registry::any_from_json::<ServerReflectionResponse>,
is_wkt: false,
};
pub mod server_reflection_response {
#[allow(unused_imports)]
use super::*;
#[doc(inline)]
pub use super::__buffa::oneof::server_reflection_response::MessageResponse;
#[doc(inline)]
pub use super::__buffa::view::oneof::server_reflection_response::MessageResponse as MessageResponseView;
}
#[derive(Clone, PartialEq, Default)]
#[derive(::serde::Serialize, ::serde::Deserialize)]
#[serde(default)]
pub struct FileDescriptorResponse {
#[serde(
rename = "fileDescriptorProto",
alias = "file_descriptor_proto",
with = "::buffa::json_helpers::proto_seq",
skip_serializing_if = "::buffa::json_helpers::skip_if::is_empty_vec"
)]
pub file_descriptor_proto: ::buffa::alloc::vec::Vec<::buffa::alloc::vec::Vec<u8>>,
#[serde(skip)]
#[doc(hidden)]
pub __buffa_unknown_fields: ::buffa::UnknownFields,
}
impl ::core::fmt::Debug for FileDescriptorResponse {
fn fmt(&self, f: &mut ::core::fmt::Formatter<'_>) -> ::core::fmt::Result {
f.debug_struct("FileDescriptorResponse")
.field("file_descriptor_proto", &self.file_descriptor_proto)
.finish()
}
}
impl FileDescriptorResponse {
pub const TYPE_URL: &'static str = "type.googleapis.com/grpc.reflection.v1alpha.FileDescriptorResponse";
}
impl ::buffa::DefaultInstance for FileDescriptorResponse {
fn default_instance() -> &'static Self {
static VALUE: ::buffa::__private::OnceBox<FileDescriptorResponse> = ::buffa::__private::OnceBox::new();
VALUE.get_or_init(|| ::buffa::alloc::boxed::Box::new(Self::default()))
}
}
impl ::buffa::MessageName for FileDescriptorResponse {
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";
}
impl ::buffa::Message for FileDescriptorResponse {
#[allow(clippy::let_and_return)]
fn compute_size(&self, _cache: &mut ::buffa::SizeCache) -> u32 {
#[allow(unused_imports)]
use ::buffa::Enumeration as _;
let mut size = 0u32;
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
}
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::encoding::Tag::new(
1u32,
::buffa::encoding::WireType::LengthDelimited,
)
.encode(buf);
::buffa::types::encode_bytes(v, buf);
}
self.__buffa_unknown_fields.write_to(buf);
}
fn merge_field(
&mut self,
tag: ::buffa::encoding::Tag,
buf: &mut impl ::buffa::bytes::Buf,
depth: u32,
) -> ::core::result::Result<(), ::buffa::DecodeError> {
#[allow(unused_imports)]
use ::buffa::bytes::Buf as _;
#[allow(unused_imports)]
use ::buffa::Enumeration as _;
match tag.field_number() {
1u32 => {
if tag.wire_type() != ::buffa::encoding::WireType::LengthDelimited {
return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
field_number: 1u32,
expected: 2u8,
actual: tag.wire_type() as u8,
});
}
self.file_descriptor_proto.push(::buffa::types::decode_bytes(buf)?);
}
_ => {
self.__buffa_unknown_fields
.push(::buffa::encoding::decode_unknown_field(tag, buf, depth)?);
}
}
::core::result::Result::Ok(())
}
fn clear(&mut self) {
self.file_descriptor_proto.clear();
self.__buffa_unknown_fields.clear();
}
}
impl ::buffa::ExtensionSet for FileDescriptorResponse {
const PROTO_FQN: &'static str = "grpc.reflection.v1alpha.FileDescriptorResponse";
fn unknown_fields(&self) -> &::buffa::UnknownFields {
&self.__buffa_unknown_fields
}
fn unknown_fields_mut(&mut self) -> &mut ::buffa::UnknownFields {
&mut self.__buffa_unknown_fields
}
}
impl ::buffa::json_helpers::ProtoElemJson for FileDescriptorResponse {
fn serialize_proto_json<S: ::serde::Serializer>(
v: &Self,
s: S,
) -> ::core::result::Result<S::Ok, S::Error> {
::serde::Serialize::serialize(v, s)
}
fn deserialize_proto_json<'de, D: ::serde::Deserializer<'de>>(
d: D,
) -> ::core::result::Result<Self, D::Error> {
<Self as ::serde::Deserialize>::deserialize(d)
}
}
#[doc(hidden)]
pub const __FILE_DESCRIPTOR_RESPONSE_JSON_ANY: ::buffa::type_registry::JsonAnyEntry = ::buffa::type_registry::JsonAnyEntry {
type_url: "type.googleapis.com/grpc.reflection.v1alpha.FileDescriptorResponse",
to_json: ::buffa::type_registry::any_to_json::<FileDescriptorResponse>,
from_json: ::buffa::type_registry::any_from_json::<FileDescriptorResponse>,
is_wkt: false,
};
#[derive(Clone, PartialEq, Default)]
#[derive(::serde::Serialize, ::serde::Deserialize)]
#[serde(default)]
pub struct ExtensionNumberResponse {
#[serde(
rename = "baseTypeName",
alias = "base_type_name",
with = "::buffa::json_helpers::proto_string",
skip_serializing_if = "::buffa::json_helpers::skip_if::is_empty_str"
)]
pub base_type_name: ::buffa::alloc::string::String,
#[serde(
rename = "extensionNumber",
alias = "extension_number",
skip_serializing_if = "::buffa::json_helpers::skip_if::is_empty_vec",
deserialize_with = "::buffa::json_helpers::null_as_default"
)]
pub extension_number: ::buffa::alloc::vec::Vec<i32>,
#[serde(skip)]
#[doc(hidden)]
pub __buffa_unknown_fields: ::buffa::UnknownFields,
}
impl ::core::fmt::Debug for ExtensionNumberResponse {
fn fmt(&self, f: &mut ::core::fmt::Formatter<'_>) -> ::core::fmt::Result {
f.debug_struct("ExtensionNumberResponse")
.field("base_type_name", &self.base_type_name)
.field("extension_number", &self.extension_number)
.finish()
}
}
impl ExtensionNumberResponse {
pub const TYPE_URL: &'static str = "type.googleapis.com/grpc.reflection.v1alpha.ExtensionNumberResponse";
}
impl ::buffa::DefaultInstance for ExtensionNumberResponse {
fn default_instance() -> &'static Self {
static VALUE: ::buffa::__private::OnceBox<ExtensionNumberResponse> = ::buffa::__private::OnceBox::new();
VALUE.get_or_init(|| ::buffa::alloc::boxed::Box::new(Self::default()))
}
}
impl ::buffa::MessageName for ExtensionNumberResponse {
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";
}
impl ::buffa::Message for ExtensionNumberResponse {
#[allow(clippy::let_and_return)]
fn compute_size(&self, _cache: &mut ::buffa::SizeCache) -> u32 {
#[allow(unused_imports)]
use ::buffa::Enumeration as _;
let mut size = 0u32;
if !self.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
}
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::encoding::Tag::new(
1u32,
::buffa::encoding::WireType::LengthDelimited,
)
.encode(buf);
::buffa::types::encode_string(&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::encoding::Tag::new(
2u32,
::buffa::encoding::WireType::LengthDelimited,
)
.encode(buf);
::buffa::encoding::encode_varint(payload as u64, buf);
for &v in &self.extension_number {
::buffa::types::encode_int32(v, buf);
}
}
self.__buffa_unknown_fields.write_to(buf);
}
fn merge_field(
&mut self,
tag: ::buffa::encoding::Tag,
buf: &mut impl ::buffa::bytes::Buf,
depth: u32,
) -> ::core::result::Result<(), ::buffa::DecodeError> {
#[allow(unused_imports)]
use ::buffa::bytes::Buf as _;
#[allow(unused_imports)]
use ::buffa::Enumeration as _;
match tag.field_number() {
1u32 => {
if tag.wire_type() != ::buffa::encoding::WireType::LengthDelimited {
return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
field_number: 1u32,
expected: 2u8,
actual: tag.wire_type() as u8,
});
}
::buffa::types::merge_string(&mut self.base_type_name, buf)?;
}
2u32 => {
if tag.wire_type() == ::buffa::encoding::WireType::LengthDelimited {
let len = ::buffa::encoding::decode_varint(buf)?;
let len = usize::try_from(len)
.map_err(|_| ::buffa::DecodeError::MessageTooLarge)?;
if buf.remaining() < len {
return ::core::result::Result::Err(
::buffa::DecodeError::UnexpectedEof,
);
}
self.extension_number.reserve(len);
let mut limited = buf.take(len);
while limited.has_remaining() {
self.extension_number
.push(::buffa::types::decode_int32(&mut limited)?);
}
let leftover = limited.remaining();
if leftover > 0 {
limited.advance(leftover);
}
} else if tag.wire_type() == ::buffa::encoding::WireType::Varint {
self.extension_number.push(::buffa::types::decode_int32(buf)?);
} else {
return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
field_number: 2u32,
expected: 2u8,
actual: tag.wire_type() as u8,
});
}
}
_ => {
self.__buffa_unknown_fields
.push(::buffa::encoding::decode_unknown_field(tag, buf, depth)?);
}
}
::core::result::Result::Ok(())
}
fn clear(&mut self) {
self.base_type_name.clear();
self.extension_number.clear();
self.__buffa_unknown_fields.clear();
}
}
impl ::buffa::ExtensionSet for ExtensionNumberResponse {
const PROTO_FQN: &'static str = "grpc.reflection.v1alpha.ExtensionNumberResponse";
fn unknown_fields(&self) -> &::buffa::UnknownFields {
&self.__buffa_unknown_fields
}
fn unknown_fields_mut(&mut self) -> &mut ::buffa::UnknownFields {
&mut self.__buffa_unknown_fields
}
}
impl ::buffa::json_helpers::ProtoElemJson for ExtensionNumberResponse {
fn serialize_proto_json<S: ::serde::Serializer>(
v: &Self,
s: S,
) -> ::core::result::Result<S::Ok, S::Error> {
::serde::Serialize::serialize(v, s)
}
fn deserialize_proto_json<'de, D: ::serde::Deserializer<'de>>(
d: D,
) -> ::core::result::Result<Self, D::Error> {
<Self as ::serde::Deserialize>::deserialize(d)
}
}
#[doc(hidden)]
pub const __EXTENSION_NUMBER_RESPONSE_JSON_ANY: ::buffa::type_registry::JsonAnyEntry = ::buffa::type_registry::JsonAnyEntry {
type_url: "type.googleapis.com/grpc.reflection.v1alpha.ExtensionNumberResponse",
to_json: ::buffa::type_registry::any_to_json::<ExtensionNumberResponse>,
from_json: ::buffa::type_registry::any_from_json::<ExtensionNumberResponse>,
is_wkt: false,
};
#[derive(Clone, PartialEq, Default)]
#[derive(::serde::Serialize, ::serde::Deserialize)]
#[serde(default)]
pub struct ListServiceResponse {
#[serde(
rename = "service",
skip_serializing_if = "::buffa::json_helpers::skip_if::is_empty_vec",
deserialize_with = "::buffa::json_helpers::null_as_default"
)]
pub service: ::buffa::alloc::vec::Vec<ServiceResponse>,
#[serde(skip)]
#[doc(hidden)]
pub __buffa_unknown_fields: ::buffa::UnknownFields,
}
impl ::core::fmt::Debug for ListServiceResponse {
fn fmt(&self, f: &mut ::core::fmt::Formatter<'_>) -> ::core::fmt::Result {
f.debug_struct("ListServiceResponse").field("service", &self.service).finish()
}
}
impl ListServiceResponse {
pub const TYPE_URL: &'static str = "type.googleapis.com/grpc.reflection.v1alpha.ListServiceResponse";
}
impl ::buffa::DefaultInstance for ListServiceResponse {
fn default_instance() -> &'static Self {
static VALUE: ::buffa::__private::OnceBox<ListServiceResponse> = ::buffa::__private::OnceBox::new();
VALUE.get_or_init(|| ::buffa::alloc::boxed::Box::new(Self::default()))
}
}
impl ::buffa::MessageName for ListServiceResponse {
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";
}
impl ::buffa::Message for ListServiceResponse {
#[allow(clippy::let_and_return)]
fn compute_size(&self, __cache: &mut ::buffa::SizeCache) -> u32 {
#[allow(unused_imports)]
use ::buffa::Enumeration as _;
let mut size = 0u32;
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
}
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::encoding::Tag::new(
1u32,
::buffa::encoding::WireType::LengthDelimited,
)
.encode(buf);
::buffa::encoding::encode_varint(__cache.consume_next() as u64, buf);
v.write_to(__cache, buf);
}
self.__buffa_unknown_fields.write_to(buf);
}
fn merge_field(
&mut self,
tag: ::buffa::encoding::Tag,
buf: &mut impl ::buffa::bytes::Buf,
depth: u32,
) -> ::core::result::Result<(), ::buffa::DecodeError> {
#[allow(unused_imports)]
use ::buffa::bytes::Buf as _;
#[allow(unused_imports)]
use ::buffa::Enumeration as _;
match tag.field_number() {
1u32 => {
if tag.wire_type() != ::buffa::encoding::WireType::LengthDelimited {
return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
field_number: 1u32,
expected: 2u8,
actual: tag.wire_type() as u8,
});
}
let mut elem = ::core::default::Default::default();
::buffa::Message::merge_length_delimited(&mut elem, buf, depth)?;
self.service.push(elem);
}
_ => {
self.__buffa_unknown_fields
.push(::buffa::encoding::decode_unknown_field(tag, buf, depth)?);
}
}
::core::result::Result::Ok(())
}
fn clear(&mut self) {
self.service.clear();
self.__buffa_unknown_fields.clear();
}
}
impl ::buffa::ExtensionSet for ListServiceResponse {
const PROTO_FQN: &'static str = "grpc.reflection.v1alpha.ListServiceResponse";
fn unknown_fields(&self) -> &::buffa::UnknownFields {
&self.__buffa_unknown_fields
}
fn unknown_fields_mut(&mut self) -> &mut ::buffa::UnknownFields {
&mut self.__buffa_unknown_fields
}
}
impl ::buffa::json_helpers::ProtoElemJson for ListServiceResponse {
fn serialize_proto_json<S: ::serde::Serializer>(
v: &Self,
s: S,
) -> ::core::result::Result<S::Ok, S::Error> {
::serde::Serialize::serialize(v, s)
}
fn deserialize_proto_json<'de, D: ::serde::Deserializer<'de>>(
d: D,
) -> ::core::result::Result<Self, D::Error> {
<Self as ::serde::Deserialize>::deserialize(d)
}
}
#[doc(hidden)]
pub const __LIST_SERVICE_RESPONSE_JSON_ANY: ::buffa::type_registry::JsonAnyEntry = ::buffa::type_registry::JsonAnyEntry {
type_url: "type.googleapis.com/grpc.reflection.v1alpha.ListServiceResponse",
to_json: ::buffa::type_registry::any_to_json::<ListServiceResponse>,
from_json: ::buffa::type_registry::any_from_json::<ListServiceResponse>,
is_wkt: false,
};
#[derive(Clone, PartialEq, Default)]
#[derive(::serde::Serialize, ::serde::Deserialize)]
#[serde(default)]
pub struct ServiceResponse {
#[serde(
rename = "name",
with = "::buffa::json_helpers::proto_string",
skip_serializing_if = "::buffa::json_helpers::skip_if::is_empty_str"
)]
pub name: ::buffa::alloc::string::String,
#[serde(skip)]
#[doc(hidden)]
pub __buffa_unknown_fields: ::buffa::UnknownFields,
}
impl ::core::fmt::Debug for ServiceResponse {
fn fmt(&self, f: &mut ::core::fmt::Formatter<'_>) -> ::core::fmt::Result {
f.debug_struct("ServiceResponse").field("name", &self.name).finish()
}
}
impl ServiceResponse {
pub const TYPE_URL: &'static str = "type.googleapis.com/grpc.reflection.v1alpha.ServiceResponse";
}
impl ::buffa::DefaultInstance for ServiceResponse {
fn default_instance() -> &'static Self {
static VALUE: ::buffa::__private::OnceBox<ServiceResponse> = ::buffa::__private::OnceBox::new();
VALUE.get_or_init(|| ::buffa::alloc::boxed::Box::new(Self::default()))
}
}
impl ::buffa::MessageName for ServiceResponse {
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";
}
impl ::buffa::Message for ServiceResponse {
#[allow(clippy::let_and_return)]
fn compute_size(&self, _cache: &mut ::buffa::SizeCache) -> u32 {
#[allow(unused_imports)]
use ::buffa::Enumeration as _;
let mut size = 0u32;
if !self.name.is_empty() {
size += 1u32 + ::buffa::types::string_encoded_len(&self.name) as u32;
}
size += self.__buffa_unknown_fields.encoded_len() as u32;
size
}
fn write_to(
&self,
_cache: &mut ::buffa::SizeCache,
buf: &mut impl ::buffa::bytes::BufMut,
) {
#[allow(unused_imports)]
use ::buffa::Enumeration as _;
if !self.name.is_empty() {
::buffa::encoding::Tag::new(
1u32,
::buffa::encoding::WireType::LengthDelimited,
)
.encode(buf);
::buffa::types::encode_string(&self.name, buf);
}
self.__buffa_unknown_fields.write_to(buf);
}
fn merge_field(
&mut self,
tag: ::buffa::encoding::Tag,
buf: &mut impl ::buffa::bytes::Buf,
depth: u32,
) -> ::core::result::Result<(), ::buffa::DecodeError> {
#[allow(unused_imports)]
use ::buffa::bytes::Buf as _;
#[allow(unused_imports)]
use ::buffa::Enumeration as _;
match tag.field_number() {
1u32 => {
if tag.wire_type() != ::buffa::encoding::WireType::LengthDelimited {
return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
field_number: 1u32,
expected: 2u8,
actual: tag.wire_type() as u8,
});
}
::buffa::types::merge_string(&mut self.name, buf)?;
}
_ => {
self.__buffa_unknown_fields
.push(::buffa::encoding::decode_unknown_field(tag, buf, depth)?);
}
}
::core::result::Result::Ok(())
}
fn clear(&mut self) {
self.name.clear();
self.__buffa_unknown_fields.clear();
}
}
impl ::buffa::ExtensionSet for ServiceResponse {
const PROTO_FQN: &'static str = "grpc.reflection.v1alpha.ServiceResponse";
fn unknown_fields(&self) -> &::buffa::UnknownFields {
&self.__buffa_unknown_fields
}
fn unknown_fields_mut(&mut self) -> &mut ::buffa::UnknownFields {
&mut self.__buffa_unknown_fields
}
}
impl ::buffa::json_helpers::ProtoElemJson for ServiceResponse {
fn serialize_proto_json<S: ::serde::Serializer>(
v: &Self,
s: S,
) -> ::core::result::Result<S::Ok, S::Error> {
::serde::Serialize::serialize(v, s)
}
fn deserialize_proto_json<'de, D: ::serde::Deserializer<'de>>(
d: D,
) -> ::core::result::Result<Self, D::Error> {
<Self as ::serde::Deserialize>::deserialize(d)
}
}
#[doc(hidden)]
pub const __SERVICE_RESPONSE_JSON_ANY: ::buffa::type_registry::JsonAnyEntry = ::buffa::type_registry::JsonAnyEntry {
type_url: "type.googleapis.com/grpc.reflection.v1alpha.ServiceResponse",
to_json: ::buffa::type_registry::any_to_json::<ServiceResponse>,
from_json: ::buffa::type_registry::any_from_json::<ServiceResponse>,
is_wkt: false,
};
#[derive(Clone, PartialEq, Default)]
#[derive(::serde::Serialize, ::serde::Deserialize)]
#[serde(default)]
pub struct ErrorResponse {
#[serde(
rename = "errorCode",
alias = "error_code",
with = "::buffa::json_helpers::int32",
skip_serializing_if = "::buffa::json_helpers::skip_if::is_zero_i32"
)]
pub error_code: i32,
#[serde(
rename = "errorMessage",
alias = "error_message",
with = "::buffa::json_helpers::proto_string",
skip_serializing_if = "::buffa::json_helpers::skip_if::is_empty_str"
)]
pub error_message: ::buffa::alloc::string::String,
#[serde(skip)]
#[doc(hidden)]
pub __buffa_unknown_fields: ::buffa::UnknownFields,
}
impl ::core::fmt::Debug for ErrorResponse {
fn fmt(&self, f: &mut ::core::fmt::Formatter<'_>) -> ::core::fmt::Result {
f.debug_struct("ErrorResponse")
.field("error_code", &self.error_code)
.field("error_message", &self.error_message)
.finish()
}
}
impl ErrorResponse {
pub const TYPE_URL: &'static str = "type.googleapis.com/grpc.reflection.v1alpha.ErrorResponse";
}
impl ::buffa::DefaultInstance for ErrorResponse {
fn default_instance() -> &'static Self {
static VALUE: ::buffa::__private::OnceBox<ErrorResponse> = ::buffa::__private::OnceBox::new();
VALUE.get_or_init(|| ::buffa::alloc::boxed::Box::new(Self::default()))
}
}
impl ::buffa::MessageName for ErrorResponse {
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";
}
impl ::buffa::Message for ErrorResponse {
#[allow(clippy::let_and_return)]
fn compute_size(&self, _cache: &mut ::buffa::SizeCache) -> u32 {
#[allow(unused_imports)]
use ::buffa::Enumeration as _;
let mut size = 0u32;
if self.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
}
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::encoding::Tag::new(1u32, ::buffa::encoding::WireType::Varint)
.encode(buf);
::buffa::types::encode_int32(self.error_code, buf);
}
if !self.error_message.is_empty() {
::buffa::encoding::Tag::new(
2u32,
::buffa::encoding::WireType::LengthDelimited,
)
.encode(buf);
::buffa::types::encode_string(&self.error_message, buf);
}
self.__buffa_unknown_fields.write_to(buf);
}
fn merge_field(
&mut self,
tag: ::buffa::encoding::Tag,
buf: &mut impl ::buffa::bytes::Buf,
depth: u32,
) -> ::core::result::Result<(), ::buffa::DecodeError> {
#[allow(unused_imports)]
use ::buffa::bytes::Buf as _;
#[allow(unused_imports)]
use ::buffa::Enumeration as _;
match tag.field_number() {
1u32 => {
if tag.wire_type() != ::buffa::encoding::WireType::Varint {
return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
field_number: 1u32,
expected: 0u8,
actual: tag.wire_type() as u8,
});
}
self.error_code = ::buffa::types::decode_int32(buf)?;
}
2u32 => {
if tag.wire_type() != ::buffa::encoding::WireType::LengthDelimited {
return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
field_number: 2u32,
expected: 2u8,
actual: tag.wire_type() as u8,
});
}
::buffa::types::merge_string(&mut self.error_message, buf)?;
}
_ => {
self.__buffa_unknown_fields
.push(::buffa::encoding::decode_unknown_field(tag, buf, depth)?);
}
}
::core::result::Result::Ok(())
}
fn clear(&mut self) {
self.error_code = 0i32;
self.error_message.clear();
self.__buffa_unknown_fields.clear();
}
}
impl ::buffa::ExtensionSet for ErrorResponse {
const PROTO_FQN: &'static str = "grpc.reflection.v1alpha.ErrorResponse";
fn unknown_fields(&self) -> &::buffa::UnknownFields {
&self.__buffa_unknown_fields
}
fn unknown_fields_mut(&mut self) -> &mut ::buffa::UnknownFields {
&mut self.__buffa_unknown_fields
}
}
impl ::buffa::json_helpers::ProtoElemJson for ErrorResponse {
fn serialize_proto_json<S: ::serde::Serializer>(
v: &Self,
s: S,
) -> ::core::result::Result<S::Ok, S::Error> {
::serde::Serialize::serialize(v, s)
}
fn deserialize_proto_json<'de, D: ::serde::Deserializer<'de>>(
d: D,
) -> ::core::result::Result<Self, D::Error> {
<Self as ::serde::Deserialize>::deserialize(d)
}
}
#[doc(hidden)]
pub const __ERROR_RESPONSE_JSON_ANY: ::buffa::type_registry::JsonAnyEntry = ::buffa::type_registry::JsonAnyEntry {
type_url: "type.googleapis.com/grpc.reflection.v1alpha.ErrorResponse",
to_json: ::buffa::type_registry::any_to_json::<ErrorResponse>,
from_json: ::buffa::type_registry::any_from_json::<ErrorResponse>,
is_wkt: false,
};