| /tonic/tonic/src/codec/ |
| H A D | compression.rs | 19 inner: [Option<CompressionEncoding>; 3], 85 pub enum CompressionEncoding { enum 97 impl CompressionEncoding { impl 100 CompressionEncoding::Gzip, 102 CompressionEncoding::Deflate, 104 CompressionEncoding::Zstd, 227 CompressionEncoding::Gzip => { in compress() 236 CompressionEncoding::Deflate => { in compress() 245 CompressionEncoding::Zstd => { in compress() 279 CompressionEncoding::Gzip => { in decompress() [all …]
|
| H A D | encode.rs | 2 compress, CompressionEncoding, CompressionSettings, SingleMessageCompressionOverride, 27 compression_encoding: Option<CompressionEncoding>, 38 compression_encoding: Option<CompressionEncoding>, in new() argument 137 compression_encoding: Option<CompressionEncoding>, in encode_item() argument 182 compression_encoding: Option<CompressionEncoding>, in finish_encoding() argument 237 compression_encoding: Option<CompressionEncoding>, in new_client() argument 261 compression_encoding: Option<CompressionEncoding>, in new_server() argument
|
| H A D | decode.rs | 1 use super::compression::{decompress, CompressionEncoding, CompressionSettings}; 33 encoding: Option<CompressionEncoding>, 43 compression: Option<CompressionEncoding>, 63 encoding: Option<CompressionEncoding>, in new_response() argument 95 encoding: Option<CompressionEncoding>, in new_request() argument 116 encoding: Option<CompressionEncoding>, in new() argument
|
| H A D | mod.rs | 17 pub use self::compression::{CompressionEncoding, EnabledCompressionEncodings};
|
| /tonic/tests/compression/src/ |
| H A D | compressing_request.rs | 3 use tonic::codec::CompressionEncoding; 7 zstd: CompressionEncoding::Zstd, 8 gzip: CompressionEncoding::Gzip, 9 deflate: CompressionEncoding::Deflate, 22 encoding: CompressionEncoding, in client_enabled_server_enabled() 84 zstd: CompressionEncoding::Zstd, 85 gzip: CompressionEncoding::Gzip, 146 zstd: CompressionEncoding::Zstd, 147 gzip: CompressionEncoding::Gzip, 197 zstd: CompressionEncoding::Zstd, [all …]
|
| H A D | client_stream.rs | 3 use tonic::codec::CompressionEncoding; 7 zstd: CompressionEncoding::Zstd, 8 gzip: CompressionEncoding::Gzip, 9 deflate: CompressionEncoding::Deflate, 22 encoding: CompressionEncoding, in client_enabled_server_enabled() 80 zstd: CompressionEncoding::Zstd, 81 gzip: CompressionEncoding::Gzip, 131 zstd: CompressionEncoding::Zstd, 132 gzip: CompressionEncoding::Gzip, 177 zstd: CompressionEncoding::Zstd, [all …]
|
| H A D | compressing_response.rs | 2 use tonic::codec::CompressionEncoding; 6 zstd: CompressionEncoding::Zstd, 7 gzip: CompressionEncoding::Gzip, 8 deflate: CompressionEncoding::Deflate, 18 encoding: CompressionEncoding, in client_enabled_server_enabled() 104 zstd: CompressionEncoding::Zstd, 105 gzip: CompressionEncoding::Gzip, 195 zstd: CompressionEncoding::Zstd, 196 gzip: CompressionEncoding::Gzip, 266 zstd: CompressionEncoding::Zstd, [all …]
|
| H A D | bidirectional_stream.rs | 3 use tonic::codec::CompressionEncoding; 7 zstd: CompressionEncoding::Zstd, 8 gzip: CompressionEncoding::Gzip, 9 deflate: CompressionEncoding::Deflate, 25 encoding: CompressionEncoding, in client_enabled_server_enabled() 30 pub fn new(encoding: CompressionEncoding) -> Self { in client_enabled_server_enabled() 36 CompressionEncoding::Gzip => "gzip", in client_enabled_server_enabled() 37 CompressionEncoding::Zstd => "zstd", in client_enabled_server_enabled() 89 CompressionEncoding::Gzip => "gzip", in client_enabled_server_enabled() 90 CompressionEncoding::Zstd => "zstd", in client_enabled_server_enabled() [all …]
|
| H A D | server_stream.rs | 2 use tonic::codec::CompressionEncoding; 7 zstd: CompressionEncoding::Zstd, 8 gzip: CompressionEncoding::Gzip, 9 deflate: CompressionEncoding::Deflate, 47 CompressionEncoding::Gzip => "gzip", in client_enabled_server_enabled() 48 CompressionEncoding::Zstd => "zstd", in client_enabled_server_enabled() 73 zstd: CompressionEncoding::Zstd, 74 gzip: CompressionEncoding::Gzip, 124 zstd: CompressionEncoding::Zstd, 125 gzip: CompressionEncoding::Gzip, [all …]
|
| H A D | util.rs | 17 use tonic::codec::CompressionEncoding; 151 encoding: CompressionEncoding, 156 pub fn new(encoding: CompressionEncoding) -> Self { in new() 162 CompressionEncoding::Gzip => "gzip", in call() 163 CompressionEncoding::Zstd => "zstd", in call() 164 CompressionEncoding::Deflate => "deflate", in call()
|
| /tonic/examples/src/compression/ |
| H A D | client.rs | 3 use tonic::codec::CompressionEncoding; 18 .send_compressed(CompressionEncoding::Gzip) in main() 19 .accept_compressed(CompressionEncoding::Gzip); in main()
|
| H A D | server.rs | 5 use tonic::codec::CompressionEncoding; 37 .send_compressed(CompressionEncoding::Gzip) in main() 38 .accept_compressed(CompressionEncoding::Gzip); in main()
|
| /tonic/tonic/src/server/ |
| H A D | grpc.rs | 2 CompressionEncoding, EnabledCompressionEncodings, SingleMessageCompressionOverride, 88 pub fn accept_compressed(mut self, encoding: CompressionEncoding) -> Self { in accept_compressed() 119 pub fn send_compressed(mut self, encoding: CompressionEncoding) -> Self { in send_compressed() 190 for &encoding in CompressionEncoding::ENCODINGS { in apply_compression_config() 229 let accept_encoding = CompressionEncoding::from_accept_encoding_header( in unary() 273 let accept_encoding = CompressionEncoding::from_accept_encoding_header( in server_streaming() 313 let accept_encoding = CompressionEncoding::from_accept_encoding_header( in client_streaming() 347 let accept_encoding = CompressionEncoding::from_accept_encoding_header( in streaming() 422 accept_encoding: Option<CompressionEncoding>, in map_response() argument 461 ) -> Result<Option<CompressionEncoding>, Status> { in request_encoding_if_supported() argument [all …]
|
| /tonic/tonic/src/client/ |
| H A D | grpc.rs | 1 use crate::codec::compression::{CompressionEncoding, EnabledCompressionEncodings}; 42 send_compression_encodings: Option<CompressionEncoding>, 98 pub fn send_compressed(mut self, encoding: CompressionEncoding) -> Self { in send_compressed() 129 pub fn accept_compressed(mut self, encoding: CompressionEncoding) -> Self { in accept_compressed() 333 let encoding = CompressionEncoding::from_encoding_header( in create_response()
|
| /tonic/tonic/src/ |
| H A D | codegen.rs | 12 pub use crate::codec::{CompressionEncoding, EnabledCompressionEncodings};
|
| /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() 118 pub fn accept_compressed(mut self, encoding: CompressionEncoding) -> Self { in accept_compressed() 285 pub fn accept_compressed(mut self, encoding: CompressionEncoding) -> Self { in accept_compressed() 291 pub fn send_compressed(mut self, encoding: CompressionEncoding) -> Self { 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() 207 pub fn accept_compressed(mut self, encoding: CompressionEncoding) -> Self { in accept_compressed() 326 pub fn accept_compressed(mut self, encoding: CompressionEncoding) -> Self { in accept_compressed() 332 pub fn send_compressed(mut self, encoding: CompressionEncoding) -> Self { in send_compressed()
|
| H A D | grpc_reflection_v1alpha.rs | 201 pub fn send_compressed(mut self, encoding: CompressionEncoding) -> Self { in send_compressed() 207 pub fn accept_compressed(mut self, encoding: CompressionEncoding) -> Self { in accept_compressed() 326 pub fn accept_compressed(mut self, encoding: CompressionEncoding) -> Self { in accept_compressed() 332 pub fn send_compressed(mut self, encoding: CompressionEncoding) -> Self { in send_compressed()
|
| /tonic/tonic-build/src/ |
| H A D | client.rs | 103 pub fn send_compressed(mut self, encoding: CompressionEncoding) -> Self { in generate_internal() 110 pub fn accept_compressed(mut self, encoding: CompressionEncoding) -> Self { in generate_internal()
|
| H A D | server.rs | 62 pub fn accept_compressed(mut self, encoding: CompressionEncoding) -> Self { in generate_internal() 69 pub fn send_compressed(mut self, encoding: CompressionEncoding) -> Self { in generate_internal()
|