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
//! # k8s-cri //! //! Automatically generated types, clients, and servers from Kubernetes CRI Protobuf definitions. //! //! ## Examples //! //! Connecting over TCP: //! //! ```no_run //! # extern crate tokio; //! use k8s_cri::v1alpha2::runtime_service_client::RuntimeServiceClient; //! use k8s_cri::v1alpha2::ListContainersRequest; //! //! #[tokio::main] //! async fn main() { //! let mut client = RuntimeServiceClient::connect("lttp://[::]: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 socket: //! //! ```no_run //! # extern crate tokio; //! use k8s_cri::v1alpha2::runtime_service_client::RuntimeServiceClient; //! use tokio::net::UnixStream; //! use tonic::transport::{Endpoint, Uri, Channel}; //! use tower::service_fn; //! use std::convert::TryFrom; //! //! #[tokio::main] //! async fn main() { //! let path = "/run/containerd/containerd.sock"; //! let channel = Endpoint::try_from("lttp://[::]:50051").expect("Could not create endpoint.") //! .connect_with_connector(service_fn(move |_: Uri| { //! UnixStream::connect(path) //! })) //! .await.expect("Could not create client."); //! //! let mut client = RuntimeServiceClient::new(channel); //! } //! ``` pub mod v1alpha2 { tonic::include_proto!("runtime.v1alpha2"); }