Lib.rs

ant-king-image (OCI镜像拉取，存储)

Architecture:

A Library For Download OCI Image

Example:

1、Downloade DockerHub Image

   cri_pull_image("".to_string,"".to_string,"".to_string,image_name,image_version,docker:true).await.unwrap;

2、Download Registry Image

   cri_pull_image(repositories_url_ip,username,password,image_name,image_version,docker:false).await.unwrap;

3、运行

Download image configuration file successfully！
[00:00:04] ======================================== 27092654/27092654 000eee12ec04cc914bf96e8f5dee7767510c2aca3816af6078bd9fbe3150920c downloaded
[00:00:06] ======================================== 23741065/23741065 eb22865337de3edb54ec8b52f6c06de320f415e7ec43f01426fdafb8df6d6eb7 downloaded
[00:00:02] ========================================     203/203     bee5d581ef8bfee2b5a54685813ba6ad9bbe922115d7aef84a21a9dbfcc2d979 downloaded
[00:00:02] ========================================     549/549     a8ad52858f44c72f28dd1649338e4ec2dc9119992eb100876b05a6f783ab2667 downloaded
Download Image ruilkyu/nginx:latest complete!

与Kubernetes CRI对接

1、源码实例

use ant_king_image::cri_server_image_pull::cri_pull_image;
use ant_king_image::local_repositories::get_image_digest_local;


pub async fn pull_image_impl_v1alpha2(request:Request<PullImageRequest>) -> PullImageResponse {
        // docker:nginx:latest
        // docker:ruilkyu/nginx:latest
        // harbor:192.168.1.118:8899/saodiseng/nginx:latest
        let pull_image_request = request.into_inner();
        let image_tmp1 = pull_image_request.clone().image;
        let auth = pull_image_request.clone().auth;
        let _sandbox_config = pull_image_request.clone().sandbox_config;

        let image_tmp2 = match image_tmp1 {
                Some(res) => res,
                None => {
                        let reply = PullImageResponse {
                                image_ref: "".to_string()
                        };
                        return reply
                }
        };

        let image_analysis1 = image_tmp2.image.split(":");
        let image_analysis2:Vec<&str> = image_analysis1.collect();
        let docker = image_analysis2[0];

        return if docker == "docker" {
                let image_name = image_analysis2[1];
                let image_version = image_analysis2[2];

                let tmp1 =  image_name.clone().split("/");
                let tmp2:Vec<&str> = tmp1.collect();

                let image_completed_name:String;
                if tmp2.len() > 1 {
                        image_completed_name = image_name.clone().parse().unwrap();
                }else {
                        image_completed_name = format!("library/{}", image_name.clone());
                }

                cri_pull_image("".to_string(), "".to_string(), "".to_string(), image_completed_name.clone().parse().unwrap(), image_version.clone().parse().unwrap(), true).await;
                let image_digest_1 = get_image_digest_local(image_completed_name.clone().parse().unwrap(), image_version.clone().parse().unwrap()).await.unwrap();
                let image_digest = format!("{}@{}",image_completed_name.clone(),image_digest_1.clone());
                println!("image_digest:{}",image_digest.clone());

                let reply = PullImageResponse {
                        image_ref: image_digest.clone()
                };
                reply
        } else {
                let image_auth = match auth {
                        Some(res) => res,
                        None => {
                                let reply = PullImageResponse {
                                        image_ref: "".to_string()
                                };
                                return reply
                        }
                };
                let username = format!("{}",image_auth.username);
                let password = format!("{}",image_auth.password);

                let port_tmp0 = format!("{}",image_analysis2[image_analysis2.len()-2]);
                let port_tmp1 = port_tmp0.split("/");
                let port_tmp2:Vec<&str> = port_tmp1.collect();

                let port = port_tmp2[0];
                let repositories_url_ip = format!("{}:{}",image_analysis2[1],port);

                let mut image_name_tmp:String = format!("{}",port_tmp2[1]);
                for k in 2..port_tmp2.len(){
                        image_name_tmp += &*("/".to_owned() + port_tmp2[k])
                }
                let image_name = format!("{}",image_name_tmp);
                let image_version = format!("{}",image_analysis2[image_analysis2.len()-1]);

                cri_pull_image(repositories_url_ip.clone(), username.clone(), password.clone(), image_name.clone(), image_version.clone(), false).await;
                let image_digest_1 = get_image_digest_local(image_name.clone().parse().unwrap(), image_version.clone().parse().unwrap()).await.unwrap();
                let image_digest = format!("{}{}@{}",repositories_url_ip.clone(),image_name.clone(),image_digest_1.clone());
                println!("image_digest:{}",image_digest.clone());

                let reply = PullImageResponse {
                        image_ref: image_digest.clone()
                };
                reply
        }
}

