| /tonic/tests/compression/src/ |
| H A D | bidirectional_stream.rs | 13 async fn client_enabled_server_enabled(encoding: CompressionEncoding) { in client_enabled_server_enabled()
17 .accept_compressed(encoding) in client_enabled_server_enabled()
18 .send_compressed(encoding); in client_enabled_server_enabled()
25 encoding: CompressionEncoding, in client_enabled_server_enabled() field
30 pub fn new(encoding: CompressionEncoding) -> Self { in client_enabled_server_enabled()
31 Self { encoding } in client_enabled_server_enabled()
35 let expected = match self.encoding { in client_enabled_server_enabled()
76 .send_compressed(encoding) in client_enabled_server_enabled()
77 .accept_compressed(encoding); in client_enabled_server_enabled()
88 let expected = match encoding { in client_enabled_server_enabled()
[all …]
|
| H A D | client_stream.rs | 13 async fn client_enabled_server_enabled(encoding: CompressionEncoding) { in client_enabled_server_enabled()
22 encoding: CompressionEncoding, in client_enabled_server_enabled() field
27 pub fn new(encoding: CompressionEncoding) -> Self { in client_enabled_server_enabled()
28 Self { encoding } in client_enabled_server_enabled()
32 let expected = match self.encoding { in client_enabled_server_enabled()
36 _ => panic!("unexpected encoding {:?}", self.encoding), in client_enabled_server_enabled()
86 async fn client_disabled_server_enabled(encoding: CompressionEncoding) { in client_disabled_server_enabled()
160 let expected = match encoding { in client_enabled_server_disabled()
164 _ => panic!("unexpected encoding {:?}", encoding), in client_enabled_server_disabled()
217 let expected = match encoding { in compressing_response_from_client_stream()
[all …]
|
| H A D | compressing_request.rs | 13 async fn client_enabled_server_enabled(encoding: CompressionEncoding) { in client_enabled_server_enabled()
16 let svc = test_server::TestServer::new(Svc::default()).accept_compressed(encoding); in client_enabled_server_enabled()
22 encoding: CompressionEncoding, in client_enabled_server_enabled() field
27 pub fn new(encoding: CompressionEncoding) -> Self { in client_enabled_server_enabled()
28 Self { encoding } in client_enabled_server_enabled()
32 let expected = match self.encoding { in client_enabled_server_enabled()
36 _ => panic!("unexpected encoding {:?}", self.encoding), in client_enabled_server_enabled()
90 async fn client_enabled_server_enabled_multi_encoding(encoding: CompressionEncoding) { in client_enabled_server_enabled_multi_encoding()
152 async fn client_enabled_server_disabled(encoding: CompressionEncoding) { in client_enabled_server_disabled()
176 let expected = match encoding { in client_enabled_server_disabled()
[all …]
|
| H A D | compressing_response.rs | 18 encoding: CompressionEncoding, in client_enabled_server_enabled() field
37 let expected = match self.encoding { in client_enabled_server_enabled()
67 encoding, in client_enabled_server_enabled()
87 let expected = match encoding { in client_enabled_server_enabled()
322 .send_compressed(encoding); in disabling_compression_on_single_response()
352 let expected = match encoding { in disabling_compression_on_single_response()
373 encoding: CompressionEncoding, in disabling_compression_on_response_but_keeping_compression_on_stream()
380 .send_compressed(encoding); in disabling_compression_on_response_but_keeping_compression_on_stream()
410 let expected = match encoding { in disabling_compression_on_response_but_keeping_compression_on_stream()
449 .send_compressed(encoding); in disabling_compression_on_response_from_client_stream()
[all …]
|
| H A D | server_stream.rs | 13 async fn client_enabled_server_enabled(encoding: CompressionEncoding) { in client_enabled_server_enabled()
16 let svc = test_server::TestServer::new(Svc::default()).send_compressed(encoding); in client_enabled_server_enabled()
42 test_client::TestClient::new(mock_io_channel(client).await).accept_compressed(encoding); in client_enabled_server_enabled()
46 let expected = match encoding { in client_enabled_server_enabled()
50 _ => panic!("unexpected encoding {:?}", encoding), in client_enabled_server_enabled()
78 async fn client_disabled_server_enabled(encoding: CompressionEncoding) { in client_disabled_server_enabled()
81 let svc = test_server::TestServer::new(Svc::default()).send_compressed(encoding); in client_disabled_server_enabled()
130 async fn client_enabled_server_disabled(encoding: CompressionEncoding) { in client_enabled_server_disabled()
159 test_client::TestClient::new(mock_io_channel(client).await).accept_compressed(encoding); in client_enabled_server_disabled()
|
| H A D | util.rs | 151 encoding: CompressionEncoding, field
156 pub fn new(encoding: CompressionEncoding) -> Self { in new()
157 Self { encoding } in new()
161 let expected = match self.encoding { in call()
165 _ => panic!("unexpected encoding {:?}", self.encoding), in call()
|
| /tonic/tonic/src/metadata/ |
| H A D | mod.rs | 3 mod encoding; module
8 pub use self::encoding::Ascii;
9 pub use self::encoding::Binary;
43 pub use super::encoding::InvalidMetadataValue;
44 pub use super::encoding::InvalidMetadataValueBytes;
|
| H A D | key.rs | 9 use super::encoding::{Ascii, Binary, ValueEncoding};
|
| /tonic/tonic/src/server/ |
| H A D | grpc.rs | 89 self.accept_compression_encodings.enable(encoding); in accept_compressed()
120 self.send_compression_encodings.enable(encoding); in send_compressed()
190 for &encoding in CompressionEncoding::ENCODINGS { in apply_compression_config()
191 if accept_encodings.is_enabled(encoding) { in apply_compression_config()
192 self = self.accept_compressed(encoding); in apply_compression_config()
194 if send_encodings.is_enabled(encoding) { in apply_compression_config()
195 self = self.send_compressed(encoding); in apply_compression_config()
405 let encoding = self.request_encoding_if_supported(&request)?; in map_request_streaming() localVariable
411 encoding, in map_request_streaming()
439 if let Some(encoding) = accept_encoding { in map_response()
[all …]
|
| /tonic/tonic/src/codec/ |
| H A D | decode.rs | 33 encoding: Option<CompressionEncoding>, field
63 encoding: Option<CompressionEncoding>, in new_response()
75 encoding, in new_response()
95 encoding: Option<CompressionEncoding>, in new_request()
107 encoding, in new_request()
116 encoding: Option<CompressionEncoding>, in new()
139 encoding, in new()
160 if self.encoding.is_some() { in decode_chunk()
161 self.encoding in decode_chunk()
213 let decode_buf = if let Some(encoding) = compression { in decode_chunk()
[all …]
|
| H A D | compression.rs | 26 pub fn enable(&mut self, encoding: CompressionEncoding) { in enable()
29 Some(e) if *e == encoding => return, in enable()
31 *e = Some(encoding); in enable()
50 for encoding in self.inner.into_iter().flatten() { in into_accept_encoding_header_value()
51 value.put_slice(encoding.as_str().as_bytes()); in into_accept_encoding_header_value()
64 pub fn is_enabled(&self, encoding: CompressionEncoding) -> bool { in is_enabled()
65 self.inner.contains(&Some(encoding)) in is_enabled()
76 pub(crate) encoding: CompressionEncoding, field
225 match settings.encoding { in compress()
277 match settings.encoding { in decompress()
|
| H A D | encode.rs | 152 if let Some(encoding) = compression_encoding { in encode_item()
163 encoding, in encode_item()
|
| /tonic/tonic-web/src/ |
| H A D | call.rs | 68 encoding: Encoding, field
80 encoding: Encoding::None, in default()
88 pub(crate) fn request(inner: B, encoding: Encoding) -> Self { in request()
89 Self::new(inner, Direction::Decode, encoding) in request()
92 pub(crate) fn response(inner: B, encoding: Encoding) -> Self { in response()
93 Self::new(inner, Direction::Encode, encoding) in response()
116 encoding, in new_client()
131 encoding, in new()
174 match self.encoding { in poll_decode()
227 if *this.encoding == Encoding::Base64 { in poll_encode()
[all …]
|
| H A D | service.rs | 33 encoding: Encoding,
73 encoding, in call()
76 trace!(kind = "simple", path = ?req.uri().path(), ?encoding, ?accept); in call()
80 future: self.inner.call(coerce_request(req, encoding)), in call()
194 encoding: Encoding::from_content_type(headers), in new()
206 fn coerce_request<B>(mut req: Request<B>, encoding: Encoding) -> Request<Body> in coerce_request()
224 req.map(|b| Body::new(GrpcWebCall::request(b, encoding))) in coerce_request()
227 fn coerce_response<B>(res: Response<B>, encoding: Encoding) -> Response<Body> in coerce_response()
233 .map(|b| GrpcWebCall::response(b, encoding)) in coerce_response()
238 HeaderValue::from_static(encoding.to_content_type()), in coerce_response()
|
| /tonic/tonic/src/client/ |
| H A D | grpc.rs | 98 pub fn send_compressed(mut self, encoding: CompressionEncoding) -> Self { in send_compressed()
99 self.config.send_compression_encodings = Some(encoding); in send_compressed()
129 pub fn accept_compressed(mut self, encoding: CompressionEncoding) -> Self { in accept_compressed()
130 self.config.accept_compression_encodings.enable(encoding); in accept_compressed()
333 let encoding = CompressionEncoding::from_encoding_header( in create_response() localVariable
359 encoding, in create_response()
408 if let Some(encoding) = self.send_compression_encodings { in prepare_request()
411 encoding.into_header_value(), in prepare_request()
|
| /tonic/tonic-health/src/generated/ |
| H A D | grpc_health_v1.rs | 112 pub fn send_compressed(mut self, encoding: CompressionEncoding) -> Self { in send_compressed()
113 self.inner = self.inner.send_compressed(encoding); in send_compressed()
118 pub fn accept_compressed(mut self, encoding: CompressionEncoding) -> Self { in accept_compressed()
119 self.inner = self.inner.accept_compressed(encoding); in accept_compressed()
285 pub fn accept_compressed(mut self, encoding: CompressionEncoding) -> Self { in accept_compressed()
286 self.accept_compression_encodings.enable(encoding); in accept_compressed()
291 pub fn send_compressed(mut self, encoding: CompressionEncoding) -> Self { in send_compressed()
292 self.send_compression_encodings.enable(encoding); in send_compressed()
|
| /tonic/tonic-reflection/src/generated/ |
| H A D | grpc_reflection_v1.rs | 201 pub fn send_compressed(mut self, encoding: CompressionEncoding) -> Self { in send_compressed()
202 self.inner = self.inner.send_compressed(encoding); in send_compressed()
207 pub fn accept_compressed(mut self, encoding: CompressionEncoding) -> Self { in accept_compressed()
208 self.inner = self.inner.accept_compressed(encoding); in accept_compressed()
326 pub fn accept_compressed(mut self, encoding: CompressionEncoding) -> Self { in accept_compressed()
327 self.accept_compression_encodings.enable(encoding); in accept_compressed()
332 pub fn send_compressed(mut self, encoding: CompressionEncoding) -> Self { in send_compressed()
333 self.send_compression_encodings.enable(encoding); in send_compressed()
|
| H A D | grpc_reflection_v1alpha.rs | 201 pub fn send_compressed(mut self, encoding: CompressionEncoding) -> Self { in send_compressed()
202 self.inner = self.inner.send_compressed(encoding); in send_compressed()
207 pub fn accept_compressed(mut self, encoding: CompressionEncoding) -> Self { in accept_compressed()
208 self.inner = self.inner.accept_compressed(encoding); in accept_compressed()
326 pub fn accept_compressed(mut self, encoding: CompressionEncoding) -> Self { in accept_compressed()
327 self.accept_compression_encodings.enable(encoding); in accept_compressed()
332 pub fn send_compressed(mut self, encoding: CompressionEncoding) -> Self { in send_compressed()
333 self.send_compression_encodings.enable(encoding); in send_compressed()
|
| /tonic/examples/proto/googleapis/google/pubsub/v1/ |
| H A D | schema.proto | 271 // The encoding expected for messages
272 Encoding encoding = 5;
278 // Possible encoding types for messages.
283 // JSON encoding
286 // Binary encoding, as defined by the schema type. For some schema types,
287 // binary encoding may not be available.
|
| /tonic/tonic-build/src/ |
| H A D | client.rs | 103 pub fn send_compressed(mut self, encoding: CompressionEncoding) -> Self { in generate_internal()
104 self.inner = self.inner.send_compressed(encoding); in generate_internal()
110 pub fn accept_compressed(mut self, encoding: CompressionEncoding) -> Self { in generate_internal()
111 self.inner = self.inner.accept_compressed(encoding); in generate_internal()
|
| H A D | server.rs | 62 pub fn accept_compressed(mut self, encoding: CompressionEncoding) -> Self { in generate_internal()
63 self.accept_compression_encodings.enable(encoding); in generate_internal()
69 pub fn send_compressed(mut self, encoding: CompressionEncoding) -> Self { in generate_internal()
70 self.send_compression_encodings.enable(encoding); in generate_internal()
|
| /tonic/tonic/ |
| H A D | Cargo.toml | 68 percent-encoding = "2.1"
|
| /tonic/ |
| H A D | README.md | 19 implementation and any encoding via a set of generic traits. The HTTP/2 implementation is based on …
|
| H A D | CHANGELOG.md | 53 * **codec:** Make error when not utf8 value in compression encoding ([#1768](https://github.com/hyp…
75 * Make compression encoding configuration more malleable (#1757)
159 * **core:** Default encoding/decoding limits ([#1335](https://github.com/hyperium/tonic/issues/1335…
193 * do not panic while encoding oversized bodies ([#1142](https://github.com/hyperium/tonic/issues/11…
500 * `Status::details` leaking base64 encoding ([#395](https://github.com/hyperium/tonic/issues/395)) …
|
| /tonic/examples/proto/googleapis/google/api/ |
| H A D | http.proto | 143 // protos JSON encoding:
297 // to invalid URLs. As the result, gRPC Transcoding uses a custom encoding
|