k8-client 15.0.1

Core Kubernetes metadata traits
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55

mod client_impl;
mod log_stream;
#[cfg(feature = "memory_client")]
pub mod memory;

mod list_stream;
mod wstream;

pub use client_impl::K8Client;
pub use log_stream::LogStream;

cfg_if::cfg_if! {
    if #[cfg(feature = "openssl_tls")] {
        mod config_openssl;
        use config_openssl::*;
    } else if #[cfg(feature = "native_tls")] {
        mod config_native;
        use config_native::*;
    } else if #[cfg(feature = "rust_tls")] {
        mod config_rustls;
        use config_rustls::*;
    }
}

use list_stream::*;

pub mod http {
    pub use ::http::header;
    pub use ::http::status;
    pub use ::http::Error;
    pub use ::http::uri::InvalidUri;
    pub use hyper::Uri;
}

pub mod prelude {
    pub use hyper::Body;
    pub use hyper::Request;
}

mod executor {

    use futures_util::future::Future;
    use hyper::rt::Executor;

    use fluvio_future::task::spawn;

    #[allow(dead_code)]
    pub(crate) struct FluvioHyperExecutor;

    impl<F: Future + Send + 'static> Executor<F> for FluvioHyperExecutor {
        fn execute(&self, fut: F) {
            spawn(async { drop(fut.await) });
        }
    }
}