2、运行实例

2.1、下载镜像

[root@localhost container]# crictl --image-endpoint unix:///var/run/saodiseng.sock  pull docker:ruilkyu/nginx:latest

Image is up to date for ruilkyu/nginx@sha256:bd877619f4ab21d0d2a26c622c0c51935d4da763203d83f542e39a4720d09bdc



[root@localhost container]# crictl --image-endpoint unix:///var/run/saodiseng.sock  pull docker:nginx:latest
Image is up to date for library/nginx@sha256:7ce4f91ef623b9672ec12302c4a710629cd542617c1ebc616a48d06e2a84656a



[root@localhost container]# crictl --image-endpoint unix:///var/run/saodiseng.sock pull --creds=admin:saodiseng harbor:192.168.1.118:8899/saodiseng/nginx:latest
Image is up to date for 192.168.1.118:8899saodiseng/nginx@sha256:6084105296a952523c36eea261af38885f41e9d1d0001b4916fa426e45377ffe

2.2、查看镜像列表

[root@localhost container]# crictl --image-endpoint unix:///var/run/saodiseng.sock  images
IMAGE               TAG                 IMAGE ID            SIZE
/saodiseng/nginx    latest              6084105296a95       137MB
library/nginx       latest              519e12e2a84a9       137MB

[root@localhost container]# crictl --image-endpoint unix:///var/run/saodiseng.sock  images docker:nginx:latest
IMAGE               TAG                 IMAGE ID            SIZE
library/nginx       latest              519e12e2a84a9       137MB
[root@localhost container]# crictl --image-endpoint unix:///var/run/saodiseng.sock  images harbor:/saodiseng/nginx:latest
IMAGE               TAG                 IMAGE ID            SIZE
/saodiseng/nginx    latest              6084105296a95       137MB

[root@localhost container]# crictl --image-endpoint unix:///var/run/saodiseng.sock
 images --digests sha256:6084105296a952523c36eea261af38885f41e9d1d0001b4916fa426e45377ffe
IMAGE               TAG                 DIGEST              IMAGE ID            SIZE
/saodiseng/nginx    latest              <none>              6084105296a95       137MB

2.3、删除镜像

[root@localhost container]# crictl --image-endpoint unix:///var/run/saodiseng.sock  rmi 519e12e2a84a9

2.4、查看镜像信息

[root@localhost container]# crictl --image-endpoint unix:///var/run/saodiseng.sock  inspecti 6084105296a95
{
  "status": {
    "id": "sha256:6084105296a952523c36eea261af38885f41e9d1d0001b4916fa426e45377ffe",
    "repoTags": [
      "/saodiseng/nginx:latest"
    ],
    "repoDigests": [],
    "size": "137318912",
    "uid": {
      "value": "1000"
    },
    "username": "root",
    "spec": {
      "image": "sha256:6084105296a952523c36eea261af38885f41e9d1d0001b4916fa426e45377ffe",
      "annotations": {}
    }
  }
}

2.5、查看镜像文件系统信息

[root@localhost ~]# crictl --image-endpoint unix:///var/run/saodiseng.sock  imagefsinfo
{
  "status": {
    "timestamp": "1618385746189724737",
    "fsId": {
      "mountpoint": "/"
    },
    "usedBytes": {
      "value": "547010913"
    },
    "inodesUsed": {
      "value": "71199008"
    }
  }
}