Home
last modified time | relevance | path

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

123

/tonic/tonic-types/src/richer_error/
H A Dmod.rs280 fn get_details_retry_info(&self) -> Option<RetryInfo>; in get_details_retry_info()
302 fn get_details_debug_info(&self) -> Option<DebugInfo>; in get_details_debug_info()
346 fn get_details_error_info(&self) -> Option<ErrorInfo>; in get_details_error_info()
456 fn get_details_help(&self) -> Option<Help>; in get_details_help()
626 fn get_details_retry_info(&self) -> Option<RetryInfo> { in get_details_retry_info()
674 fn get_details_help(&self) -> Option<Help> { in get_details_help()
720 fn get_details_retry_info(&self) -> Option<RetryInfo>; in get_details_retry_info()
724 fn get_details_debug_info(&self) -> Option<DebugInfo>; in get_details_debug_info()
732 fn get_details_error_info(&self) -> Option<ErrorInfo>; in get_details_error_info()
752 fn get_details_help(&self) -> Option<Help>; in get_details_help()
[all …]
/tonic/tonic-types/src/richer_error/error_details/
H A Dmod.rs19 pub(crate) retry_info: Option<RetryInfo>,
22 pub(crate) debug_info: Option<DebugInfo>,
25 pub(crate) quota_failure: Option<QuotaFailure>,
28 pub(crate) error_info: Option<ErrorInfo>,
34 pub(crate) bad_request: Option<BadRequest>,
37 pub(crate) request_info: Option<RequestInfo>,
40 pub(crate) resource_info: Option<ResourceInfo>,
43 pub(crate) help: Option<Help>,
385 pub fn retry_info(&self) -> Option<&RetryInfo> { in retry_info()
390 pub fn debug_info(&self) -> Option<&DebugInfo> { in debug_info()
[all …]
/tonic/tonic/src/transport/channel/
H A Dendpoint.rs21 pub(crate) origin: Option<Uri>,
22 pub(crate) user_agent: Option<HeaderValue>,
23 pub(crate) timeout: Option<Duration>,
24 pub(crate) concurrency_limit: Option<usize>,
25 pub(crate) rate_limit: Option<(u64, Duration)>,
27 pub(crate) tls: Option<TlsConnector>,
28 pub(crate) buffer_size: Option<usize>,
29 pub(crate) init_stream_window_size: Option<u32>,
31 pub(crate) tcp_keepalive: Option<Duration>,
37 pub(crate) connect_timeout: Option<Duration>,
[all …]
H A Dtls.rs12 domain: Option<String>,
15 identity: Option<Identity>,
/tonic/tonic/src/transport/server/
H A Dconn.rs71 pub local_addr: Option<SocketAddr>,
73 pub remote_addr: Option<SocketAddr>,
78 pub fn local_addr(&self) -> Option<SocketAddr> { in local_addr()
83 pub fn remote_addr(&self) -> Option<SocketAddr> { in remote_addr()
135 certs: Option<Arc<Vec<CertificateDer<'static>>>>,
151 pub fn peer_certs(&self) -> Option<Arc<Vec<CertificateDer<'static>>>> { in peer_certs()
H A Dincoming.rs20 nodelay: Option<bool>,
21 keepalive: Option<TcpKeepalive>,
64 pub fn with_nodelay(self, nodelay: Option<bool>) -> Self { in with_nodelay()
69 pub fn with_keepalive(self, keepalive: Option<Duration>) -> Self { in with_keepalive()
88 fn poll_next(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>> { in poll_next()
102 nodelay: Option<bool>, in set_accepted_socket_options()
103 keepalive: &Option<TcpKeepalive>, in set_accepted_socket_options()
H A Dmod.rs91 concurrency_limit: Option<usize>,
92 timeout: Option<Duration>,
94 tls: Option<TlsAcceptor>,
95 init_stream_window_size: Option<u32>,
97 max_concurrent_streams: Option<u32>,
98 tcp_keepalive: Option<Duration>,
102 http2_adaptive_window: Option<bool>,
105 max_frame_size: Option<u32>,
631 signal: Option<F>, in serve_internal()
1059 timeout: Option<Duration>,
[all …]
H A Dunix.rs15 pub peer_addr: Option<Arc<tokio::net::unix::SocketAddr>>,
17 pub peer_cred: Option<tokio::net::unix::UCred>,
H A Dtls.rs9 identity: Option<Identity>,
10 client_ca_root: Option<Certificate>,
H A Dio_stream.rs33 state: Option<State<IO>>,
40 pub(crate) fn new(incoming: S, #[cfg(feature = "_tls-any")] tls: Option<TlsAcceptor>) -> Self { in new()
51 ) -> Poll<Option<Result<ServerIo<IO>, crate::BoxError>>> in poll_next_without_tls()
78 fn poll_next(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>> { in poll_next()
83 fn poll_next(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>> { in poll_next()
/tonic/tonic/src/codec/
H A Dencode.rs27 compression_encoding: Option<CompressionEncoding>,
28 max_message_size: Option<usize>,
31 error: Option<Status>,
40 max_message_size: Option<usize>, in new()
137 compression_encoding: Option<CompressionEncoding>, in encode_item()
138 max_message_size: Option<usize>, in encode_item()
182 compression_encoding: Option<CompressionEncoding>, in finish_encoding()
183 max_message_size: Option<usize>, in finish_encoding()
226 error: Option<Status>,
238 max_message_size: Option<usize>, in new_client()
[all …]
H A Ddecode.rs31 trailers: Option<HeaderMap>,
33 encoding: Option<CompressionEncoding>,
34 max_message_size: Option<usize>,
43 compression: Option<CompressionEncoding>,
46 Error(Option<Status>),
63 encoding: Option<CompressionEncoding>, in new_response()
64 max_message_size: Option<usize>, in new_response()
95 encoding: Option<CompressionEncoding>, in new_request()
96 max_message_size: Option<usize>, in new_request()
116 encoding: Option<CompressionEncoding>, in new()
[all …]
H A Dcompression.rs19 inner: [Option<CompressionEncoding>; 3],
40 pub fn pop(&mut self) -> Option<CompressionEncoding> { in pop()
48 pub(crate) fn into_accept_encoding_header_value(self) -> Option<http::HeaderValue> { in into_accept_encoding_header_value()
111 ) -> Option<Self> { in from_accept_encoding_header()
134 ) -> Result<Option<Self>, Status> { in from_encoding_header()
/tonic/tonic/src/metadata/
H A Dmap.rs1056 ) -> Option<MetadataValue<Binary>> in insert_bin()
1238 fn next(&mut self) -> Option<Self::Item> { in next()
1265 fn next(&mut self) -> Option<Self::Item> { in next()
1292 fn next(&mut self) -> Option<Self::Item> { in next()
1308 fn next(&mut self) -> Option<Self::Item> { in next()
1330 fn next(&mut self) -> Option<Self::Item> { in next()
1351 fn next(&mut self) -> Option<Self::Item> { in next()
2036 -> Option<MetadataValue<VE>>; in insert()
2051 ) -> Option<MetadataValue<VE>> { in insert()
2073 ) -> Option<MetadataValue<VE>> { in insert()
[all …]
H A Dvalue.rs644 fn partial_cmp(&self, other: &MetadataValue<VE>) -> Option<cmp::Ordering> { in partial_cmp()
672 fn partial_cmp(&self, other: &str) -> Option<cmp::Ordering> { in partial_cmp()
679 fn partial_cmp(&self, other: &[u8]) -> Option<cmp::Ordering> { in partial_cmp()
700 fn partial_cmp(&self, other: &MetadataValue<VE>) -> Option<cmp::Ordering> { in partial_cmp()
707 fn partial_cmp(&self, other: &MetadataValue<VE>) -> Option<cmp::Ordering> { in partial_cmp()
721 fn partial_cmp(&self, other: &String) -> Option<cmp::Ordering> { in partial_cmp()
735 fn partial_cmp(&self, other: &MetadataValue<VE>) -> Option<cmp::Ordering> { in partial_cmp()
749 fn partial_cmp(&self, other: &MetadataValue<VE>) -> Option<cmp::Ordering> { in partial_cmp()
769 fn partial_cmp(&self, other: &&'a T) -> Option<cmp::Ordering> { in partial_cmp()
783 fn partial_cmp(&self, other: &MetadataValue<VE>) -> Option<cmp::Ordering> { in partial_cmp()
/tonic/tonic-build/src/
H A Dmanual.rs59 name: Option<String>,
61 package: Option<String>,
258 name: Option<String>,
260 route_name: Option<String>,
264 input_type: Option<String>,
266 output_type: Option<String>,
274 codec_path: Option<String>,
421 out_dir: Option<PathBuf>,
/tonic/tonic/src/
H A Dbody.rs44 if let Some(body) = <dyn std::any::Any>::downcast_mut::<Option<Body>>(&mut body) { in new()
48 if let Some(body) = <dyn std::any::Any>::downcast_mut::<Option<BoxBody>>(&mut body) { in new()
74 ) -> Poll<Option<Result<http_body::Frame<Self::Data>, Self::Error>>> { in poll_frame()
/tonic/tonic/src/transport/service/
H A Dgrpc_timeout.rs16 server_timeout: Option<Duration>,
20 pub(crate) fn new(inner: S, server_timeout: Option<Duration>) -> Self { in new()
70 sleep: Option<Sleep>,
105 ) -> Result<Option<Duration>, &HeaderValue> { in try_parse_grpc_timeout()
155 fn setup_map_try_parse(val: Option<&str>) -> Result<Option<Duration>, HeaderValue> { in setup_map_try_parse()
/tonic/tonic/src/server/
H A Dgrpc.rs41 max_decoding_message_size: Option<usize>,
43 max_encoding_message_size: Option<usize>,
205 max_decoding_message_size: Option<usize>, in apply_max_message_size_config()
206 max_encoding_message_size: Option<usize>, in apply_max_message_size_config()
422 accept_encoding: Option<CompressionEncoding>, in map_response()
424 max_message_size: Option<usize>, in map_response()
461 ) -> Result<Option<CompressionEncoding>, Status> { in request_encoding_if_supported()
/tonic/tonic/src/transport/
H A Derror.rs12 source: Option<Source>,
82 fn source(&self) -> Option<&(dyn StdError + 'static)> { in source()
/tonic/tests/root-crate-path/src/
H A Dmain.rs4 pub name: ::core::option::Option<::prost::alloc::string::String>,
/tonic/tonic/src/transport/channel/service/
H A Dadd_origin.rs11 scheme: Option<Scheme>,
12 authority: Option<Authority>,
H A Dconnector.rs20 tls: Option<TlsConnector>,
24 pub(crate) fn new(inner: C, #[cfg(feature = "_tls-any")] tls: Option<TlsConnector>) -> Self { in new()
/tonic/tests/integration_tests/tests/
H A Dmax_message_size.rs265 client_recv_max: Option<usize>,
266 server_recv_max: Option<usize>,
267 client_send_max: Option<usize>,
268 server_send_max: Option<usize>,
270 expected_code: Option<Code>,
/tonic/tonic-web/src/
H A Dcall.rs33 fn content_type(headers: &HeaderMap) -> Option<&str> { in content_type()
70 trailers: Option<HeaderMap>,
144 fn decode_chunk(mut self: Pin<&mut Self>) -> Result<Option<Bytes>, Status> { in decode_chunk()
173 ) -> Poll<Option<Result<Frame<Bytes>, Status>>> { in poll_decode()
219 ) -> Poll<Option<Result<Frame<Bytes>, Status>>> { in poll_encode()
261 ) -> Poll<Option<Result<Frame<Self::Data>, Self::Error>>> { in poll_frame()
346 fn poll_next(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>> { in poll_next()
367 fn from_header(value: Option<&HeaderValue>) -> Encoding { in from_header()
390 fn decode_trailers_frame(mut buf: Bytes) -> Result<Option<HeaderMap>, Status> { in decode_trailers_frame()

123