Home
last modified time | relevance | path

Searched refs:svc (Results 1 – 25 of 34) sorted by relevance

12

/tonic/tonic/src/transport/channel/
H A Dmod.rs160 let svc = Connection::lazy(connector, endpoint); in new() localVariable
161 let (svc, worker) = Buffer::pair(svc, buffer_size); in new()
165 Channel { svc } in new()
181 let svc = Connection::connect(connector, endpoint) in connect() localVariable
184 let (svc, worker) = Buffer::pair(svc, buffer_size); in connect()
187 Ok(Channel { svc }) in connect()
197 let svc = Balance::new(discover); in balance() localVariable
199 let svc = BoxService::new(svc); in balance() localVariable
200 let (svc, worker) = Buffer::pair(svc, buffer_size); in balance()
203 Channel { svc } in balance()
[all …]
/tonic/tonic-web/src/
H A Dservice.rs302 let mut svc = enable(Svc); in default_cors_config() localVariable
318 let mut svc = enable(Svc); in without_origin() localVariable
323 let res = svc.call(req).await.unwrap(); in without_origin()
330 let mut svc = enable(Svc); in only_post_and_options_allowed() localVariable
355 let mut svc = enable(Svc); in grpc_web_content_types() localVariable
384 let mut svc = enable(Svc); in valid_grpc_web_preflight() localVariable
404 let mut svc = enable(Svc); in h2_is_ok() localVariable
414 let mut svc = enable(Svc); in h1_is_err() localVariable
427 let mut svc = enable(Svc); in content_type_variants() localVariable
455 let mut svc = enable(Svc); in h1_is_err() localVariable
[all …]
/tonic/examples/src/tls_rustls/
H A Dserver.rs45 let svc = Routes::new(pb::echo_server::EchoServer::new(server)).prepare(); in main() localVariable
63 let svc = svc.clone(); in main() localVariable
79 let svc = tower::ServiceBuilder::new() in main() localVariable
81 .service(svc); in main()
86 svc.map_request(|req: http::Request<_>| req.map(Body::new)), in main()
/tonic/tonic/src/service/
H A Dinterceptor.rs276 let svc = tower::service_fn(|request: http::Request<()>| async move { in doesnt_remove_headers_from_requests() localVariable
288 let svc = InterceptedService::new(svc, |request: crate::Request<()>| { in doesnt_remove_headers_from_requests() localVariable
305 svc.oneshot(request).await.unwrap(); in doesnt_remove_headers_from_requests()
313 let svc = tower::service_fn(|_: http::Request<()>| async { in handles_intercepted_status_as_response() localVariable
317 let svc = InterceptedService::new(svc, |_: crate::Request<()>| { in handles_intercepted_status_as_response() localVariable
322 let response = svc.oneshot(request).await.unwrap(); in handles_intercepted_status_as_response()
331 let svc = tower::service_fn(|request: http::Request<()>| async move { in doesnt_change_http_method() localVariable
337 let svc = InterceptedService::new(svc, Ok); in doesnt_change_http_method() localVariable
344 svc.oneshot(request).await.unwrap(); in doesnt_change_http_method()
H A Drouter.rs26 pub fn add_service<S>(&mut self, svc: S) -> &mut Self in add_service()
38 self.routes.replace(routes.add_service(svc)); in add_service()
58 pub fn new<S>(svc: S) -> Self in new()
69 Self::default().add_service(svc) in new()
78 pub fn add_service<S>(mut self, svc: S) -> Self in add_service()
91 svc.map_request(|req: Request<axum::body::Body>| req.map(Body::new)), in add_service()
/tonic/tests/integration_tests/tests/
H A Dmax_message_size.rs147 let svc = test1_server::Test1Server::new(Svc); in response_stream_limit() localVariable
151 .add_service(svc) in response_stream_limit()
301 let svc = test1_server::Test1Server::new(Svc(server_blob)); in max_message_run() localVariable
303 let svc = if let Some(size) = case.server_recv_max { in max_message_run() localVariable
304 svc.max_decoding_message_size(size) in max_message_run()
306 svc in max_message_run()
309 let svc = if let Some(size) = case.server_send_max { in max_message_run() localVariable
310 svc.max_encoding_message_size(size) in max_message_run()
312 svc in max_message_run()
317 .add_service(svc) in max_message_run()
H A Dhttp2_keep_alive.rs20 let svc = test_server::TestServer::new(Svc {}); in http2_keepalive_does_not_cause_panics() localVariable
30 .add_service(svc) in http2_keepalive_does_not_cause_panics()
50 let svc = test_server::TestServer::new(Svc {}); in http2_keepalive_does_not_cause_panics_on_client_side() localVariable
60 .add_service(svc) in http2_keepalive_does_not_cause_panics_on_client_side()
H A Dstatus.rs33 let svc = test_server::TestServer::new(Svc); in status_with_details() localVariable
43 .add_service(svc) in status_with_details()
91 let svc = test_server::TestServer::new(Svc); in status_with_metadata() localVariable
101 .add_service(svc) in status_with_metadata()
164 let svc = test_stream_server::TestStreamServer::new(Svc); in status_from_server_stream() localVariable
172 .add_service(svc) in status_from_server_stream()
234 let svc = test_stream_server::TestStreamServer::new(Svc); in message_and_then_status_from_server_stream() localVariable
242 .add_service(svc) in message_and_then_status_from_server_stream()
H A Dconnection.rs41 let svc = test_server::TestServer::new(Svc(sender)); in connect_returns_err_via_call_after_connected() localVariable
49 .add_service(svc) in connect_returns_err_via_call_after_connected()
76 let svc = test_server::TestServer::new(Svc(sender)); in connect_lazy_reconnects_after_first_failure() localVariable
93 .add_service(svc) in connect_lazy_reconnects_after_first_failure()
H A Dextensions.rs35 let svc = test_server::TestServer::with_interceptor(Svc, |mut req: Request<()>| { in setting_extension_from_interceptor() localVariable
48 .add_service(svc) in setting_extension_from_interceptor()
85 let svc = InterceptedService { in setting_extension_from_tower() localVariable
97 .add_service(svc) in setting_extension_from_tower()
H A Dstreams.rs27 let svc = test_stream_server::TestStreamServer::new(Svc); in status_from_server_stream_with_source() localVariable
33 .add_service(svc) in status_from_server_stream_with_source()
H A Duser_agent.rs23 let svc = test_server::TestServer::new(Svc); in writes_user_agent_header() localVariable
33 .add_service(svc) in writes_user_agent_header()
H A Dinterceptor.rs22 let svc = test_server::TestServer::new(Svc); in interceptor_retrieves_grpc_method() localVariable
33 .add_service(svc) in interceptor_retrieves_grpc_method()
H A Dhttp2_max_header_list_size.rs30 let svc = test_server::TestServer::new(Svc); in test_http_max_header_list_size_and_long_errors() localVariable
43 .add_service(svc) in test_http_max_header_list_size_and_long_errors()
H A Dclient_layer.rs27 let svc = test_server::TestServer::new(Svc); in connect_supports_standard_tower_layers() localVariable
36 .add_service(svc) in connect_supports_standard_tower_layers()
/tonic/tests/compression/src/
H A Dcompressing_response.rs77 .add_service(svc) in client_enabled_server_enabled()
132 .add_service(svc) in client_enabled_server_disabled()
173 .add_service(svc) in client_enabled_server_disabled_multi_encoding()
247 .add_service(svc) in client_disabled()
291 .add_service(svc) in server_replying_with_unsupported_encoding()
319 let svc = test_server::TestServer::new(Svc { in disabling_compression_on_single_response() localVariable
340 .add_service(svc) in disabling_compression_on_single_response()
377 let svc = test_server::TestServer::new(Svc { in disabling_compression_on_response_but_keeping_compression_on_stream() localVariable
398 .add_service(svc) in disabling_compression_on_response_but_keeping_compression_on_stream()
446 let svc = test_server::TestServer::new(Svc { in disabling_compression_on_response_from_client_stream() localVariable
[all …]
H A Dcompressing_request.rs16 let svc = test_server::TestServer::new(Svc::default()).accept_compressed(encoding); in client_enabled_server_enabled() localVariable
60 .add_service(svc) in client_enabled_server_enabled()
93 let svc = test_server::TestServer::new(Svc::default()) in client_enabled_server_enabled_multi_encoding() localVariable
122 .add_service(svc) in client_enabled_server_enabled_multi_encoding()
155 let svc = test_server::TestServer::new(Svc::default()); in client_enabled_server_disabled() localVariable
159 .add_service(svc) in client_enabled_server_disabled()
206 let svc = test_server::TestServer::new(Svc::default()).accept_compressed(encoding); in client_mark_compressed_without_header_server_enabled() localVariable
211 .add_service(svc) in client_mark_compressed_without_header_server_enabled()
H A Dserver_stream.rs16 let svc = test_server::TestServer::new(Svc::default()).send_compressed(encoding); in client_enabled_server_enabled() localVariable
34 .add_service(svc) in client_enabled_server_enabled()
81 let svc = test_server::TestServer::new(Svc::default()).send_compressed(encoding); in client_disabled_server_enabled() localVariable
99 .add_service(svc) in client_disabled_server_enabled()
133 let svc = test_server::TestServer::new(Svc::default()); in client_enabled_server_disabled() localVariable
151 .add_service(svc) in client_enabled_server_disabled()
H A Dclient_stream.rs16 let svc = test_server::TestServer::new(Svc::default()).accept_compressed(encoding); in client_enabled_server_enabled() localVariable
58 .add_service(svc) in client_enabled_server_enabled()
89 let svc = test_server::TestServer::new(Svc::default()).accept_compressed(encoding); in client_disabled_server_enabled() localVariable
110 .add_service(svc) in client_disabled_server_enabled()
140 let svc = test_server::TestServer::new(Svc::default()); in client_enabled_server_disabled() localVariable
144 .add_service(svc) in client_enabled_server_disabled()
186 let svc = test_server::TestServer::new(Svc::default()).send_compressed(encoding); in compressing_response_from_client_stream() localVariable
204 .add_service(svc) in compressing_response_from_client_stream()
/tonic/examples/src/dynamic/
H A Dserver.rs38 let svc = EchoServer::new(MyEcho::default()); in init_echo() localVariable
39 builder.add_service(svc); in init_echo()
66 let svc = GreeterServer::new(MyGreeter::default()); in init_greeter() localVariable
67 builder.add_service(svc); in init_greeter()
/tonic/tonic/src/transport/server/
H A Dmod.rs564 svc: S, in serve_with_shutdown()
585 svc: S, in serve_with_incoming()
607 svc: S, in serve_with_incoming_shutdown()
629 svc: S, in serve_internal()
664 let svc = self.service_builder.service(svc); in serve_internal() localVariable
671 let mut svc = MakeSvc { in serve_internal() localVariable
672 inner: svc, in serve_internal()
866 if let Some(svc) = svc { in add_optional_service()
1094 .service(svc); in call()
1100 inner: svc, in call()
[all …]
/tonic/examples/src/grpc-web/
H A Dclient.rs14 let svc = tower::ServiceBuilder::new() in main() localVariable
18 let mut client = GreeterClient::with_origin(svc, "http://127.0.0.1:3000".try_into()?); in main()
/tonic/examples/src/h2c/
H A Dserver.rs42 let svc = Routes::new(GreeterServer::new(greeter)).prepare(); in main() localVariable
44 let h2c = h2c::H2c { s: svc }; in main()
102 let svc = self in call() localVariable
111 .serve_connection(upgraded_io, TowerToHyperService::new(svc)) in call()
/tonic/examples/src/authentication/
H A Dserver.rs26 let svc = pb::echo_server::EchoServer::with_interceptor(server, check_auth); in main() localVariable
28 Server::builder().add_service(svc).serve(addr).await?; in main()
/tonic/examples/src/interceptor/
H A Dserver.rs37 let svc = GreeterServer::with_interceptor(greeter, intercept); in main() localVariable
41 Server::builder().add_service(svc).serve(addr).await?; in main()

12