| /tonic/tonic-types/src/generated/ |
| H A D | google_rpc.rs | 22 pub details: ::prost::alloc::vec::Vec<::prost_types::Any>,
48 pub stack_entries: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
68 pub violations: ::prost::alloc::vec::Vec<quota_failure::Violation>,
159 pub violations: ::prost::alloc::vec::Vec<precondition_failure::Violation>,
190 pub field_violations: ::prost::alloc::vec::Vec<bad_request::FieldViolation>,
253 pub links: ::prost::alloc::vec::Vec<help::Link>,
|
| /tonic/examples/src/richer-error/ |
| H A D | server_vec.rs | 26 let mut bad_request = BadRequest::new(vec![]); in say_hello()
45 vec![bad_request.into(), help.into(), localized_message.into()], in say_hello()
|
| /tonic/tests/integration_tests/tests/ |
| H A D | max_message_size.rs | 119 let client_blob = vec![0; 1]; in response_stream_limit()
139 buf: vec![0; 6877902], in response_stream_limit()
141 let stream = tokio_stream::iter(vec![Ok(blob.clone()), Ok(blob.clone())]); in response_stream_limit()
275 let client_blob = vec![0; case.client_blob_size]; in max_message_run()
276 let server_blob = vec![0; case.server_blob_size]; in max_message_run()
|
| H A D | status.rs | 156 let s = tokio_stream::iter(vec![ in status_from_server_stream()
226 let s = tokio_stream::iter(vec![ in message_and_then_status_from_server_stream()
|
| /tonic/tonic/src/codec/ |
| H A D | prost.rs | 170 let msg = vec![0u8; LEN]; in decode()
196 let msg = vec![0u8; MAX_MESSAGE_SIZE + 1]; in decode_max_message_size_exceeded()
248 let msg = vec![0u8; MAX_MESSAGE_SIZE + 1]; in encode_max_message_size_exceeded()
285 let msg = vec![0u8; u32::MAX as usize + 1]; in encode_too_big()
|
| H A D | buffer.rs | 115 payload.put(&vec![0u8; 50][..]); in decode_buf()
|
| /tonic/tonic-types/src/richer_error/std_messages/ |
| H A D | help.rs | 71 links: vec![HelpLink { in with_link()
84 self.links.append(&mut vec![HelpLink { in add_link()
|
| H A D | bad_request.rs | 75 field_violations: vec![FieldViolation { in with_violation()
88 self.field_violations.append(&mut vec![FieldViolation { in add_violation()
|
| H A D | quota_failure.rs | 72 violations: vec![QuotaViolation { in with_violation()
85 self.violations.append(&mut vec![QuotaViolation { in add_violation()
|
| H A D | prec_failure.rs | 91 violations: vec![PreconditionViolation { in with_violation()
107 self.violations.append(&mut vec![PreconditionViolation { in add_violation()
|
| H A D | debug_info.rs | 93 vec!["trace 3".into(), "trace 2".into(), "trace 1".into()], in gen_debug_info()
|
| /tonic/tonic-reflection/src/server/ |
| H A D | v1alpha.rs | 46 file_descriptor_proto: vec![fd], in server_reflection_info()
52 file_descriptor_proto: vec![fd], in server_reflection_info()
|
| H A D | v1.rs | 46 file_descriptor_proto: vec![fd], in server_reflection_info()
52 file_descriptor_proto: vec![fd], in server_reflection_info()
|
| /tonic/tonic-reflection/tests/ |
| H A D | versions.rs | 27 vec![v1::ServiceResponse { in test_v1()
51 vec![v1alpha::ServiceResponse { in test_v1alpha()
|
| H A D | server.rs | 38 vec![ServiceResponse { in test_list_services()
|
| /tonic/tests/compression/src/ |
| H A D | client_stream.rs | 69 let stream = tokio_stream::iter(vec![SomeData { data: data.clone() }, SomeData { data }]); in client_enabled_server_enabled()
120 let stream = tokio_stream::iter(vec![SomeData { data: data.clone() }, SomeData { data }]); in client_disabled_server_enabled()
154 let stream = tokio_stream::iter(vec![SomeData { data: data.clone() }, SomeData { data }]); in client_enabled_server_disabled()
|
| H A D | bidirectional_stream.rs | 80 let stream = tokio_stream::iter(vec![SomeData { data: data.clone() }, SomeData { data }]); in client_enabled_server_enabled()
|
| /tonic/examples/ |
| H A D | README.md | 172 $ cargo run --bin richer-error-client-vec
184 $ cargo run --bin richer-error-server-vec
|
| /tonic/tonic-reflection/src/generated/ |
| H A D | grpc_reflection_v1.rs | 108 pub file_descriptor_proto: ::prost::alloc::vec::Vec<::prost::alloc::vec::Vec<u8>>,
119 pub extension_number: ::prost::alloc::vec::Vec<i32>,
127 pub service: ::prost::alloc::vec::Vec<ServiceResponse>,
|
| H A D | grpc_reflection_v1alpha.rs | 108 pub file_descriptor_proto: ::prost::alloc::vec::Vec<::prost::alloc::vec::Vec<u8>>,
119 pub extension_number: ::prost::alloc::vec::Vec<i32>,
127 pub service: ::prost::alloc::vec::Vec<ServiceResponse>,
|
| /tonic/tests/web/src/ |
| H A D | lib.rs | 39 Ok(Response::new(Box::pin(stream::iter(vec![1, 2]).map( in server_stream()
|
| /tonic/tonic-types/src/richer_error/ |
| H A D | mod.rs | 13 pub use error_details::{vec::ErrorDetail, ErrorDetails};
993 vec!["trace3".into(), "trace2".into(), "trace1".into()], in gen_status_with_details()
1007 let err_details_vec = vec![ in gen_status_with_details()
1010 vec!["trace3".into(), "trace2".into(), "trace1".into()], in gen_status_with_details()
|
| /tonic/examples/src/routeguide/ |
| H A D | client.rs | 45 let mut points = vec![]; in run_record_route()
|
| /tonic/examples/src/tls_rustls/ |
| H A D | server.rs | 41 tls.alpn_protocols = vec![b"h2".to_vec()]; in main()
|
| /tonic/tonic/benches/ |
| H A D | decode.rs | 117 let msg = vec![97u8; message_length]; in make_payload()
|