| /tonic/tonic/src/server/ |
| H A D | grpc.rs | 149 pub fn max_decoding_message_size(mut self, limit: usize) -> Self { in max_decoding_message_size()
150 self.max_decoding_message_size = Some(limit); in max_decoding_message_size()
179 pub fn max_encoding_message_size(mut self, limit: usize) -> Self { in max_encoding_message_size()
180 self.max_encoding_message_size = Some(limit); in max_encoding_message_size()
208 if let Some(limit) = max_decoding_message_size { in apply_max_message_size_config()
209 self = self.max_decoding_message_size(limit); in apply_max_message_size_config()
211 if let Some(limit) = max_encoding_message_size { in apply_max_message_size_config()
212 self = self.max_encoding_message_size(limit); in apply_max_message_size_config()
|
| /tonic/tonic-health/src/generated/ |
| H A D | grpc_health_v1.rs | 126 pub fn max_decoding_message_size(mut self, limit: usize) -> Self { in max_decoding_message_size()
127 self.inner = self.inner.max_decoding_message_size(limit); in max_decoding_message_size()
134 pub fn max_encoding_message_size(mut self, limit: usize) -> Self { in max_encoding_message_size()
135 self.inner = self.inner.max_encoding_message_size(limit); in max_encoding_message_size()
299 pub fn max_decoding_message_size(mut self, limit: usize) -> Self { in max_decoding_message_size()
300 self.max_decoding_message_size = Some(limit); in max_decoding_message_size()
307 pub fn max_encoding_message_size(mut self, limit: usize) -> Self { in max_encoding_message_size()
308 self.max_encoding_message_size = Some(limit); in max_encoding_message_size()
|
| /tonic/tonic-reflection/src/generated/ |
| H A D | grpc_reflection_v1.rs | 215 pub fn max_decoding_message_size(mut self, limit: usize) -> Self { in max_decoding_message_size()
216 self.inner = self.inner.max_decoding_message_size(limit); in max_decoding_message_size()
223 pub fn max_encoding_message_size(mut self, limit: usize) -> Self { in max_encoding_message_size()
224 self.inner = self.inner.max_encoding_message_size(limit); in max_encoding_message_size()
340 pub fn max_decoding_message_size(mut self, limit: usize) -> Self { in max_decoding_message_size()
341 self.max_decoding_message_size = Some(limit); in max_decoding_message_size()
348 pub fn max_encoding_message_size(mut self, limit: usize) -> Self { in max_encoding_message_size()
349 self.max_encoding_message_size = Some(limit); in max_encoding_message_size()
|
| H A D | grpc_reflection_v1alpha.rs | 215 pub fn max_decoding_message_size(mut self, limit: usize) -> Self { in max_decoding_message_size()
216 self.inner = self.inner.max_decoding_message_size(limit); in max_decoding_message_size()
223 pub fn max_encoding_message_size(mut self, limit: usize) -> Self { in max_encoding_message_size()
224 self.inner = self.inner.max_encoding_message_size(limit); in max_encoding_message_size()
340 pub fn max_decoding_message_size(mut self, limit: usize) -> Self { in max_decoding_message_size()
341 self.max_decoding_message_size = Some(limit); in max_decoding_message_size()
348 pub fn max_encoding_message_size(mut self, limit: usize) -> Self { in max_encoding_message_size()
349 self.max_encoding_message_size = Some(limit); in max_encoding_message_size()
|
| /tonic/tonic/src/transport/channel/ |
| H A D | endpoint.rs | 192 pub fn concurrency_limit(self, limit: usize) -> Self { in concurrency_limit()
194 concurrency_limit: Some(limit), in concurrency_limit()
207 pub fn rate_limit(self, limit: u64, duration: Duration) -> Self { in rate_limit()
209 rate_limit: Some((limit, duration)), in rate_limit()
|
| /tonic/tonic/src/client/ |
| H A D | grpc.rs | 159 pub fn max_decoding_message_size(mut self, limit: usize) -> Self { in max_decoding_message_size()
160 self.config.max_decoding_message_size = Some(limit); in max_decoding_message_size()
189 pub fn max_encoding_message_size(mut self, limit: usize) -> Self { in max_encoding_message_size()
190 self.config.max_encoding_message_size = Some(limit); in max_encoding_message_size()
|
| /tonic/tonic-build/src/ |
| H A D | client.rs | 119 pub fn max_decoding_message_size(mut self, limit: usize) -> Self { in generate_internal()
120 self.inner = self.inner.max_decoding_message_size(limit); in generate_internal()
128 pub fn max_encoding_message_size(mut self, limit: usize) -> Self { in generate_internal()
129 self.inner = self.inner.max_encoding_message_size(limit); in generate_internal()
|
| H A D | server.rs | 80 pub fn max_decoding_message_size(mut self, limit: usize) -> Self { in generate_internal()
81 self.max_decoding_message_size = Some(limit); in generate_internal()
89 pub fn max_encoding_message_size(mut self, limit: usize) -> Self { in generate_internal()
90 self.max_encoding_message_size = Some(limit); in generate_internal()
|
| /tonic/tonic/src/codec/ |
| H A D | encode.rs | 187 let limit = max_message_size.unwrap_or(DEFAULT_MAX_SEND_MESSAGE_SIZE); in finish_encoding() localVariable
188 if len > limit { in finish_encoding()
191 len, limit in finish_encoding()
|
| H A D | decode.rs | 186 let limit = self in decode_chunk() localVariable
189 if len > limit { in decode_chunk()
193 len, limit in decode_chunk()
|
| /tonic/tonic/src/service/ |
| H A D | layered.rs | 85 use tower::{limit::ConcurrencyLimitLayer, timeout::TimeoutLayer}; in named_service_is_propagated_to_layered()
|
| /tonic/tonic/ |
| H A D | Cargo.toml | 45 "dep:tower", "tower?/util", "tower?/limit",
50 "dep:tower", "tower?/balance", "tower?/buffer", "tower?/discover", "tower?/limit", "tower?/util",
|
| /tonic/tonic-types/proto/ |
| H A D | error_details.proto | 56 // For example if a daily limit was exceeded for the calling project,
58 // id and the description of the quota limit that was exceeded. If the
76 // public documentation, or find the relevant quota limit to adjust through
131 // length. When identifying the current value of an exceeded limit, the units
|
| /tonic/tonic/src/transport/channel/service/ |
| H A D | connection.rs | 17 limit::{concurrency::ConcurrencyLimitLayer, rate::RateLimitLayer},
|
| /tonic/tonic/src/transport/server/ |
| H A D | mod.rs | 70 limit::concurrency::ConcurrencyLimitLayer,
177 pub fn concurrency_limit_per_connection(self, limit: usize) -> Self { in concurrency_limit_per_connection()
179 concurrency_limit: Some(limit), in concurrency_limit_per_connection()
|
| /tonic/ |
| H A D | CONTRIBUTING.md | 223 possible within individual commits. There is no limit to the number of commits
|
| /tonic/examples/proto/googleapis/google/pubsub/v1/ |
| H A D | pubsub.proto | 1126 // <= 0, there is no limit to the number of outstanding messages. This
1137 // is <= 0, there is no limit to the number of outstanding bytes. This
|