| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/interceptor/ |
| D | mod.rs | 43 fn intercept_connection(&self, _info: ConnDetail) -> Result<(), HttpClientError> { in intercept_connection() argument
48 fn intercept_input(&self, _bytes: &[u8]) -> Result<(), HttpClientError> { in intercept_input() argument
53 fn intercept_output(&self, _bytes: &[u8]) -> Result<(), HttpClientError> { in intercept_output() argument
58 fn intercept_request(&self, _request: &Request) -> Result<(), HttpClientError> { in intercept_request() argument
63 fn intercept_response(&self, _response: &Response) -> Result<(), HttpClientError> { in intercept_response() argument
68 fn intercept_retry(&self, _error: &HttpClientError) -> Result<(), HttpClientError> { in intercept_retry() argument
73 fn intercept_redirect_request(&self, _request: &Request) -> Result<(), HttpClientError> { in intercept_redirect_request() argument
81 ) -> Result<(), HttpClientError> { in intercept_redirect_response() argument
|
| /commonlibrary/rust/ylong_http/ylong_http_client/tests/ |
| D | sdv_async_interceptor.rs | 168 fn intercept_connection(&self, _info: ConnDetail) -> Result<(), HttpClientError> { in sdv_client_request_interceptor_http1_connection() argument
181 fn intercept_input(&self, _bytes: &[u8]) -> Result<(), HttpClientError> { in sdv_client_request_interceptor_http1_input() argument
194 fn intercept_output(&self, _bytes: &[u8]) -> Result<(), HttpClientError> { in sdv_client_request_interceptor_http1_output() argument
207 fn intercept_request(&self, _request: &Request) -> Result<(), HttpClientError> { in sdv_client_request_interceptor_http1_request() argument
220 fn intercept_response(&self, _response: &Response) -> Result<(), HttpClientError> { in sdv_client_request_interceptor_http1_response() argument
233 fn intercept_connection(&self, _info: ConnDetail) -> Result<(), HttpClientError> { in sdv_client_request_interceptor_http1_retry() argument
236 fn intercept_retry(&self, _error: &HttpClientError) -> Result<(), HttpClientError> { in sdv_client_request_interceptor_http1_retry() argument
273 fn intercept_redirect_request(&self, _request: &Request) -> Result<(), HttpClientError> { in sdv_client_request_interceptor_http1_redirect_request() argument
289 ) -> Result<(), HttpClientError> { in sdv_client_request_interceptor_http1_redirect_response() argument
338 fn intercept_connection(&self, _info: ConnDetail) -> Result<(), HttpClientError> { in sdv_client_request_interceptor_http2_connection() argument
[all …]
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/ |
| D | error.rs | 31 pub struct HttpClientError { struct
36 impl HttpClientError { argument
136 impl HttpClientError { implementation
180 impl Debug for HttpClientError { implementation
189 impl Display for HttpClientError { implementation
197 impl error::Error for HttpClientError { implementation
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/config/tls/verifier/ |
| D | openssl.rs | 42 pub fn version(&self) -> Result<usize, HttpClientError> { in version() argument
62 pub fn cert_name(&self) -> Result<String, HttpClientError> { in cert_name() argument
89 pub fn issuer(&self) -> Result<String, HttpClientError> { in issuer() argument
120 pub fn cmp_pem_cert(&self, target_pem: &[u8]) -> Result<usize, HttpClientError> { in cmp_pem_cert() argument
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/downloader/ |
| D | operator.rs | 31 ) -> Poll<Result<usize, HttpClientError>>; in poll_download() argument
42 ) -> Poll<Result<(), HttpClientError>> { in poll_progress() argument
84 ) -> Poll<Result<usize, HttpClientError>> { in poll_download() argument
93 ) -> Poll<Result<(), HttpClientError>> { in poll_progress() argument
141 ) -> Poll<Result<usize, HttpClientError>> { in poll_download() argument
154 ) -> Poll<Result<(), HttpClientError>> { in poll_progress() argument
|
| D | mod.rs | 164 pub async fn download(&mut self) -> Result<(), HttpClientError> { in download() argument
180 async fn limited_download(&mut self) -> Result<(), HttpClientError> { in limited_download() argument
206 fn check_timeout(&mut self) -> Result<(), HttpClientError> { in check_timeout() argument
216 async fn show_progress(&mut self) -> Result<(), HttpClientError> { in show_progress() argument
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/uploader/ |
| D | operator.rs | 58 ) -> Poll<Result<(), HttpClientError>> { in poll_progress() argument
84 ) -> Poll<Result<(), HttpClientError>> { in poll_progress() argument
117 ) -> Poll<Result<(), HttpClientError>> { in poll_progress() argument
|
| D | mod.rs | 284 ) -> Poll<Result<(), HttpClientError>> { in upload_op_cov() argument
317 ) -> Poll<Result<(), HttpClientError>> { in upload_and_show_progress() argument
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/sync_impl/ |
| D | client.rs | 109 ) -> Result<Response<HttpBody>, HttpClientError> { in request() argument
117 ) -> Result<Response<HttpBody>, HttpClientError> { in retry_send_request() argument
131 ) -> Result<Response<HttpBody>, HttpClientError> { in send_request_retryable() argument
140 ) -> Result<Response<HttpBody>, HttpClientError> { in redirect_request() argument
163 ) -> Result<Response<HttpBody>, HttpClientError> { in send_request_with_uri() argument
311 pub fn build(self) -> Result<Client<HttpConnector>, HttpClientError> { in build() argument
|
| D | http_body.rs | 121 fn data(&mut self, buf: &mut [u8]) -> Result<usize, HttpClientError> { in data() argument
206 fn data(&mut self, buf: &mut [u8]) -> Result<usize, HttpClientError> { in data() argument
263 fn merge_chunks(&mut self, buf: &mut [u8]) -> Result<(usize, bool), HttpClientError> { in merge_chunks() argument
|
| D | pool.rs | 39 pub(crate) fn connect_to(&self, uri: Uri) -> Result<Conn<C::Stream>, HttpClientError> { in connect_to() argument
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/ |
| D | response.rs | 39 pub async fn data(&mut self, buf: &mut [u8]) -> Result<usize, HttpClientError> { in data() argument
44 pub async fn text(mut self) -> Result<String, HttpClientError> { in text() argument
|
| D | http_body.rs | 80 ) -> Result<Self, HttpClientError> { in new() argument
231 ) -> Poll<Result<usize, HttpClientError>> { in data() argument
260 ) -> Poll<Result<usize, HttpClientError>> { in poll_read_io() argument
325 ) -> Poll<Result<usize, HttpClientError>> { in data() argument
357 ) -> Option<Poll<Result<usize, HttpClientError>>> { in read_remaining() argument
388 ) -> Poll<Result<usize, HttpClientError>> { in poll_read_io() argument
467 ) -> Poll<Result<usize, HttpClientError>> { in data() argument
532 fn merge_chunks(&mut self, buf: &mut [u8]) -> Result<(usize, bool), HttpClientError> { in merge_chunks() argument
|
| D | client.rs | 160 pub async fn request(&self, request: Request) -> Result<Response, HttpClientError> { in request() argument
207 async fn send_request(&self, request: RequestArc) -> Result<Response, HttpClientError> { in send_request() argument
218 ) -> Result<Response, HttpClientError> { in send_unformatted_request() argument
230 async fn connect_to(&self, uri: &Uri) -> Result<TimeInfoConn<C::Stream>, HttpClientError> { in connect_to() argument
246 ) -> Result<Response, HttpClientError> { in send_request_on_conn() argument
269 ) -> Result<Response, HttpClientError> { in redirect() argument
615 pub fn build(self) -> Result<Client<HttpConnector>, HttpClientError> { in build() argument
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/ |
| D | normalizer.rs | 32 pub(crate) fn format(&mut self) -> Result<(), HttpClientError> { in format() argument
65 pub(crate) fn format(&self, uri: &mut Uri) -> Result<(), HttpClientError> { in format() argument
125 pub(crate) fn parse(&self) -> Result<BodyLength, HttpClientError> { in parse() argument
188 pub(crate) fn format_host_value(uri: &Uri) -> Result<String, HttpClientError> { in format_host_value() argument
|
| D | proxy.rs | 64 pub(crate) fn http(uri: &str) -> Result<Self, HttpClientError> { in http() argument
68 pub(crate) fn https(uri: &str) -> Result<Self, HttpClientError> { in https() argument
72 pub(crate) fn all(uri: &str) -> Result<Self, HttpClientError> { in all() argument
155 pub(crate) fn new(uri: &str) -> Result<Self, HttpClientError> { in new() argument
|
| D | redirect.rs | 46 ) -> Result<Trigger, HttpClientError> { in redirect() argument
125 fn trigger(&self, info: &RedirectInfo) -> Result<Trigger, HttpClientError> { in trigger() argument
|
| D | data_ref.rs | 45 ) -> Poll<Result<usize, HttpClientError>> { in poll_read() argument
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/c_openssl/ |
| D | adapter.rs | 365 pub fn build(mut self) -> Result<TlsConfig, HttpClientError> { in build() argument
565 pub fn from_pem(pem: &[u8]) -> Result<Self, HttpClientError> { in from_pem() argument
582 pub fn from_der(der: &[u8]) -> Result<Self, HttpClientError> { in from_der() argument
589 pub fn stack_from_pem(pem: &[u8]) -> Result<Vec<Self>, HttpClientError> { in stack_from_pem() argument
624 pub fn from_pem(pem: &[u8]) -> Result<Self, HttpClientError> { in from_pem() argument
636 pub fn from_path(path: &str) -> Result<Self, HttpClientError> { in from_path() argument
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/progress/ |
| D | rate_limit.rs | 84 pub(crate) fn min_send_speed_limit(&mut self, size: usize) -> Result<(), HttpClientError> { in min_send_speed_limit() argument
92 pub(crate) fn min_recv_speed_limit(&mut self, size: usize) -> Result<(), HttpClientError> { in min_recv_speed_limit() argument
179 pub(crate) fn min_speed_limit(&mut self, read: usize) -> Result<(), HttpClientError> { in min_speed_limit() argument
325 pub(crate) fn limit_min_speed(&mut self, data_size: usize) -> Result<(), HttpClientError> { in limit_min_speed() argument
342 fn check_min_speed(&mut self, data_size: usize) -> Result<(), HttpClientError> { in check_min_speed() argument
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/connector/ |
| D | mod.rs | 88 async fn tcp_stream(eyeballs: HappyEyeballs) -> Result<TcpStream, HttpClientError> { in tcp_stream() argument
114 ) -> Result<Vec<SocketAddr>, HttpClientError> { in dns_query() argument
131 ) -> Result<TcpStream, HttpClientError> { in eyeballs_connect() argument
140 ) -> Result<ConnectedUdpSocket, HttpClientError> { in udp_stream() argument
418 ) -> Result<HttpStream<MixStream>, HttpClientError> { in https_connect() argument
|
| /commonlibrary/rust/ylong_http/ylong_http_client/examples/ |
| D | async_certs_adapter.rs | 62 async fn request(client: Arc<Client>) -> Result<(), HttpClientError> { in request() argument
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/c_openssl/verify/ |
| D | pinning.rs | 179 pub fn build(self) -> Result<PubKeyPins, HttpClientError> { in build() argument
222 fn parse_uri(uri: &str) -> Result<String, HttpClientError> { in parse_uri() argument
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/dns/ |
| D | doh.rs | 128 async fn retry(&self, authority: &str) -> Result<(Vec<SocketAddr>, u64), HttpClientError> { in retry() argument
147 ) -> Result<(Vec<SocketAddr>, u64), HttpClientError> { in doh_connect() argument
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/config/ |
| D | settings.rs | 117 pub fn new(times: usize) -> Result<Self, HttpClientError> { in new() argument
460 pub fn build(self) -> Result<Proxy, HttpClientError> { in build() argument
|