Home
last modified time | relevance | path

Searched refs:http (Results 1 – 25 of 91) sorted by relevance

1234

/tonic/tonic/src/client/
H A Dservice.rs19 type Future: Future<Output = Result<http::Response<Self::ResponseBody>, Self::Error>>;
29 fn call(&mut self, request: http::Request<ReqBody>) -> Self::Future; in call()
34 T: Service<http::Request<ReqBody>, Response = http::Response<ResBody>>,
47 fn call(&mut self, request: http::Request<ReqBody>) -> Self::Future { in call()
/tonic/tests/compression/
H A DCargo.toml9 http = "1"
10 http-body = "1"
11 http-body-util = "0.1"
21 tower-http = {version = "0.6", features = ["map-response-body", "map-request-body"]}
/tonic/tonic/src/service/
H A Dinterceptor.rs117 S: Service<http::Request<ReqBody>, Response = http::Response<ResBody>>,
120 type Response = http::Response<ResponseBody<ResBody>>;
195 F: Future<Output = Result<http::Response<B>, E>>,
197 type Output = Result<http::Response<ResponseBody<B>>, E>;
285 Ok::<_, Status>(http::Response::new(())) in doesnt_remove_headers_from_requests()
300 let request = http::Request::builder() in doesnt_remove_headers_from_requests()
314 Ok::<_, Status>(http::Response::new(())) in handles_intercepted_status_as_response()
321 let request = http::Request::builder().body(()).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()
[all …]
/tonic/tonic/src/transport/channel/service/
H A Dadd_origin.rs2 use http::uri::Authority;
3 use http::uri::Scheme;
4 use http::{Request, Uri};
17 let http::uri::Parts { in new() localVariable
55 let mut uri: http::uri::Parts = head.uri.into(); in call()
60 http::Uri::from_parts(uri).expect("valid uri") in call()
/tonic/tonic/src/
H A Drequest.rs6 use http::Extensions;
169 pub fn from_http(http: http::Request<T>) -> Self { in from_http()
170 let (parts, message) = http.into_parts(); in from_http()
176 uri: http::Uri, in into_http()
177 method: http::Method, in into_http()
178 version: http::Version, in into_http()
180 ) -> http::Request<T> { in into_http()
181 let mut request = http::Request::new(self.message); in into_http()
443 use http::Uri;
458 http::Method::POST, in reserved_headers_are_excluded()
[all …]
H A Dresponse.rs1 use http::Extensions;
73 pub(crate) fn from_http(res: http::Response<T>) -> Self { in from_http()
82 pub(crate) fn into_http(self) -> http::Response<T> { in into_http()
83 let mut res = http::Response::new(self.message); in into_http()
85 *res.version_mut() = http::Version::HTTP_2; in into_http()
/tonic/examples/src/h2c/
H A Dclient.rs3 use http::Uri;
49 impl Service<http::Request<Body>> for H2cChannel {
50 type Response = http::Response<Incoming>;
59 fn call(&mut self, request: http::Request<Body>) -> Self::Future { in call()
67 .header(http::header::UPGRADE, "h2c") in call()
73 if res.status() != http::StatusCode::SWITCHING_PROTOCOLS { in call()
/tonic/tonic/src/server/
H A Dgrpc.rs222 req: http::Request<B>, in unary()
223 ) -> http::Response<Body> in unary()
265 req: http::Request<B>, in server_streaming()
266 ) -> http::Response<Body> in server_streaming()
306 req: http::Request<B>, in client_streaming()
307 ) -> http::Response<Body> in client_streaming()
339 req: http::Request<B>, in streaming()
340 ) -> http::Response<Body> in streaming()
366 request: http::Request<B>, in map_request_unary()
399 request: http::Request<B>, in map_request_streaming()
[all …]
/tonic/tonic-web/
H A DCargo.toml22 http = "1"
23 http-body = "1"
32 tower-http = { version = "0.6", features = ["cors"] }
43 "http::*",
/tonic/interop/
H A DCargo.toml20 http = "1"
21 http-body = "1"
22 http-body-util = "0.1"
/tonic/tests/integration_tests/
H A DCargo.toml18 http = "1"
19 http-body = "1"
24 tower-http = { version = "0.6", features = ["set-header", "trace"] }
/tonic/examples/src/tls_rustls/
H A Dserver.rs47 let http = Builder::new(TokioExecutor::new()); in main() localVariable
61 let http = http.clone(); in main() localVariable
83 http.serve_connection( in main()
86 svc.map_request(|req: http::Request<_>| req.map(Body::new)), in main()
H A Dclient.rs31 let mut http = HttpConnector::new(); in main() localVariable
32 http.enforce_http(false); in main()
51 .service(http); in main()
/tonic/tonic/src/metadata/
H A Dmap.rs1 use http::HeaderName;
59 inner: http::header::Iter<'a, http::header::HeaderValue>,
88 inner: http::header::IterMut<'a, http::header::HeaderValue>,
94 inner: http::header::ValueDrain<'a, http::header::HeaderValue>,
104 inner: http::header::Keys<'a, http::header::HeaderValue>,
125 inner: http::header::Iter<'a, http::header::HeaderValue>,
145 inner: http::header::IterMut<'a, http::header::HeaderValue>,
168 inner: http::header::ValueIterMut<'a, http::header::HeaderValue>,
178 inner: Option<http::header::GetAll<'a, http::header::HeaderValue>>,
198 inner: http::header::VacantEntry<'a, http::header::HeaderValue>,
[all …]
/tonic/tests/integration_tests/tests/
H A Dcomplex_tower_middleware.rs58 S: Service<R, Response = http::Response<ResBody>>,
60 type Response = http::Response<MyBody<ResBody>>;
80 F: Future<Output = Result<http::Response<B>, E>>,
82 type Output = Result<http::Response<MyBody<B>>, BoxError>;
/tonic/tests/web/
H A DCargo.toml10 http-body = "1"
11 http-body-util = "0.1"
/tonic/examples/proto/googleapis/google/api/
H A Dannotations.proto7 // http://www.apache.org/licenses/LICENSE-2.0
19 import "google/api/http.proto";
30 HttpRule http = 72295728; field
/tonic/tonic-health/src/generated/
H A Dgrpc_health_v1.rs68 use tonic::codegen::http::Uri;
96 http::Request<tonic::body::Body>, in with_interceptor()
97 Response = http::Response< in with_interceptor()
102 http::Request<tonic::body::Body>, in with_interceptor()
156 let path = http::uri::PathAndQuery::from_static( in check()
195 let path = http::uri::PathAndQuery::from_static( in watch()
312 impl<T, B> tonic::codegen::Service<http::Request<B>> for HealthServer<T>
318 type Response = http::Response<tonic::body::Body>;
327 fn call(&mut self, req: http::Request<B>) -> Self::Future { in call()
422 let mut response = http::Response::new( in call()
[all …]
/tonic/tonic/src/transport/channel/
H A Dendpoint.rs9 use http::{uri::Uri, HeaderValue};
54 if me.uri.scheme() == Some(&http::uri::Scheme::HTTPS) { in new()
340 let mut http = HttpConnector::new(); in http_connector() localVariable
341 http.enforce_http(false); in http_connector()
342 http.set_nodelay(self.tcp_nodelay); in http_connector()
343 http.set_keepalive(self.tcp_keepalive); in http_connector()
344 http.set_connect_timeout(self.connect_timeout); in http_connector()
345 http.set_local_address(self.local_address); in http_connector()
346 self.connector(http) in http_connector()
/tonic/examples/src/tower/
H A Dserver.rs83 impl<S, ReqBody, ResBody> Service<http::Request<ReqBody>> for MyMiddleware<S>
85 S: Service<http::Request<ReqBody>, Response = http::Response<ResBody>> + Clone + Send + 'static,
97 fn call(&mut self, req: http::Request<ReqBody>) -> Self::Future { in call()
/tonic/tonic-reflection/src/generated/
H A Dgrpc_reflection_v1.rs157 use tonic::codegen::http::Uri;
185 http::Request<tonic::body::Body>, in with_interceptor()
186 Response = http::Response< in with_interceptor()
191 http::Request<tonic::body::Body>, in with_interceptor()
247 let path = http::uri::PathAndQuery::from_static( in server_reflection_info()
353 impl<T, B> tonic::codegen::Service<http::Request<B>> for ServerReflectionServer<T>
359 type Response = http::Response<tonic::body::Body>;
368 fn call(&mut self, req: http::Request<B>) -> Self::Future { in call()
424 let mut response = http::Response::new( in call()
435 http::header::CONTENT_TYPE, in call()
H A Dgrpc_reflection_v1alpha.rs157 use tonic::codegen::http::Uri;
185 http::Request<tonic::body::Body>, in with_interceptor()
186 Response = http::Response< in with_interceptor()
191 http::Request<tonic::body::Body>, in with_interceptor()
247 let path = http::uri::PathAndQuery::from_static( in server_reflection_info()
353 impl<T, B> tonic::codegen::Service<http::Request<B>> for ServerReflectionServer<T>
359 type Response = http::Response<tonic::body::Body>;
368 fn call(&mut self, req: http::Request<B>) -> Self::Future { in call()
424 let mut response = http::Response::new( in call()
435 http::header::CONTENT_TYPE, in call()
/tonic/examples/
H A DCargo.toml256 …eb", "dep:bytes", "dep:http", "dep:hyper", "dep:hyper-util", "dep:tracing-subscriber", "dep:tower"…
261 tower = ["dep:tower", "dep:http"]
265 tls-rustls = ["dep:http", "dep:hyper", "dep:hyper-util", "dep:hyper-rustls", "dep:tower", "tower-ht…
268 h2c = ["dep:hyper", "dep:tower", "dep:http", "dep:hyper-util"]
294 http = { version = "1", optional = true }
295 http-body = { version = "1", optional = true }
303 tower-http = { version = "0.6", optional = true }
/tonic/tonic/src/codec/
H A Dcompression.rs48 pub(crate) fn into_accept_encoding_header_value(self) -> Option<http::HeaderValue> { in into_accept_encoding_header_value()
60 Some(http::HeaderValue::from_maybe_shared(value).unwrap()) in into_accept_encoding_header_value()
109 map: &http::HeaderMap, in from_accept_encoding_header()
132 map: &http::HeaderMap, in from_encoding_header()
194 pub(crate) fn into_header_value(self) -> http::HeaderValue { in into_header_value()
195 http::HeaderValue::from_static(self.as_str()) in into_header_value()
315 use http::HeaderValue;
/tonic/tonic/benches-disabled/benchmarks/compiled_protos/
H A Dhelloworld.rs60 let path = http::uri::PathAndQuery::from_static("/helloworld.Greeter/SayHello"); in say_hello()
123 impl<T: Greeter> Service<http::Request<HyperBody>> for GreeterServerSvc<T> {
124 type Response = http::Response<tonic::body::BoxBody>;
130 fn call(&mut self, req: http::Request<HyperBody>) -> Self::Future { in call()
158 Ok(http::Response::builder() in call()

1234