## ant-king-image (OCI镜像拉取，存储) ## Architecture: ![ant-king-image architecture](https://github.com/ruilkqun/AntKingImage/blob/main/architecture/AntKingImage.png) ``` 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) -> 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 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" } } } ```