| /tonic/tonic/src/metadata/ |
| H A D | encoding.rs | 35 fn decode(value: &[u8]) -> Result<Bytes, InvalidMetadataValueBytes>; in decode() method
97 fn decode(value: &[u8]) -> Result<Bytes, InvalidMetadataValueBytes> { in decode() method
141 if crate::util::base64::STANDARD.decode(value).is_err() { in from_static()
151 fn decode(value: &[u8]) -> Result<Bytes, InvalidMetadataValueBytes> { in decode() method
153 .decode(value) in decode()
159 if let Ok(decoded) = crate::util::base64::STANDARD.decode(a.as_bytes()) { in equals()
167 match (Self::decode(a.as_bytes()), Self::decode(b.as_bytes())) { in values_equal()
175 if let Ok(decoded) = Self::decode(value.as_bytes()) { in fmt()
|
| /tonic/tonic/src/codec/ |
| H A D | mod.rs | 8 mod decode; module
18 pub use self::decode::Streaming;
153 fn decode(&mut self, src: &mut DecodeBuf<'_>) -> Result<Option<Self::Item>, Self::Error>; in decode() method
|
| H A D | prost.rs | 131 fn decode(&mut self, buf: &mut DecodeBuf<'_>) -> Result<Option<Self::Item>, Self::Error> { in decode() method
132 let item = Message::decode(buf) in decode()
167 async fn decode() { in decode() function
338 fn decode(&mut self, buf: &mut DecodeBuf<'_>) -> Result<Option<Self::Item>, Self::Error> { in decode() method
|
| H A D | decode.rs | 374 Some(mut decode_buf) => match self.decoder.decode(&mut decode_buf)? { in decode_chunk()
|
| /tonic/tonic-reflection/src/ |
| H A D | lib.rs | 37 prost_types::FileDescriptorSet::decode(FILE_DESCRIPTOR_SET_V1ALPHA).unwrap(); in v1alpha_file_descriptor_set_is_valid()
42 prost_types::FileDescriptorSet::decode(FILE_DESCRIPTOR_SET_V1).unwrap(); in v1_file_descriptor_set_is_valid()
|
| /tonic/tonic-types/src/richer_error/ |
| H A D | mod.rs | 607 let status = pb::Status::decode(self.details())?; in check_error_details()
617 let status = pb::Status::decode(self.details())?; in check_error_details_vec()
627 let status = pb::Status::decode(self.details()).ok()?; in get_details_retry_info()
633 let status = pb::Status::decode(self.details()).ok()?; in get_details_debug_info()
639 let status = pb::Status::decode(self.details()).ok()?; in get_details_quota_failure()
645 let status = pb::Status::decode(self.details()).ok()?; in get_details_error_info()
651 let status = pb::Status::decode(self.details()).ok()?; in get_details_precondition_failure()
657 let status = pb::Status::decode(self.details()).ok()?; in get_details_bad_request()
663 let status = pb::Status::decode(self.details()).ok()?; in get_details_request_info()
669 let status = pb::Status::decode(self.details()).ok()?; in get_details_resource_info()
[all …]
|
| /tonic/tonic-types/src/ |
| H A D | lib.rs | 165 prost_types::FileDescriptorSet::decode(FILE_DESCRIPTOR_SET).unwrap(); in file_descriptor_set_is_valid()
|
| /tonic/tonic-health/src/ |
| H A D | lib.rs | 35 prost_types::FileDescriptorSet::decode(FILE_DESCRIPTOR_SET).unwrap(); in file_descriptor_set_is_valid()
|
| /tonic/tests/web/tests/ |
| H A D | grpc_web.rs | 143 .decode(body) in decode_body()
150 let msg = Output::decode(&mut body.split_to(len as usize)).expect("decode"); in decode_body()
|
| /tonic/tonic-types/src/richer_error/std_messages/ |
| H A D | request_info.rs | 64 let req_info = pb::RequestInfo::decode(buf)?; in from_any_ref()
|
| H A D | loc_message.rs | 65 let loc_message = pb::LocalizedMessage::decode(buf)?; in from_any_ref()
|
| H A D | debug_info.rs | 61 let debug_info = pb::DebugInfo::decode(buf)?; in from_any_ref()
|
| H A D | resource_info.rs | 77 let res_info = pb::ResourceInfo::decode(buf)?; in from_any_ref()
|
| H A D | error_info.rs | 77 let error_info = pb::ErrorInfo::decode(buf)?; in from_any_ref()
|
| H A D | retry_info.rs | 76 let retry_info = pb::RetryInfo::decode(buf)?; in from_any_ref()
|
| H A D | help.rs | 119 let help = pb::Help::decode(buf)?; in from_any_ref()
|
| H A D | bad_request.rs | 123 let bad_req = pb::BadRequest::decode(buf)?; in from_any_ref()
|
| H A D | quota_failure.rs | 120 let quota_failure = pb::QuotaFailure::decode(buf)?; in from_any_ref()
|
| H A D | prec_failure.rs | 143 let precondition_failure = pb::PreconditionFailure::decode(buf)?; in from_any_ref()
|
| /tonic/examples/src/json-codec/ |
| H A D | common.rs | 42 fn decode(&mut self, buf: &mut DecodeBuf<'_>) -> Result<Option<Self::Item>, Self::Error> { in decode() method
|
| /tonic/tonic-reflection/tests/ |
| H A D | server.rs | 19 prost_types::FileDescriptorSet::decode(FILE_DESCRIPTOR_SET) in get_encoded_reflection_service_fd()
|
| /tonic/tonic/benches/ |
| H A D | decode.rs | 106 fn decode(&mut self, buf: &mut DecodeBuf<'_>) -> Result<Option<Self::Item>, Self::Error> { in decode() method
|
| /tonic/tonic/ |
| H A D | Cargo.toml | 145 name = "decode"
|
| /tonic/tonic-reflection/src/server/ |
| H A D | mod.rs | 129 file_descriptor_sets.push(FileDescriptorSet::decode(encoded)?); in new()
|
| /tonic/tonic-web/src/ |
| H A D | call.rs | 155 .decode(self.as_mut().project().buf.split_to(index)) in decode_chunk()
|