cant find exec method?

[Masber]

Hi,

I am quite new to Rust and trying this library to talk to my k8s cluster.

I would like to be able to run kubectl exec ... and I copied the code in your example like the one below:

pub async fn test() -> Result<(), Box<dyn Error>>{

    log::info!("Connecting to node {} console", xname);

    tracing_subscriber::fmt::init();
    let client = Client::try_default().await?;

    let pods: Api<Pod> = Api::default_namespaced(client);

    {
        let attached = pods
            .exec(
                "example",
                vec!["sh", "-c", "for i in $(seq 1 3); do date; done"],
                None,
            )
            .await?;
    }

    Ok(())
}

async fn get_output(mut attached: AttachedProcess) -> String {
    let stdout = tokio_util::io::ReaderStream::new(attached.stdout().unwrap());
    let out = stdout
        .filter_map(|r| async { r.ok().and_then(|v| String::from_utf8(v.to_vec()).ok()) })
        .collect::<Vec<_>>()
        .await
        .join("");
    attached.join().await.unwrap();
    out
}

Version used

kube = { version = "0.74.0", features = ["runtime", "derive", "native-tls"] }
k8s-openapi = { version = "0.15.0", features = ["v1_24"] }

My problem is that the compiler complains

error[E0599]: no method named `exec` found for struct `kube::Api` in the current scope
  --> src/node_console/mod.rs:16:14
   |
16 |             .exec(
   |              ^^^^ method not found in `kube::Api<Pod>`

Any idea why?

[clux]

Api::exec requires the ws feature which is not enabled by default https://docs.rs/kube-client/0.75.0/src/kube_client/api/subresource.rs.html#357-378 since it pulls in some extra dependencies for the streaming protocol.

Modifying your Cargo.toml kube line to

kube = { version = "0.74.0", features = ["runtime", "derive", "native-tls", "ws"] }

should fix it.

Separate note; native-tls is removed in the next version (via #1044).