Current state of the http proxy support?

[njust]

Hi, what’s the current state of the http proxy support? I found that it was added with this PR #246

And then removed when switchting from reqwest to hyper here 6a8e819

But since there was recently this PR #892, to support lowercase http_proxy & https_proxy environment variables, I guess proxies are somehow supported?

[Masber]

I did a test https://github.com/kube-rs/kube-rs/discussions?discussions_q=proxy and it did not work for me... not sure I am doing something wrong but I also would like someone from the community to give some advice on this

[Masber]

Apparently, you can get a work around like this:

    let mut config = kube::Config::infer().await?;
    let connector = {
        let mut http = HttpConnector::new();
        http.enforce_http(false);
        let proxy = hyper_socks2::SocksConnector {
            proxy_addr: Uri::from_static("socks5://localhost:1080"),
            auth: None,
            connector: http,
        };
        let mut native_tls_builder = native_tls::TlsConnector::builder();
		native_tls_builder.danger_accept_invalid_certs(true);
		native_tls_builder.danger_accept_invalid_hostnames(true);
		native_tls_builder.use_sni(false);

		let native_tls_connector = native_tls_builder.build().unwrap();

        let tls = tokio_native_tls::TlsConnector::from(native_tls_connector);
        hyper_tls::HttpsConnector::from((proxy, tls))
    };
    let service = ServiceBuilder::new()
        .layer(kube::client::ConfigExt::base_uri_layer(&config))
        .service(hyper::Client::builder().build(connector));
    let client = kube::Client::new(service, config.default_namespace);
        // let client = Client::try_default().await?;
    let jobs: Api<Job> = Api::default_namespaced(client);

    let params = kube::api::ListParams::default();
    jobs.list(&params).await?;

with dependencies

tokio = { version = "1", features = ["full"] }
kube = { version = "0.74.0", features = ["runtime", "derive"] }
k8s-openapi = { version = "0.15.0", features = ["v1_24"] }
hyper-socks2 = "0.6.0"
hyper = { version = "0.14", features = ["full"] }
tokio-native-tls = "0.3.0"
hyper-tls = "0.5.0"
tower = "0.4.13"
native-tls = "0.2.10"

[njust]

Thanks, if you need support for http proxies, you can use this code

async fn get_kube_client(kube_ctx: &str) -> Result<Client>{
    let config = Config::from_kubeconfig(&KubeConfigOptions{
        context: Some(kube_ctx.to_string()),
        ..KubeConfigOptions::default()
    }).await?;

    let client = if let Some(proxy_uri) = &config.proxy_url {
        let proxy = {
            let proxy = Proxy::new(Intercept::All, proxy_uri.clone());
            let mut proxy_connector = ProxyConnector::from_proxy(HttpConnector::new(), proxy)?;
            proxy_connector.set_tls(Some(config.native_tls_connector()?));
            proxy_connector
        };

        let service = ServiceBuilder::new()
            .layer(config.base_uri_layer())
            .service(hyper::Client::builder().build(proxy));
        Client::new(service, config.default_namespace)
    } else {
        Client::try_from(config)?
    };

    Ok(client)
}

with the additional dependencies

hyper-proxy = {version="0.9.1", features = ["native-tls"]}
hyper = { version = "0.14.13", features = ["client"] }
tower = "0.4.13"