Searched refs:extensions (Results 1 – 17 of 17) sorted by relevance
| /tonic/tonic/src/ |
| H A D | response.rs | 10 extensions: Extensions, field
30 extensions: Extensions::new(), in new()
61 (self.metadata, self.message, self.extensions) in into_parts()
65 pub fn from_parts(metadata: MetadataMap, message: T, extensions: Extensions) -> Self { in from_parts()
69 extensions, in from_parts()
78 extensions: head.extensions, in from_http()
87 *res.extensions_mut() = self.extensions; in into_http()
101 extensions: self.extensions, in map()
106 pub fn extensions(&self) -> &Extensions { in extensions() method
107 &self.extensions in extensions()
[all …]
|
| H A D | request.rs | 21 extensions: Extensions, field
155 extensions, in from_parts()
164 extensions: parts.extensions, in from_http_parts()
205 extensions: self.extensions, in map()
217 .extensions() in local_addr()
223 self.extensions() in local_addr()
239 .extensions() in remote_addr()
245 self.extensions() in remote_addr()
261 self.extensions() in peer_certs()
301 &self.extensions in extensions()
[all …]
|
| H A D | lib.rs | 108 mod extensions; module
121 pub use extensions::GrpcMethod;
|
| H A D | codegen.rs | 13 pub use crate::extensions::GrpcMethod;
|
| /tonic/tonic/src/service/ |
| H A D | interceptor.rs | 139 let (metadata, extensions, msg) = req.into_parts(); in call()
143 .call(crate::Request::from_parts(metadata, extensions, ())) in call()
146 let (metadata, extensions, _) = req.into_parts(); in call()
147 let req = crate::Request::from_parts(metadata, extensions, msg); in call()
|
| /tonic/tests/integration_tests/tests/ |
| H A D | connect_info.rs | 21 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 D | extensions.rs | 28 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 D | interceptor.rs | 46 let gm = req.extensions().get::<GrpcMethod>().unwrap(); in interceptor_retrieves_grpc_method()
|
| /tonic/examples/src/interceptor/ |
| H A D | server.rs | 19 let extension = request.extensions().get::<MyExtension>().unwrap(); in say_hello()
|
| /tonic/examples/src/tls/ |
| H A D | server.rs | 23 .extensions() in unary_echo()
|
| /tonic/examples/src/uds/ |
| H A D | server.rs | 32 let conn_info = request.extensions().get::<UdsConnectInfo>().unwrap(); in say_hello()
|
| /tonic/examples/src/tls_rustls/ |
| H A D | server.rs | 109 let conn_info = request.extensions().get::<Arc<ConnInfo>>().unwrap(); in unary_echo()
|
| /tonic/tonic/src/client/ |
| H A D | grpc.rs | 241 let (mut parts, body, extensions) = in client_streaming()
259 Ok(Response::from_parts(parts, message, extensions)) in client_streaming()
|
| /tonic/tonic-reflection/proto/ |
| H A D | reflection_v1alpha.proto | 47 // Finds the tag numbers used by all known extensions of extendee_type, and
51 // that this method will provide all extensions. Returns
|
| H A D | reflection_v1.proto | 57 // Finds the tag numbers used by all known extensions of the given message
61 // that this method will provide all extensions. Returns
|
| /tonic/tonic/src/server/ |
| H A D | grpc.rs | 492 .extensions() in compression_override_from_response()
|
| /tonic/ |
| H A D | CHANGELOG.md | 330 * **tonic:** fix extensions disappearing during streaming requests ([5c1bb90](https://github.com/hy…
390 * **tonic:** add `Request` and `Response` extensions ([#642](https://github.com/hyperium/tonic/issu…
|