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

``` A Library For Download OCI Image

Example:

1、Downloade DockerHub Image

cripullimage("".tostring,"".tostring,"".tostring,imagename,image_version,docker:true).await.unwrap;

2、Download Registry Image

cripullimage(repositoriesurlip,username,password,imagename,imageversion,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 antkingimage::criserverimagepull::cripullimage; use antkingimage::localrepositories::getimagedigest_local;

pub async fn pullimageimplv1alpha2(request:Request) -> PullImageResponse { // docker:nginx:latest // docker:ruilkyu/nginx:latest // harbor:192.168.1.118:8899/saodiseng/nginx:latest let pullimagerequest = request.intoinner(); let imagetmp1 = pullimagerequest.clone().image; let auth = pullimagerequest.clone().auth; let _sandboxconfig = pullimagerequest.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、运行实例

``` [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 ```