| /tonic/tonic/src/ |
| H A D | response.rs | 3 use crate::metadata::MetadataMap;
8 metadata: MetadataMap, field
28 metadata: MetadataMap::new(), in new()
45 pub fn metadata(&self) -> &MetadataMap { in metadata() method
46 &self.metadata in metadata()
51 &mut self.metadata in metadata_mut()
61 (self.metadata, self.message, self.extensions) in into_parts()
67 metadata, in from_parts()
76 metadata: MetadataMap::from_headers(head.headers), in from_http()
99 metadata: self.metadata, in map()
[all …]
|
| H A D | request.rs | 1 use crate::metadata::{MetadataMap, MetadataValue};
19 metadata: MetadataMap, field
115 metadata: MetadataMap::new(), in new()
132 pub fn metadata(&self) -> &MetadataMap { in metadata() method
133 &self.metadata in metadata()
138 &mut self.metadata in metadata_mut()
148 (self.metadata, self.extensions, self.message) in into_parts()
154 metadata, in from_parts()
162 metadata: MetadataMap::from_headers(parts.headers), in from_http_parts()
203 metadata: self.metadata, in map()
[all …]
|
| H A D | status.rs | 1 use crate::metadata::MetadataMap;
2 use crate::metadata::GRPC_CONTENT_TYPE;
48 metadata: MetadataMap, field
167 metadata: MetadataMap::new(), in new()
502 &self.metadata in metadata()
507 &mut self.metadata in metadata_mut()
560 metadata: MetadataMap, in with_details_and_metadata()
566 metadata, in with_details_and_metadata()
604 metadata: status.metadata.clone(), in find_status_in_source_chain()
653 if !self.metadata.is_empty() { in fmt()
[all …]
|
| H A D | lib.rs | 101 pub mod metadata; module
|
| /tonic/tonic-types/src/richer_error/std_messages/ |
| H A D | error_info.rs | 29 pub metadata: HashMap<String, String>, field
40 metadata: impl Into<HashMap<String, String>>, in new()
45 metadata: metadata.into(), in new()
52 self.reason.is_empty() && self.domain.is_empty() && self.metadata.is_empty() in is_empty()
88 metadata: error_info.metadata, in from()
98 metadata: error_info.metadata, in from()
112 let mut metadata = HashMap::new(); in gen_error_info() localVariable
113 metadata.insert("instanceLimitPerRequest".into(), "100".into()); in gen_error_info()
115 let error_info = ErrorInfo::new("SOME_INFO", "mydomain.com", metadata); in gen_error_info()
|
| /tonic/tests/integration_tests/tests/ |
| H A D | status.rs | 12 use tonic::metadata::{MetadataMap, MetadataValue};
83 let mut metadata = MetadataMap::new(); in status_with_metadata() localVariable
84 metadata.insert(ASCII_NAME, ASCII_VALUE.parse().unwrap()); in status_with_metadata()
85 metadata.insert_bin(BINARY_NAME, MetadataValue::from_bytes(BINARY_VALUE)); in status_with_metadata()
87 Err(Status::with_metadata(Code::Internal, MESSAGE, metadata)) in status_with_metadata()
121 let metadata = err.metadata(); in status_with_metadata() localVariable
124 metadata.get(ASCII_NAME).unwrap().to_str().unwrap(), in status_with_metadata()
129 metadata.get_bin(BINARY_NAME).unwrap().to_bytes().unwrap(), in status_with_metadata()
|
| H A D | user_agent.rs | 16 match req.metadata().get("user-agent") { in writes_user_agent_header()
|
| H A D | client_layer.rs | 19 match req.metadata().get("x-test") { in connect_supports_standard_tower_layers()
|
| /tonic/examples/src/authentication/ |
| H A D | server.rs | 6 use tonic::{metadata::MetadataValue, transport::Server, Request, Response, Status};
36 match req.metadata().get("authorization") { in check_auth()
|
| H A D | client.rs | 6 use tonic::{metadata::MetadataValue, transport::Channel, Request};
|
| /tonic/tonic-build/ |
| H A D | Cargo.toml | 35 [package.metadata.docs.rs]
38 [package.metadata.cargo_check_external_types]
|
| /tonic/tonic-types/src/richer_error/ |
| H A D | mod.rs | 6 use tonic::{metadata::MetadataMap, Code};
76 metadata: MetadataMap, in with_error_details_and_metadata()
122 metadata: MetadataMap, in with_error_details_vec_and_metadata()
488 metadata: MetadataMap, in with_error_details_and_metadata()
536 tonic::Status::with_details_and_metadata(code, message, details, metadata) in with_error_details_and_metadata()
547 metadata: MetadataMap, in with_error_details_vec_and_metadata()
590 tonic::Status::with_details_and_metadata(code, message, details, metadata) in with_error_details_vec_and_metadata()
985 let mut metadata = HashMap::new(); in gen_status_with_details() localVariable
986 metadata.insert("limitPerRequest".into(), "100".into()); in gen_status_with_details()
997 .set_error_info("SOME_INFO", "example.local", metadata.clone()) in gen_status_with_details()
[all …]
|
| /tonic/interop/src/ |
| H A D | client.rs | 8 use tonic::{metadata::MetadataValue, Code, Request, Response, Status};
371 response.metadata().get(key1) == Some(&value1), in custom_metadata()
372 format!("result={:?}", response.metadata().get(key1)) in custom_metadata()
376 response.metadata().get_bin(key2) == Some(&value2), in custom_metadata()
377 format!("result={:?}", response.metadata().get_bin(key1)) in custom_metadata()
387 response.metadata().get(key1) == Some(&value1), in custom_metadata()
388 format!("result={:?}", response.metadata().get(key1)) in custom_metadata()
|
| /tonic/tonic-reflection/ |
| H A D | Cargo.toml | 21 [package.metadata.docs.rs]
43 [package.metadata.cargo_check_external_types]
|
| /tonic/tests/use_arc_self/ |
| H A D | Cargo.toml | 15 [package.metadata.cargo-machete]
|
| /tonic/tests/compression/src/ |
| H A D | server_stream.rs | 52 assert_eq!(res.metadata().get("grpc-encoding").unwrap(), expected); in client_enabled_server_enabled()
110 assert!(res.metadata().get("grpc-encoding").is_none()); in client_disabled_server_enabled()
163 assert!(res.metadata().get("grpc-encoding").is_none()); in client_enabled_server_disabled()
|
| H A D | compressing_response.rs | 96 assert_eq!(res.metadata().get("grpc-encoding").unwrap(), expected); in client_enabled_server_enabled()
144 assert!(res.metadata().get("grpc-encoding").is_none()); in client_enabled_server_disabled()
187 assert!(res.metadata().get("grpc-encoding").is_none()); in client_enabled_server_disabled_multi_encoding()
258 assert!(res.metadata().get("grpc-encoding").is_none()); in client_disabled()
358 assert_eq!(res.metadata().get("grpc-encoding").unwrap(), expected); in disabling_compression_on_single_response()
416 assert_eq!(res.metadata().get("grpc-encoding").unwrap(), expected); in disabling_compression_on_response_but_keeping_compression_on_stream()
487 assert_eq!(res.metadata().get("grpc-encoding").unwrap(), expected); in disabling_compression_on_response_from_client_stream()
|
| /tonic/tests/default_stubs/ |
| H A D | Cargo.toml | 16 [package.metadata.cargo-machete]
|
| /tonic/tonic/src/service/ |
| H A D | interceptor.rs | 139 let (metadata, extensions, msg) = req.into_parts(); in call()
143 .call(crate::Request::from_parts(metadata, extensions, ())) in call()
146 let (metadata, extensions, _) = req.into_parts(); in call()
147 let req = crate::Request::from_parts(metadata, extensions, msg); in call()
291 .metadata() in doesnt_remove_headers_from_requests()
|
| /tonic/tonic-types/src/richer_error/error_details/ |
| H A D | mod.rs | 160 metadata: impl Into<HashMap<String, String>>, in with_error_info()
163 error_info: Some(ErrorInfo::new(reason, domain, metadata)), in with_error_info()
567 metadata: impl Into<HashMap<String, String>>, in set_error_info()
569 self.error_info = Some(ErrorInfo::new(reason, domain, metadata)); in set_error_info()
|
| /tonic/tonic-types/ |
| H A D | Cargo.toml | 29 [package.metadata.cargo_check_external_types]
|
| /tonic/examples/src/gcp/ |
| H A D | client.rs | 7 metadata::MetadataValue,
|
| /tonic/tonic-web/ |
| H A D | Cargo.toml | 37 [package.metadata.cargo_check_external_types]
|
| /tonic/tonic-health/ |
| H A D | Cargo.toml | 31 [package.metadata.cargo_check_external_types]
|
| /tonic/tests/web/tests/ |
| H A D | grpc.rs | 152 format!("{:?}", r.metadata()) in meta()
164 (format!("{:?}", s.metadata()), s.code()) in status()
|