12 releases (breaking)

0.10.0 Jan 11, 2025
0.9.0 Oct 4, 2024
0.8.0 May 14, 2024
0.7.0 May 19, 2023
0.2.0 Jul 3, 2020

#2106 in Network programming

Download history 1031/week @ 2024-12-28 1662/week @ 2025-01-04 1451/week @ 2025-01-11 1819/week @ 2025-01-18 2353/week @ 2025-01-25 2029/week @ 2025-02-01 2448/week @ 2025-02-08 2452/week @ 2025-02-15 2917/week @ 2025-02-22 2661/week @ 2025-03-01 2294/week @ 2025-03-08 2250/week @ 2025-03-15 2217/week @ 2025-03-22 1617/week @ 2025-03-29 2210/week @ 2025-04-05 1315/week @ 2025-04-12

7,573 downloads per month

Apache-2.0

49KB

k8s-cri

Automatically generated Rust types, clients, and servers from Kubernetes CRI Protobuf spec using tonic.

API Documentation


lib.rs:

Automatically generated types, clients, and servers from Kubernetes CRI Protobuf definitions.

Examples

Connecting over TCP:

use k8s_cri::v1alpha2::runtime_service_client::RuntimeServiceClient;
use k8s_cri::v1alpha2::ListContainersRequest;
use tokio::main;

#[tokio::main]
async fn main() {
    let mut client = RuntimeServiceClient::connect("http://[::1]:50051")
        .await
        .expect("Could not create client.");

    let request = tonic::Request::new(ListContainersRequest { filter: None });
    let response = client
        .list_containers(request)
        .await
        .expect("Request failed.");
    println!("{:?}", response);
}

Connecting to a Unix domain socket:

use std::convert::TryFrom;
use tokio::main;

use k8s_cri::v1alpha2::runtime_service_client::RuntimeServiceClient;
use tokio::net::UnixStream;
use hyper_util::rt::TokioIo;
use tonic::transport::{Channel, Endpoint, Uri};
use tower::service_fn;

#[tokio::main]
async fn main() {
    let channel = Endpoint::try_from("http://[::]")
        .unwrap()
        .connect_with_connector(service_fn(|_: Uri| async {
            let path = "/run/containerd/containerd.sock";
            Ok::<_, std::io::Error>(TokioIo::new(UnixStream::connect(path).await?))
}))
        .await
        .expect("Could not create client.");

    let mut client = RuntimeServiceClient::new(channel);
}

API version v1, original Protocol Buffers file. API version v1alpha2, original Protocol Buffers file.

Dependencies

~4–12MB
~132K SLoC