Home
last modified time | relevance | path

Searched refs:get (Results 1 – 25 of 43) sorted by relevance

12

/tonic/tests/compression/src/
H A Dcompressing_response.rs45 .get("grpc-accept-encoding") in client_enabled_server_enabled()
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()
223 assert!(req.headers().get("grpc-accept-encoding").is_none()); in client_disabled()
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()
H A Dserver_stream.rs52 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 Dbidirectional_stream.rs41 assert_eq!(req.headers().get("grpc-encoding").unwrap(), expected); in client_enabled_server_enabled()
94 assert_eq!(res.metadata().get("grpc-encoding").unwrap(), expected); in client_enabled_server_enabled()
H A Dcompressing_request.rs38 assert_eq!(req.headers().get("grpc-encoding").unwrap(), expected); in client_enabled_server_enabled()
102 let req_encoding = req.headers().get("grpc-encoding").unwrap(); in client_enabled_server_enabled_multi_encoding()
191 status.metadata().get("grpc-accept-encoding").unwrap(), in client_enabled_server_disabled()
H A Dclient_stream.rs38 assert_eq!(req.headers().get("grpc-encoding").unwrap(), expected); in client_enabled_server_enabled()
94 assert!(req.headers().get("grpc-encoding").is_none()); in client_disabled_server_enabled()
223 assert_eq!(res.metadata().get("grpc-encoding").unwrap(), expected); in compressing_response_from_client_stream()
/tonic/tonic/src/
H A Drequest.rs218 .get::<TcpConnectInfo>() in local_addr()
224 .get::<TlsConnectInfo<TcpConnectInfo>>() in local_addr()
240 .get::<TcpConnectInfo>() in remote_addr()
246 .get::<TlsConnectInfo<TcpConnectInfo>>() in remote_addr()
262 .get::<TlsConnectInfo<TcpConnectInfo>>() in peer_certs()
/tonic/tonic/src/metadata/
H A Dmap.rs472 key.get(self) in get()
508 key.get(self) in get_bin()
1660 pub fn get(&self) -> &MetadataValue<VE> { in get() method
2157 .get(self.inner) in get()
2200 .get(&self.inner) in get()
2246 .get(self) in get()
2308 .get(self.as_str()) in get()
2369 .get(self.as_str()) in get()
2509 assert_eq!(map.get("x-host").unwrap(), "example.com"); in test_from_headers_takes_http_headers()
2527 .get("grpc-message") in test_to_headers_encoding()
[all …]
/tonic/tests/integration_tests/tests/
H A Dconnect_info.rs21 assert!(req.extensions().get::<TcpConnectInfo>().is_some()); in getting_connect_info()
83 let conn_info = req.extensions().get::<UdsConnectInfo>().unwrap(); in unary_call()
H A Dextensions.rs28 let value = req.extensions().get::<ExtensionValue>().unwrap(); in setting_extension_from_interceptor()
78 let value = req.extensions().get::<ExtensionValue>().unwrap(); in setting_extension_from_tower()
H A Duser_agent.rs16 match req.metadata().get("user-agent") { in writes_user_agent_header()
H A Dinterceptor.rs46 let gm = req.extensions().get::<GrpcMethod>().unwrap(); in interceptor_retrieves_grpc_method()
H A Dclient_layer.rs19 match req.metadata().get("x-test") { in connect_supports_standard_tower_layers()
/tonic/examples/src/authentication/
H A Dserver.rs36 match req.metadata().get("authorization") { in check_auth()
/tonic/tonic-web/
H A DREADME.md8 The easiest way to get started, is to call the function with your tonic service
/tonic/examples/src/interceptor/
H A Dserver.rs19 let extension = request.extensions().get::<MyExtension>().unwrap(); in say_hello()
/tonic/interop/src/
H A Dclient.rs371 response.metadata().get(key1) == Some(&value1), in custom_metadata()
372 format!("result={:?}", response.metadata().get(key1)) in custom_metadata()
387 response.metadata().get(key1) == Some(&value1), in custom_metadata()
388 format!("result={:?}", response.metadata().get(key1)) in custom_metadata()
H A Dserver.rs197 let echo_header = req.headers().get("x-grpc-test-echo-initial").cloned(); in call()
202 .get(&trailer_name) in call()
/tonic/examples/src/tls/
H A Dserver.rs24 .get::<TlsConnectInfo<TcpConnectInfo>>() in unary_echo()
/tonic/examples/src/uds/
H A Dserver.rs32 let conn_info = request.extensions().get::<UdsConnectInfo>().unwrap(); in say_hello()
/tonic/tests/web/tests/
H A Dgrpc_web.rs29 let content_type = res.headers().get(header::CONTENT_TYPE).unwrap().clone(); in binary_request()
52 let content_type = res.headers().get(header::CONTENT_TYPE).unwrap().clone(); in text_request()
/tonic/.github/ISSUE_TEMPLATE/
H A Dbug_report.md17 List the versions of all `tonic` crates you are using. The easiest way to get
/tonic/tonic-health/src/
H A Dserver.rs79 match writer.get(service_name) { in set_service_status()
113 reader.get(service_name).map(|p| *p.1.borrow()) in service_health()
138 let status_rx = match self.statuses.read().await.get(service_name) { in watch()
/tonic/tonic-web/src/
H A Dcall.rs34 headers.get(CONTENT_TYPE).and_then(|val| val.to_str().ok()) in content_type()
353 Self::from_header(headers.get(header::CONTENT_TYPE)) in from_content_type()
357 Self::from_header(headers.get(header::ACCEPT)) in from_accept()
406 if b == &b'\r' && buf.get(i + 1) == Some(&b'\n') { in decode_trailers_frame()
583 let status = trailers.get(Status::GRPC_STATUS).unwrap(); in find_trailers_buffered()
/tonic/examples/proto/googleapis/google/api/
H A Dhttp.proto72 // get: "/v1/{name=messages/*}"
96 // get:"/v1/messages/{message_id}"
188 // get: "/v1/messages/{message_id}"
190 // get: "/v1/users/{user_id}/messages/{message_id}"
284 // get: /v1/messages/{message_id}/{sub.subfield}
320 // used with any of the {get|put|post|delete|patch} methods. A custom method
325 string get = 2; field
/tonic/tonic-reflection/src/server/
H A Dmod.rs253 match self.symbols.get(symbol) { in symbol_by_name()
267 match self.files.get(filename) { in file_by_filename()

12