Home
last modified time | relevance | path

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

/tonic/tonic/src/client/
H A Dgrpc.rs2 use crate::codec::EncodeBody;
7 codec::{Codec, Decoder, Streaming},
211 codec: C, in unary()
222 self.client_streaming(request, path, codec).await in unary()
230 codec: C, in client_streaming()
267 codec: C, in server_streaming()
278 self.streaming(request, path, codec).await in server_streaming()
286 mut codec: C, in streaming()
300 codec.encoder(), in streaming()
316 let decoder = codec.decoder(); in streaming()
[all …]
/tonic/tonic/src/server/
H A Dgrpc.rs1 use crate::codec::compression::{
4 use crate::codec::EncodeBody;
8 codec::{Codec, Streaming},
35 codec: T, field
51 pub fn new(codec: T) -> Self { in new()
53 codec, in new()
377 self.codec.decoder(), in map_request_unary()
409 self.codec.decoder(), in map_request_streaming()
442 crate::codec::compression::ENCODING_HEADER, in map_response()
448 self.codec.encoder(), in map_response()
[all …]
/tonic/tonic-health/src/generated/
H A Dgrpc_health_v1.rs155 let codec = tonic::codec::ProstCodec::default(); in check() localVariable
162 self.inner.unary(req, path, codec).await in check()
183 tonic::Response<tonic::codec::Streaming<super::HealthCheckResponse>>, in watch()
194 let codec = tonic::codec::ProstCodec::default(); in watch() localVariable
201 self.inner.server_streaming(req, path, codec).await in watch()
359 let codec = tonic::codec::ProstCodec::default(); in call() localVariable
360 let mut grpc = tonic::server::Grpc::new(codec) in call()
405 let codec = tonic::codec::ProstCodec::default(); in call() localVariable
406 let mut grpc = tonic::server::Grpc::new(codec) in call()
/tonic/tonic-build/src/
H A Dclient.rs243 let codec = #codec_name::default(); in generate_unary() localVariable
247 self.inner.unary(req, path, codec).await in generate_unary()
270 … ) -> std::result::Result<tonic::Response<tonic::codec::Streaming<#response>>, tonic::Status> { in generate_server_streaming()
274 let codec = #codec_name::default(); in generate_server_streaming() localVariable
278 self.inner.server_streaming(req, path, codec).await in generate_server_streaming()
305 let codec = #codec_name::default(); in generate_client_streaming() localVariable
309 self.inner.client_streaming(req, path, codec).await in generate_client_streaming()
332 … ) -> std::result::Result<tonic::Response<tonic::codec::Streaming<#response>>, tonic::Status> { in generate_streaming()
336 let codec = #codec_name::default(); in generate_streaming() localVariable
340 self.inner.streaming(req, path, codec).await in generate_streaming()
H A Dserver.rs479 let codec = #codec_name::default(); in generate_unary() localVariable
481 let mut grpc = tonic::server::Grpc::new(codec) in generate_unary()
546 let codec = #codec_name::default(); in generate_server_streaming() localVariable
548 let mut grpc = tonic::server::Grpc::new(codec) in generate_server_streaming()
604 let codec = #codec_name::default(); in generate_client_streaming() localVariable
606 let mut grpc = tonic::server::Grpc::new(codec) in generate_client_streaming()
672 let codec = #codec_name::default(); in generate_streaming() localVariable
674 let mut grpc = tonic::server::Grpc::new(codec) in generate_streaming()
/tonic/tonic/benches-disabled/benchmarks/compiled_protos/
H A Dhelloworld.rs59 let codec = tonic::codec::ProstCodec::default(); in say_hello() localVariable
61 self.inner.unary(request, path, codec).await in say_hello()
150 let codec = tonic::codec::ProstCodec::default(); in call() localVariable
151 let mut grpc = tonic::server::Grpc::new(codec); in call()
/tonic/tonic/src/
H A Dlib.rs100 pub mod codec; module
120 pub use codec::Streaming;
H A Dcodegen.rs12 pub use crate::codec::{CompressionEncoding, EnabledCompressionEncodings};
H A Dresponse.rs126 .insert(crate::codec::compression::SingleMessageCompressionOverride::Disable); in disable_compression()
/tonic/examples/
H A DCargo.toml189 name = "json-codec-client"
190 path = "src/json-codec/client.rs"
191 required-features = ["json-codec"]
194 name = "json-codec-server"
195 path = "src/json-codec/server.rs"
196 required-features = ["json-codec"]
242 name = "codec-buffers-server"
246 name = "codec-buffers-client"
262 json-codec = ["dep:serde", "dep:serde_json", "dep:bytes"]
271 …ealth", "grpc-web", "tracing", "uds", "streaming", "mock", "tower", "json-codec", "compression", "…
/tonic/tonic/src/codec/
H A Dprost.rs2 use crate::codec::EncodeBuf;
152 use crate::codec::compression::SingleMessageCompressionOverride;
153 use crate::codec::{
281 use crate::codec::EncodeBody; in encode_too_big()
326 fn buffer_settings(&self) -> crate::codec::BufferSettings { in buffer_settings()
344 fn buffer_settings(&self) -> crate::codec::BufferSettings { in buffer_settings()
/tonic/tonic-reflection/src/generated/
H A Dgrpc_reflection_v1.rs235 tonic::Response<tonic::codec::Streaming<super::ServerReflectionResponse>>, in server_reflection_info()
246 let codec = tonic::codec::ProstCodec::default(); in server_reflection_info() localVariable
258 self.inner.streaming(req, path, codec).await in server_reflection_info()
407 let codec = tonic::codec::ProstCodec::default(); in call() localVariable
408 let mut grpc = tonic::server::Grpc::new(codec) in call()
H A Dgrpc_reflection_v1alpha.rs235 tonic::Response<tonic::codec::Streaming<super::ServerReflectionResponse>>, in server_reflection_info()
246 let codec = tonic::codec::ProstCodec::default(); in server_reflection_info() localVariable
258 self.inner.streaming(req, path, codec).await in server_reflection_info()
407 let codec = tonic::codec::ProstCodec::default(); in call() localVariable
408 let mut grpc = tonic::server::Grpc::new(codec) in call()
/tonic/examples/src/compression/
H A Dclient.rs3 use tonic::codec::CompressionEncoding;
H A Dserver.rs5 use tonic::codec::CompressionEncoding;
/tonic/examples/src/codec_buffers/
H A Dcommon.rs15 use tonic::codec::{BufferSettings, Codec, ProstCodec};
/tonic/tonic/benches/
H A Ddecode.rs11 use tonic::{codec::DecodeBuf, codec::Decoder, Status, Streaming};
/tonic/examples/src/json-codec/
H A Dcommon.rs9 codec::{Codec, DecodeBuf, Decoder, EncodeBuf, Encoder},
/tonic/tests/compression/src/
H A Dbidirectional_stream.rs3 use tonic::codec::CompressionEncoding;
H A Dserver_stream.rs2 use tonic::codec::CompressionEncoding;
H A Dutil.rs17 use tonic::codec::CompressionEncoding;
H A Dcompressing_request.rs3 use tonic::codec::CompressionEncoding;
H A Dclient_stream.rs3 use tonic::codec::CompressionEncoding;
H A Dcompressing_response.rs2 use tonic::codec::CompressionEncoding;
/tonic/
H A DCHANGELOG.md53 * **codec:** Make error when not utf8 value in compression encoding ([#1768](https://github.com/hyp…
275 * **codec:** Remove `Default` bound on `Codec` ([#894](https://github.com/hyperium/tonic/issues/894…
276 * **codec:** Return None after poll_data error ([#921](https://github.com/hyperium/tonic/issues/921…
385 * **codec:** compression support ([#692](https://github.com/hyperium/tonic/issues/692)) ([0583cff](…
418 * **codec:** Allocate inbound buffer once ([#578](https://github.com/hyperium/tonic/issues/578)) ([…
513 * **codec:** Improve compression flag log ([#374](https://github.com/hyperium/tonic/issues/374)) ([…
592 * **codec:** Introduce `Decoder/Encoder` traits ([#208](https://github.com/hyperium/tonic/issues/20…
601 * **codec:** Add new `Decoder/Encoder` traits and use `EncodeBuf/DecodeBuf` over `BytesMut` directl…
653 * **codec:** Remove custom content-type ([#104](https://github.com/hyperium/tonic/issues/104)) ([a…
677 * **codec:** Properly decode partial DATA frames ([#83](https://github.com/hyperium/tonic/issues/83…
[all …]