k8_client/client/
mod.rs

1mod client_impl;
2mod log_stream;
3#[cfg(feature = "memory_client")]
4pub mod memory;
5
6mod list_stream;
7mod wstream;
8
9pub use client_impl::K8Client;
10pub use log_stream::LogStream;
11
12cfg_if::cfg_if! {
13    if #[cfg(feature = "openssl_tls")] {
14        mod config_openssl;
15        use config_openssl::*;
16    } else if #[cfg(feature = "native_tls")] {
17        mod config_native;
18        use config_native::*;
19    } else if #[cfg(feature = "rust_tls")] {
20        mod config_rustls;
21        use config_rustls::*;
22    }
23}
24
25use list_stream::*;
26
27pub mod http {
28    pub use ::http::header;
29    pub use ::http::status;
30    pub use ::http::Error;
31    pub use ::http::uri::InvalidUri;
32    pub use hyper::Uri;
33}
34
35pub mod prelude {
36    pub use hyper::Body;
37    pub use hyper::Request;
38}
39
40mod executor {
41
42    use futures_util::future::Future;
43    use hyper::rt::Executor;
44
45    use fluvio_future::task::spawn;
46
47    #[allow(dead_code)]
48    pub(crate) struct FluvioHyperExecutor;
49
50    impl<F: Future + Send + 'static> Executor<F> for FluvioHyperExecutor {
51        fn execute(&self, fut: F) {
52            spawn(async { drop(fut.await) });
53        }
54    }
55}
k8_client/client/mod.rs

k8_client/client/
mod.rs
