| /tonic/tonic/benches-disabled/benchmarks/compiled_protos/ |
| H A D | helloworld.rs | 19 inner: tonic::client::Grpc<T>, field
41 let inner = tonic::client::Grpc::new(inner); in new() localVariable
42 Self { inner } in new()
67 inner: self.inner.clone(), in clone()
90 inner: Arc<T>, field
95 inner: Arc<T>, field
100 let inner = Arc::new(inner); in new() localVariable
104 Self { inner } in from_shared()
109 Self { inner } in new()
131 let inner = self.inner.clone(); in call() localVariable
[all …]
|
| /tonic/tonic-health/src/generated/ |
| H A D | grpc_health_v1.rs | 81 let inner = tonic::client::Grpc::new(inner); in new() localVariable
85 let inner = tonic::client::Grpc::with_origin(inner, origin); in with_origin() localVariable
89 inner: T, in with_interceptor()
113 self.inner = self.inner.send_compressed(encoding); in send_compressed()
119 self.inner = self.inner.accept_compressed(encoding); in accept_compressed()
127 self.inner = self.inner.max_decoding_message_size(limit); in max_decoding_message_size()
135 self.inner = self.inner.max_encoding_message_size(limit); in max_encoding_message_size()
147 self.inner in check()
356 let inner = self.inner.clone(); in call() localVariable
402 let inner = self.inner.clone(); in call() localVariable
[all …]
|
| /tonic/tonic/src/service/ |
| H A D | recover_error.rs | 34 RecoverError::new(inner) in layer()
42 inner: S, field
48 Self { inner } in new()
67 inner: self.inner.call(req), in call()
76 inner: F, field
114 inner: Option<B>, field
124 fn full(inner: B) -> Self { in full()
125 Self { inner: Some(inner) } in full()
129 Self { inner: None } in empty()
151 match &self.inner { in is_end_stream()
[all …]
|
| H A D | layered.rs | 14 inner: S, field
31 self.inner.poll_ready(cx) in poll_ready()
35 self.inner.call(req) in call()
53 inner: self.layer(service), in named_layer()
|
| /tonic/tonic/src/metadata/ |
| H A D | map.rs | 1377 Some(ref mut inner) => inner in next()
1398 Some(ref mut inner) => inner in next_back()
1611 inner: self.inner.insert_entry(value.inner), in insert_entry()
1764 inner: self.inner.insert_mult(value.inner), in insert_mult()
1791 self.inner.append(value.inner) in append()
1883 inner: Some(self.inner.iter()), in iter()
1914 inner: self.inner.iter_mut(), in iter_mut()
1929 inner: self.inner.into_iter(), in into_iter()
1976 inner: self.inner.as_ref().map(|inner| inner.iter()), in iter()
1997 inner: self.inner.map(|inner| inner.into_iter()), in into_iter()
[all …]
|
| H A D | value.rs | 25 pub(crate) inner: HeaderValue, field
196 self.inner.as_bytes() in as_encoded_bytes()
205 inner: value, in unchecked_from_header_value()
257 inner: value, in try_from()
312 inner: value, in try_from()
416 self.inner.len() in len()
448 self.inner.as_bytes() in as_bytes()
472 self.inner.as_ref() in as_ref()
486 inner: h.inner.into(), in from()
636 VE::values_equal(&self.inner, &other.inner) in eq()
[all …]
|
| H A D | key.rs | 22 pub(crate) inner: http::header::HeaderName, field
49 inner: name, in from_bytes()
109 inner: name, in from_static()
119 self.inner.as_str() in as_str()
136 inner: name, in unchecked_from_header_name()
196 Bytes::copy_from_slice(name.inner.as_ref()) in from()
230 self.inner.eq(other) in eq()
250 other.inner == *self in eq()
|
| /tonic/tonic-reflection/src/generated/ |
| H A D | grpc_reflection_v1.rs | 170 let inner = tonic::client::Grpc::new(inner); in new() localVariable
174 let inner = tonic::client::Grpc::with_origin(inner, origin); in with_origin() localVariable
178 inner: T, in with_interceptor()
202 self.inner = self.inner.send_compressed(encoding); in send_compressed()
208 self.inner = self.inner.accept_compressed(encoding); in accept_compressed()
216 self.inner = self.inner.max_decoding_message_size(limit); in max_decoding_message_size()
224 self.inner = self.inner.max_encoding_message_size(limit); in max_encoding_message_size()
238 self.inner in server_reflection_info()
316 inner: T, in with_interceptor()
404 let inner = self.inner.clone(); in call() localVariable
[all …]
|
| H A D | grpc_reflection_v1alpha.rs | 170 let inner = tonic::client::Grpc::new(inner); in new() localVariable
174 let inner = tonic::client::Grpc::with_origin(inner, origin); in with_origin() localVariable
178 inner: T, in with_interceptor()
202 self.inner = self.inner.send_compressed(encoding); in send_compressed()
208 self.inner = self.inner.accept_compressed(encoding); in accept_compressed()
216 self.inner = self.inner.max_decoding_message_size(limit); in max_decoding_message_size()
224 self.inner = self.inner.max_encoding_message_size(limit); in max_encoding_message_size()
238 self.inner in server_reflection_info()
316 inner: T, in with_interceptor()
404 let inner = self.inner.clone(); in call() localVariable
[all …]
|
| /tonic/tonic-web/src/ |
| H A D | client.rs | 31 fn layer(&self, inner: S) -> Self::Service { in layer()
32 GrpcWebClientService::new(inner) in layer()
41 inner: S, field
46 pub fn new(inner: S) -> Self { in new()
47 Self { inner } in new()
60 self.inner.poll_ready(cx) in poll_ready()
75 let fut = self.inner.call(req); in call()
77 ResponseFuture { inner: fut } in call()
86 inner: F, field
96 let res = ready!(self.project().inner.poll(cx)); in poll()
|
| H A D | layer.rs | 21 fn layer(&self, inner: S) -> Self::Service { in layer()
22 GrpcWebService::new(inner) in layer()
|
| /tonic/tonic-build/src/ |
| H A D | client.rs | 63 inner: tonic::client::Grpc<T>, in generate_internal()
75 pub fn new(inner: T) -> Self { in generate_internal()
76 let inner = tonic::client::Grpc::new(inner); in generate_internal() localVariable
77 Self { inner } in generate_internal()
81 let inner = tonic::client::Grpc::with_origin(inner, origin); in generate_internal() localVariable
82 Self { inner } in generate_internal()
104 self.inner = self.inner.send_compressed(encoding); in generate_internal()
111 self.inner = self.inner.accept_compressed(encoding); in generate_internal()
120 self.inner = self.inner.max_decoding_message_size(limit); in generate_internal()
129 self.inner = self.inner.max_encoding_message_size(limit); in generate_internal()
[all …]
|
| H A D | server.rs | 180 let inner = self.inner.clone(); in generate_internal() localVariable
450 quote!(inner) in generate_unary()
452 quote!(&inner) in generate_unary()
476 let inner = self.inner.clone(); in generate_unary() localVariable
516 quote!(inner) in generate_server_streaming()
518 quote!(&inner) in generate_server_streaming()
543 let inner = self.inner.clone(); in generate_server_streaming() localVariable
574 quote!(inner) in generate_client_streaming()
601 let inner = self.inner.clone(); in generate_client_streaming() localVariable
641 quote!(inner) in generate_streaming()
[all …]
|
| /tonic/tonic/src/transport/server/ |
| H A D | conn.rs | 113 let (inner, session) = self.get_ref(); in connect_info()
114 let inner = inner.connect_info(); in connect_info() localVariable
120 TlsConnectInfo { inner, certs } in connect_info()
134 inner: T, field
142 &self.inner in get_ref()
147 &mut self.inner in get_mut()
|
| /tonic/examples/src/tower/ |
| H A D | client.rs | 51 inner: Channel, field
55 pub fn new(inner: Channel) -> Self { in new()
56 AuthSvc { inner } in new()
67 self.inner.poll_ready(cx).map_err(Into::into) in poll_ready()
72 let clone = self.inner.clone(); in call()
73 let mut inner = std::mem::replace(&mut self.inner, clone); in call() localVariable
77 let response = inner.call(req).await?; in call()
|
| H A D | server.rs | 72 MyMiddleware { inner: service } in layer()
78 inner: S, field
94 self.inner.poll_ready(cx) in poll_ready()
99 let clone = self.inner.clone(); in call()
100 let mut inner = std::mem::replace(&mut self.inner, clone); in call() localVariable
104 let response = inner.call(req).await?; in call()
|
| /tonic/tonic/src/transport/ |
| H A D | error.rs | 7 inner: ErrorImpl, field
27 inner: ErrorImpl { kind, source: None }, in new()
32 self.inner.source = Some(source.into()); in with()
51 match &self.inner.kind { in description()
65 f.field(&self.inner.kind); in fmt()
67 if let Some(source) = &self.inner.source { in fmt()
83 self.inner in source()
|
| /tonic/tonic/src/transport/server/service/ |
| H A D | io.rs | 29 fn layer(&self, inner: S) -> Self::Service { in layer()
30 ConnectInfo::new(inner, self.connect_info.clone()) in layer()
36 inner: S, field
41 fn new(inner: S, connect_info: T) -> Self { in new()
43 inner, in new()
59 self.inner.poll_ready(cx) in poll_ready()
64 ServerIoConnectInfo::Io(inner) => { in call()
65 req.extensions_mut().insert(inner); in call()
68 ServerIoConnectInfo::TlsIo(inner) => { in call()
70 req.extensions_mut().insert(inner); in call()
[all …]
|
| /tonic/tonic/src/transport/channel/service/ |
| H A D | user_agent.rs | 9 inner: T, field
14 pub(crate) fn new(inner: T, user_agent: Option<HeaderValue>) -> Self { in new()
25 Self { inner, user_agent } in new()
38 self.inner.poll_ready(cx) in poll_ready()
45 self.inner.call(req) in call()
|
| H A D | add_origin.rs | 10 inner: T, field
16 pub(crate) fn new(inner: T, origin: Uri) -> Self { in new()
22 inner, in new()
40 self.inner.poll_ready(cx).map_err(Into::into) in poll_ready()
65 let fut = self.inner.call(request); in call()
|
| H A D | executor.rs | 9 inner: Arc<dyn Executor<BoxFuture<'static, ()>> + Send + Sync + 'static>, field
18 inner: Arc::new(exec), in new()
32 self.inner.execute(Box::pin(fut)) in execute()
|
| H A D | connector.rs | 18 inner: C, field
24 pub(crate) fn new(inner: C, #[cfg(feature = "_tls-any")] tls: Option<TlsConnector>) -> Self { in new()
26 inner, in new()
45 self.inner in poll_ready()
56 let connect = self.inner.call(uri); in call()
|
| H A D | reconnect.rs | 111 State::Connected(ref mut inner) => { in poll_ready()
116 match inner.poll_ready(cx) { in poll_ready()
178 inner: Inner<F>, field
189 pub(crate) fn new(inner: F) -> Self { in new()
191 inner: Inner::Future(inner), in new()
197 inner: Inner::Error(Some(error)), in error()
212 match me.inner.project() { in poll()
|
| /tonic/tonic/src/codec/ |
| H A D | compression.rs | 19 inner: [Option<CompressionEncoding>; 3], field
27 for e in self.inner.iter_mut() { in enable()
41 self.inner in pop()
50 for encoding in self.inner.into_iter().flatten() { in into_accept_encoding_header_value()
65 self.inner.contains(&Some(encoding)) in is_enabled()
70 self.inner.iter().all(|e| e.is_none()) in is_empty()
332 inner: [Some(CompressionEncoding::Gzip), None, None], in convert_gzip_into_header_value()
338 inner: [None, None, Some(CompressionEncoding::Gzip)], in convert_gzip_into_header_value()
350 inner: [Some(CompressionEncoding::Zstd), None, None], in convert_zstd_into_header_value()
366 inner: [ in convert_compression_encodings_into_header_value()
[all …]
|
| /tonic/tests/integration_tests/tests/ |
| H A D | extensions.rs | 86 inner: test_server::TestServer::new(Svc), in setting_extension_from_tower()
122 inner: S, field
139 self.inner.poll_ready(cx) in poll_ready()
143 let clone = self.inner.clone(); in call()
144 let mut inner = std::mem::replace(&mut self.inner, clone); in call() localVariable
149 let response = inner.call(req).await?; in call()
|