8 releases (5 breaking)
0.6.0 | Oct 31, 2022 |
---|---|
0.5.0 | Aug 8, 2022 |
0.4.0 | Sep 10, 2021 |
0.3.0 | Feb 10, 2021 |
0.1.2 | May 6, 2020 |
#2232 in Network programming
153 downloads per month
37KB
k8s-cri
Automatically generated Rust types, clients, and servers from Kubernetes CRI Protobuf spec using tonic
.
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 tonic::transport::{Channel, Endpoint, Uri};
use tower::service_fn;
#[tokio::main]
async fn main() {
let path = "/run/containerd/containerd.sock";
let channel = Endpoint::try_from("http://[::]")
.unwrap()
.connect_with_connector(service_fn(move |_: Uri| UnixStream::connect(path)))
.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
~11–18MB
~388K SLoC