| /tonic/tonic-reflection/src/server/ |
| H A D | mod.rs | 152 state.files.insert(name, fd.clone()); in new()
180 self.symbols.insert(service_name.clone(), fd.clone()); in process_file()
184 self.symbols.insert(method_name, fd.clone()); in process_file()
198 self.symbols.insert(message_name.clone(), fd.clone()); in process_message()
214 self.symbols.insert(oneof_name, fd.clone()); in process_message()
227 self.symbols.insert(enum_name.clone(), fd.clone()); in process_enum()
231 self.symbols.insert(value_name, fd.clone()); in process_enum()
244 self.symbols.insert(field_name, fd); in process_field()
|
| /tonic/tonic/src/metadata/ |
| H A D | map.rs | 1019 key.insert(self, val) in insert()
1060 key.insert(self, val) in insert_bin()
1467 Vacant(e) => e.insert(default), in or_insert()
1513 Vacant(e) => e.insert(default()), in or_insert_with()
2047 fn insert( in insert() method
2053 .insert(self.inner, val.inner) in insert()
2069 fn insert( in insert() method
2075 .insert(&self.inner, val.inner) in insert()
2090 fn insert( in insert() method
2099 .insert(key.inner, val.inner) in insert()
[all …]
|
| /tonic/tests/integration_tests/tests/ |
| H A D | timeout.rs | 17 .insert("grpc-timeout", "500m".parse().unwrap()); in cancelation_on_timeout()
37 .insert("grpc-timeout", "10H".parse().unwrap()); in picks_server_timeout_if_thats_sorter()
56 .insert("grpc-timeout", "100m".parse().unwrap()); in picks_client_timeout_if_thats_sorter()
|
| H A D | extensions.rs | 36 req.extensions_mut().insert(ExtensionValue(42)); in setting_extension_from_interceptor()
146 req.extensions_mut().insert(ExtensionValue(42)); in call()
|
| /tonic/tonic-web/src/ |
| H A D | call.rs | 440 map.insert(header_key, header_value); in decode_trailers_frame()
527 headers.insert(header::CONTENT_TYPE, case.0.parse().unwrap()); in encoding_constructors()
528 headers.insert(header::ACCEPT, case.0.parse().unwrap()); in encoding_constructors()
538 headers.insert(Status::GRPC_STATUS, 0.into()); in decode_trailers()
539 headers.insert( in decode_trailers()
641 expected.insert(Status::GRPC_STATUS, "0".parse().unwrap()); in decode_multiple_trailers()
642 expected.insert(Status::GRPC_MESSAGE, "".parse().unwrap()); in decode_multiple_trailers()
643 expected.insert("a", "1".parse().unwrap()); in decode_multiple_trailers()
644 expected.insert("b", "2".parse().unwrap()); in decode_multiple_trailers()
658 expected.insert(Status::GRPC_STATUS, "0".parse().unwrap()); in decode_trailers_with_space_after_colon()
[all …]
|
| H A D | service.rs | 214 .insert(header::CONTENT_TYPE, GRPC_CONTENT_TYPE); in coerce_request()
217 .insert(header::TE, HeaderValue::from_static("trailers")); in coerce_request()
219 req.headers_mut().insert( in coerce_request()
236 res.headers_mut().insert( in coerce_response()
360 .insert(CONTENT_TYPE, HeaderValue::from_static(ct)); in grpc_web_content_types()
431 req.headers_mut().insert( in content_type_variants()
|
| H A D | client.rs | 71 .insert(CONTENT_TYPE, GRPC_WEB.try_into().unwrap()); in call()
|
| /tonic/tonic/src/ |
| H A D | response.rs | 126 .insert(crate::codec::compression::SingleMessageCompressionOverride::Disable); in disable_compression()
146 r.metadata_mut().insert( in reserved_headers_are_excluded()
|
| H A D | request.rs | 296 .insert(crate::metadata::GRPC_TIMEOUT_HEADER, value); in set_timeout()
450 r.metadata_mut().insert( in reserved_headers_are_excluded()
|
| H A D | status.rs | 520 header_map.insert(Self::GRPC_STATUS, self.code.to_header_value()); in add_header()
527 header_map.insert( in add_header()
536 header_map.insert( in add_header()
582 .insert(http::header::CONTENT_TYPE, GRPC_CONTENT_TYPE); in into_http()
|
| /tonic/examples/src/authentication/ |
| H A D | client.rs | 15 req.metadata_mut().insert("authorization", token.clone()); in main()
|
| /tonic/tonic/src/transport/server/service/ |
| H A D | io.rs | 65 req.extensions_mut().insert(inner); in call()
69 req.extensions_mut().insert(inner.get_ref().clone()); in call()
70 req.extensions_mut().insert(inner); in call()
|
| /tonic/tonic/src/client/ |
| H A D | grpc.rs | 400 .insert(TE, HeaderValue::from_static("trailers")); in prepare_request()
405 .insert(CONTENT_TYPE, GRPC_CONTENT_TYPE); in prepare_request()
409 request.headers_mut().insert( in prepare_request()
419 request.headers_mut().insert( in prepare_request()
|
| /tonic/examples/src/gcp/ |
| H A D | client.rs | 41 .insert("authorization", header_value.clone()); in main()
|
| /tonic/examples/src/interceptor/ |
| H A D | server.rs | 53 req.extensions_mut().insert(MyExtension { in intercept()
|
| /tonic/tonic-build/src/ |
| H A D | client.rs | 246 req.extensions_mut().insert(GrpcMethod::new(#service_name, #method_name)); in generate_unary()
277 req.extensions_mut().insert(GrpcMethod::new(#service_name, #method_name)); in generate_server_streaming()
308 req.extensions_mut().insert(GrpcMethod::new(#service_name, #method_name)); in generate_client_streaming()
339 req.extensions_mut().insert(GrpcMethod::new(#service_name,#method_name)); in generate_streaming()
|
| /tonic/tonic-health/src/generated/ |
| H A D | grpc_health_v1.rs | 161 .insert(GrpcMethod::new("grpc.health.v1.Health", "Check")); in check()
200 .insert(GrpcMethod::new("grpc.health.v1.Health", "Watch")); in watch()
427 .insert( in call()
432 .insert( in call()
|
| /tonic/tonic/src/transport/channel/service/ |
| H A D | user_agent.rs | 43 .insert(USER_AGENT, self.user_agent.clone()); in call()
|
| /tonic/tonic-types/src/richer_error/std_messages/ |
| H A D | error_info.rs | 113 metadata.insert("instanceLimitPerRequest".into(), "100".into()); in gen_error_info()
|
| /tonic/tonic-reflection/src/generated/ |
| H A D | grpc_reflection_v1.rs | 252 .insert( in server_reflection_info()
429 .insert( in call()
434 .insert( in call()
|
| H A D | grpc_reflection_v1alpha.rs | 252 .insert( in server_reflection_info()
429 .insert( in call()
434 .insert( in call()
|
| /tonic/tonic-health/src/ |
| H A D | server.rs | 88 writer.insert(service_name.to_string(), watch::channel(status)); in set_service_status()
211 statuses.insert( in make_test_service()
|
| /tonic/tonic/src/server/ |
| H A D | grpc.rs | 436 .insert(http::header::CONTENT_TYPE, GRPC_CONTENT_TYPE); in map_response()
441 parts.headers.insert( in map_response()
|
| /tonic/examples/src/h2c/ |
| H A D | server.rs | 118 res.headers_mut().insert( in call()
|
| /tonic/interop/src/ |
| H A D | client.rs | 356 req_unary.metadata_mut().insert(key1, value1.clone()); in custom_metadata()
361 req_stream.metadata_mut().insert(key1, value1.clone()); in custom_metadata()
|