| /tonic/tonic/src/server/ |
| H A D | service.rs | 18 fn call(&mut self, request: Request<R>) -> Self::Future; in call()
28 fn call(&mut self, request: Request<M1>) -> Self::Future { in call()
29 Service::call(self, request) in call()
48 fn call(&mut self, request: Request<R>) -> Self::Future; in call()
60 fn call(&mut self, request: Request<M1>) -> Self::Future { in call()
61 Service::call(self, request) in call()
77 fn call(&mut self, request: Request<Streaming<R>>) -> Self::Future; in call()
87 fn call(&mut self, request: Request<Streaming<M1>>) -> Self::Future { in call()
88 Service::call(self, request) in call()
107 fn call(&mut self, request: Request<Streaming<R>>) -> Self::Future; in call()
[all …]
|
| H A D | grpc.rs | 247 .call(request) in unary()
290 let response = service.call(request).await; in server_streaming()
321 .call(request) in client_streaming()
354 let response = service.call(request).await; in streaming()
366 request: http::Request<B>, in map_request_unary()
374 let (parts, body) = request.into_parts(); in map_request_unary()
399 request: http::Request<B>, in map_request_streaming()
407 let request = request.map(|body| { in map_request_streaming() localVariable
416 Ok(Request::from_http(request)) in map_request_streaming()
460 request: &http::Request<B>, in request_encoding_if_supported()
[all …]
|
| /tonic/tonic/src/client/ |
| H A D | grpc.rs | 8 request::SanitizeHeaders,
221 let request = request.map(|m| tokio_stream::once(m)); in unary() localVariable
228 request: Request<S>, in client_streaming()
277 let request = request.map(|m| tokio_stream::once(m)); in server_streaming() localVariable
297 let request = request in streaming() localVariable
308 let request = self.config.prepare_request(request, path); in streaming() localVariable
312 .call(request) in streaming()
390 let mut request = request.into_http( in prepare_request() localVariable
398 request in prepare_request()
403 request in prepare_request()
[all …]
|
| /tonic/examples/src/tracing/ |
| H A D | client.rs | 22 let request = tonic::Request::new(HelloRequest { name }); in say_hi() localVariable
26 request = %request.get_ref().name in say_hi()
29 let response = client.say_hello(request).await?; in say_hi()
|
| /tonic/examples/src/multiplex/ |
| H A D | client.rs | 22 let request = tonic::Request::new(HelloRequest { in main() localVariable
26 let response = greeter_client.say_hello(request).await?; in main()
30 let request = tonic::Request::new(EchoRequest { in main() localVariable
34 let response = echo_client.unary_echo(request).await?; in main()
|
| H A D | server.rs | 44 request: Request<HelloRequest>, in say_hello()
47 message: format!("Hello {}!", request.into_inner().name), in say_hello()
60 request: Request<EchoRequest>, in unary_echo()
62 let message = request.into_inner().message; in unary_echo()
|
| /tonic/tonic/src/service/ |
| H A D | interceptor.rs | 5 use crate::{request::SanitizeHeaders, Status};
51 self(request) in call()
278 request in doesnt_remove_headers_from_requests()
290 request in doesnt_remove_headers_from_requests()
297 Ok(request) in doesnt_remove_headers_from_requests()
300 let request = http::Request::builder() in doesnt_remove_headers_from_requests() localVariable
305 svc.oneshot(request).await.unwrap(); in doesnt_remove_headers_from_requests()
322 let response = svc.oneshot(request).await.unwrap(); in handles_intercepted_status_as_response()
332 assert_eq!(request.method(), http::Method::OPTIONS); in doesnt_change_http_method()
339 let request = http::Request::builder() in doesnt_change_http_method() localVariable
[all …]
|
| /tonic/examples/src/dynamic/ |
| H A D | server.rs | 25 async fn unary_echo(&self, request: Request<EchoRequest>) -> EchoResult<EchoResponse> { in unary_echo()
26 println!("Got an echo request from {:?}", request.remote_addr()); in unary_echo()
28 let message = format!("you said: {}", request.into_inner().message); in unary_echo()
50 request: Request<HelloRequest>, in say_hello()
52 println!("Got a greet request from {:?}", request.remote_addr()); in say_hello()
55 message: format!("Hello {}!", request.into_inner().name), in say_hello()
|
| /tonic/examples/src/mock/ |
| H A D | mock.rs | 50 let request = tonic::Request::new(HelloRequest { in main() localVariable
54 let response = client.say_hello(request).await?; in main()
68 request: Request<HelloRequest>, in say_hello()
70 println!("Got a request: {:?}", request); in say_hello()
73 message: format!("Hello {}!", request.into_inner().name), in say_hello()
|
| /tonic/examples/src/h2c/ |
| H A D | client.rs | 20 let request = tonic::Request::new(HelloRequest { in main() localVariable
24 let response = client.say_hello(request).await?; in main()
59 fn call(&mut self, request: http::Request<Body>) -> Self::Future { in call()
63 let origin = request.uri(); in call()
71 let res = client.request(h2c_req).await.unwrap(); in call()
87 h2_client.send_request(request).await in call()
|
| /tonic/tonic-reflection/tests/ |
| H A D | versions.rs | 61 request: v1::ServerReflectionRequest, in make_v1_request()
92 let request = Request::new(tokio_stream::once(request)); in make_v1_request() localVariable
94 .server_reflection_info(request) in make_v1_request()
118 request: v1alpha::ServerReflectionRequest, in make_v1alpha_request()
149 let request = Request::new(tokio_stream::once(request)); in make_v1alpha_request() localVariable
151 .server_reflection_info(request) in make_v1alpha_request()
|
| /tonic/examples/src/blocking/ |
| H A D | client.rs | 35 request: impl tonic::IntoRequest<HelloRequest>, in say_hello()
37 self.rt.block_on(self.client.say_hello(request)) in say_hello()
44 let request = tonic::Request::new(HelloRequest { in main() localVariable
48 let response = client.say_hello(request)?; in main()
|
| H A D | server.rs | 19 request: Request<HelloRequest>, in say_hello()
21 println!("Got a request: {:?}", request); in say_hello()
24 message: format!("Hello {}!", request.into_inner().name), in say_hello()
|
| /tonic/tonic-build/src/ |
| H A D | server.rs | 268 async fn #name(#self_param, request: tonic::Request<#req_message>) in generate_trait_methods()
277 async fn #name(#self_param, request: tonic::Request<#req_message>) in generate_trait_methods()
300 async fn #name(#self_param, request: tonic::Request<#req_message>) in generate_trait_methods()
463 fn call(&mut self, request: tonic::Request<#request>) -> Self::Future { in generate_unary()
466 <T as #server_trait>::#method_ident(#inner_arg, request).await in generate_unary()
530 fn call(&mut self, request: tonic::Request<#request>) -> Self::Future { in generate_server_streaming()
533 <T as #server_trait>::#method_ident(#inner_arg, request).await in generate_server_streaming()
588 … fn call(&mut self, request: tonic::Request<tonic::Streaming<#request>>) -> Self::Future { in generate_client_streaming()
591 <T as #server_trait>::#method_ident(#inner_arg, request).await in generate_client_streaming()
656 … fn call(&mut self, request: tonic::Request<tonic::Streaming<#request>>) -> Self::Future { in generate_streaming()
[all …]
|
| H A D | client.rs | 230 let (request, response) = method.request_response_name(proto_path, compile_well_known_types); in generate_unary()
238 request: impl tonic::IntoRequest<#request>, in generate_unary()
245 let mut req = request.into_request(); in generate_unary()
261 let (request, response) = method.request_response_name(proto_path, compile_well_known_types); in generate_server_streaming()
269 request: impl tonic::IntoRequest<#request>, in generate_server_streaming()
276 let mut req = request.into_request(); in generate_server_streaming()
292 let (request, response) = method.request_response_name(proto_path, compile_well_known_types); in generate_client_streaming()
300 request: impl tonic::IntoStreamingRequest<Message = #request> in generate_client_streaming()
307 let mut req = request.into_streaming_request(); in generate_client_streaming()
331 request: impl tonic::IntoStreamingRequest<Message = #request> in generate_streaming()
[all …]
|
| /tonic/examples/src/routeguide/ |
| H A D | server.rs | 27 async fn get_feature(&self, request: Request<Point>) -> Result<Response<Feature>, Status> { in get_feature()
28 println!("GetFeature = {:?}", request); in get_feature()
31 if feature.location.as_ref() == Some(request.get_ref()) { in get_feature()
43 request: Request<Rectangle>, in list_features()
45 println!("ListFeatures = {:?}", request); in list_features()
52 if in_range(feature.location.as_ref().unwrap(), request.get_ref()) { in list_features()
66 request: Request<tonic::Streaming<Point>>, in record_route()
70 let mut stream = request.into_inner(); in record_route()
108 request: Request<tonic::Streaming<RouteNote>>, in route_chat()
113 let mut stream = request.into_inner(); in route_chat()
|
| /tonic/examples/src/tls/ |
| H A D | server.rs | 21 async fn unary_echo(&self, request: Request<EchoRequest>) -> EchoResult<EchoResponse> { in unary_echo()
22 let conn_info = request in unary_echo()
28 request.remote_addr(), in unary_echo()
32 let message = request.into_inner().message; in unary_echo()
|
| /tonic/examples/src/uds/ |
| H A D | server.rs | 28 request: Request<HelloRequest>, in say_hello()
32 let conn_info = request.extensions().get::<UdsConnectInfo>().unwrap(); in say_hello()
33 println!("Got a request {:?} with info {:?}", request, conn_info); in say_hello()
37 message: format!("Hello {}!", request.into_inner().name), in say_hello()
|
| /tonic/interop/proto/grpc/testing/ |
| H A D | messages.proto | 52 // Unary request.
62 // Optional input payload sent along with the request.
71 // Whether to request the server to compress the response. This field is
80 // Whether the server should expect this request to be compressed.
84 // Unary response, as configured by the request.
88 // The user the request came from, for verifying authentication was
95 // Client-streaming request.
97 // Optional input payload sent along with the request.
103 // the request's compression status.
131 // Server-streaming request.
[all …]
|
| /tonic/examples/src/codec_buffers/ |
| H A D | server.rs | 27 request: Request<HelloRequest>, in say_hello()
29 println!("Got a request from {:?}", request.remote_addr()); in say_hello()
32 message: format!("Hello {}!", request.into_inner().name), in say_hello()
|
| /tonic/examples/src/helloworld/ |
| H A D | server.rs | 17 request: Request<HelloRequest>, in say_hello()
19 println!("Got a request from {:?}", request.remote_addr()); in say_hello()
22 message: format!("Hello {}!", request.into_inner().name), in say_hello()
|
| /tonic/examples/src/interceptor/ |
| H A D | client.rs | 22 let request = tonic::Request::new(HelloRequest { in main() localVariable
26 let response = client.say_hello(request).await?; in main()
46 fn call(&mut self, request: tonic::Request<()>) -> Result<tonic::Request<()>, Status> { in call()
47 Ok(request) in call()
|
| /tonic/examples/src/json-codec/ |
| H A D | server.rs | 24 request: Request<HelloRequest>, in say_hello()
26 println!("Got a request from {:?}", request.remote_addr()); in say_hello()
29 message: format!("Hello {}!", request.into_inner().name), in say_hello()
|
| /tonic/examples/src/compression/ |
| H A D | server.rs | 18 request: Request<HelloRequest>, in say_hello()
20 println!("Got a request from {:?}", request.remote_addr()); in say_hello()
23 message: format!("Hello {}!", request.into_inner().name), in say_hello()
|
| /tonic/examples/src/reflection/ |
| H A D | server.rs | 18 request: Request<proto::HelloRequest>, in say_hello()
20 println!("Got a request from {:?}", request.remote_addr()); in say_hello()
23 message: format!("Hello {}!", request.into_inner().name), in say_hello()
|