kubelet 0.7.0

A Kubernetes kubelet implementation in Rust
Documentation 
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
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73

//! Client for fetching container modules from OCI
use async_trait::async_trait;
use oci_distribution::client::ImageData;
use oci_distribution::manifest;
use oci_distribution::secrets::RegistryAuth;

use oci_distribution::Reference;

/// An image client capable of fetching images from a storage location
#[async_trait]
pub trait Client {
    /// Fetch the image data and, if available, image digest for the given image
    /// reference from a storage location.
    ///
    /// # Example
    /// ```rust
    /// use async_trait::async_trait;
    /// use kubelet::store::oci::Client;
    /// use oci_distribution::Reference;
    /// use oci_distribution::client::ImageData;
    /// use oci_distribution::secrets::RegistryAuth;
    ///
    /// struct InMemoryClient(std::collections::HashMap<Reference, ImageData>);
    ///
    /// #[async_trait]
    /// impl Client for InMemoryClient {
    ///     async fn pull(&mut self, image_ref: &Reference, _auth: &RegistryAuth) -> anyhow::Result<ImageData> {
    ///         let image_data = self
    ///             .0
    ///             .get(image_ref)
    ///             .ok_or(anyhow::anyhow!("Couldn't find image"))?;
    ///         Ok(image_data.clone())
    ///     }
    /// }
    /// ```
    async fn pull(
        &mut self,
        image_ref: &Reference,
        auth: &RegistryAuth,
    ) -> anyhow::Result<ImageData>;

    /// Fetch the digest for the given image reference from a storage location.
    ///
    /// The default implementation pulls the image data and digest, and returns
    /// the digest. This is inefficient for most real-world clients, and so should
    /// be overridden.
    async fn fetch_digest(
        &mut self,
        image_ref: &Reference,
        auth: &RegistryAuth,
    ) -> anyhow::Result<String> {
        let image_data = self.pull(image_ref, auth).await?;
        image_data
            .digest
            .ok_or_else(|| anyhow::anyhow!("image {} does not have a digest", image_ref))
    }
}

#[async_trait]
impl Client for oci_distribution::Client {
    async fn pull(&mut self, image: &Reference, auth: &RegistryAuth) -> anyhow::Result<ImageData> {
        self.pull(image, auth, vec![manifest::WASM_LAYER_MEDIA_TYPE])
            .await
    }

    async fn fetch_digest(
        &mut self,
        image: &Reference,
        auth: &RegistryAuth,
    ) -> anyhow::Result<String> {
        self.fetch_manifest_digest(image, auth).await
    }
}