| /tonic/tonic/src/ |
| H A D | status.rs | 40 code: Code,
59 pub enum Code { enum
112 impl Code { impl
557 code: Code, in with_details_and_metadata() argument
666 Code::Internal, in invalid_header_value_byte()
778 impl Code { impl
783 Code::from(i) in from_i32()
842 Code::Unknown in parse_err()
846 impl From<i32> for Code { implementation
872 impl From<Code> for i32 {
[all …]
|
| H A D | lib.rs | 125 pub use status::{Code, ConnectError, Status, TimeoutExpired};
|
| /tonic/tests/default_stubs/src/ |
| H A D | test_defaults.rs | 15 use tonic::Code; in test_default_stubs()
25 Code::PermissionDenied in test_default_stubs()
29 Code::PermissionDenied in test_default_stubs()
37 Code::PermissionDenied in test_default_stubs()
45 Code::PermissionDenied in test_default_stubs()
54 Code::Unimplemented in test_default_stubs()
62 Code::Unimplemented in test_default_stubs()
70 Code::Unimplemented in test_default_stubs()
78 Code::Unimplemented in test_default_stubs()
|
| /tonic/tests/integration_tests/tests/ |
| H A D | timeout.rs | 4 use tonic::{transport::Server, Code, Request, Response, Status};
23 assert_eq!(err.code(), Code::Cancelled); in cancelation_on_timeout()
42 assert_eq!(err.code(), Code::Cancelled); in picks_server_timeout_if_thats_sorter()
61 assert_eq!(err.code(), Code::Cancelled); in picks_client_timeout_if_thats_sorter()
|
| H A D | max_message_size.rs | 11 Code, Request, Response, Status,
46 expected_code: Some(Code::OutOfRange), in max_message_recv_size()
59 expected_code: Some(Code::OutOfRange), in max_message_recv_size()
89 expected_code: Some(Code::Internal), in max_message_send_size()
112 expected_code: Some(Code::OutOfRange), in max_message_send_size()
210 expected_code: Some(Code::OutOfRange), in assert_server_recv_max_failure()
233 expected_code: Some(Code::OutOfRange), in assert_client_recv_max_failure()
270 expected_code: Option<Code>,
|
| H A D | connection.rs | 7 Code, Request, Response, Status,
67 assert_eq!(err.code(), Code::Unavailable); in connect_returns_err_via_call_after_connected()
112 assert_eq!(err.code(), Code::Unavailable); in connect_lazy_reconnects_after_first_failure()
|
| H A D | status.rs | 15 Code, Request, Response, Status,
26 Code::ResourceExhausted, in status_with_details()
87 Err(Status::with_metadata(Code::Internal, MESSAGE, metadata)) in status_with_metadata()
118 assert_eq!(err.code(), Code::Internal); in status_with_metadata()
|
| /tonic/tonic-types/src/richer_error/ |
| H A D | mod.rs | 6 use tonic::{metadata::MetadataMap, Code};
73 code: Code, in with_error_details_and_metadata() argument
95 code: Code, in with_error_details() argument
119 code: Code, in with_error_details_vec_and_metadata() argument
143 code: Code, in with_error_details_vec() argument
485 code: Code, in with_error_details_and_metadata() argument
544 code: Code, in with_error_details_vec_and_metadata() argument
594 code: Code, in with_error_details_vec() argument
976 use tonic::{Code, Status};
1027 Code::InvalidArgument, in gen_status_with_details()
[all …]
|
| /tonic/examples/src/richer-error/ |
| H A D | server.rs | 1 use tonic::{transport::Server, Code, Request, Response, Status};
43 Code::InvalidArgument, in say_hello()
|
| H A D | server_vec.rs | 1 use tonic::{transport::Server, Code, Request, Response, Status};
43 Code::InvalidArgument, in say_hello()
|
| /tonic/interop/src/ |
| H A D | server.rs | 11 use tonic::{body::Body, server::NamedService, Code, Request, Response, Status};
35 let status = Status::new(Code::from_i32(echo_status.code), echo_status.message); in unary_call()
42 let status = Status::new(Code::InvalidArgument, "response_size cannot be negative"); in unary_call()
114 let status = Status::new(Code::from_i32(echo_status.code), echo_status.message); in full_duplex_call()
124 … let status = Status::new(Code::from_i32(echo_status.code), echo_status.message); in full_duplex_call()
|
| H A D | client.rs | 8 use tonic::{metadata::MetadataValue, Code, Request, Response, Status};
238 Err(status) => status.code() == Code::Unknown, in status_code_and_message()
300 Err(status) => status.code() == Code::Unknown, in special_status_message()
321 Err(status) => status.code() == Code::Unimplemented, in unimplemented_method()
336 Err(status) => status.code() == Code::Unimplemented, in unimplemented_service()
|
| /tonic/tonic-health/src/ |
| H A D | server.rs | 193 use tonic::{Code, Request, Status};
200 fn assert_grpc_status(wire: Option<Status>, expected: Code) { in assert_grpc_status() argument
242 assert_grpc_status(resp.err(), Code::NotFound); in test_service_check()
294 assert_grpc_status(resp.err(), Code::NotFound); in test_service_watch()
|
| /tonic/tonic-types/proto/ |
| H A D | status.proto | 36 // The status code, which should be an enum value of [google.rpc.Code][google.rpc.Code].
|
| H A D | error_details.proto | 207 // error is [google.rpc.Code.PERMISSION_DENIED][google.rpc.Code.PERMISSION_DENIED].
|
| /tonic/tests/compression/src/ |
| H A D | compressing_request.rs | 175 assert_eq!(status.code(), tonic::Code::Unimplemented); in client_enabled_server_disabled()
234 assert_eq!(status.code(), tonic::Code::Internal); in client_mark_compressed_without_header_server_enabled()
|
| H A D | client_stream.rs | 159 assert_eq!(status.code(), tonic::Code::Unimplemented); in client_enabled_server_disabled()
|
| /tonic/tonic/src/client/ |
| H A D | grpc.rs | 9 Code, Request, Response, Status,
344 if status.code() != Code::Ok { in create_response()
|
| /tonic/tonic/src/codec/ |
| H A D | decode.rs | 3 use crate::{body::Body, metadata::MetadataMap, Code, Status};
252 if self.direction == Direction::Request && status.code() == Code::Cancelled { in poll_frame()
|
| /tonic/tonic-types/ |
| H A D | README.md | 29 use tonic::{Code, Status};
61 Code::InvalidArgument,
|
| /tonic/tonic/benches-disabled/benchmarks/compiled_protos/ |
| H A D | helloworld.rs | 48 tonic::Code::Unknown, in ready()
|
| /tonic/tests/web/tests/ |
| H A D | grpc.rs | 163 fn status(s: &tonic::Status) -> (String, tonic::Code) { in status() argument
|
| /tonic/tonic-web/src/ |
| H A D | call.rs | 510 use tonic::Code;
629 assert_eq!(out.code(), Code::Internal); in find_trailers_buffered_incomplete_buf_bug()
|
| /tonic/tonic-health/src/generated/ |
| H A D | grpc_health_v1.rs | 429 (tonic::Code::Unimplemented as i32).into(), in call()
|
| /tonic/tonic-reflection/src/generated/ |
| H A D | grpc_reflection_v1.rs | 431 (tonic::Code::Unimplemented as i32).into(), in call()
|