oci-util 0.2.0

云网关OCI公共库
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
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102

use anyhow::{anyhow, Result};
use std::path::PathBuf;

pub mod snapshot;

pub struct FileSystem;

///
/// $HOME/hpmq
///       ├──imagedb
///       │  ├──images.json
///       │  ├──sha256
///       │  │  ├──image的manifest文件；文件名为文件的sha256摘要
///       ├──configdb
///       │  ├──sha256
///       │  │  ├──image的config文件；文件名为文件的sha256摘要
///       ├──layerdb
///       │  ├──contents?（待实现）
///       │  │  │  layer的描述文件（Descriptor）；文件名为文件的sha256摘要
///       │  ├──blobs
///       │  │  ├──sha256
///       │  │  │  ├──image的layer文件
///       ├──containerdb
///       │  ├──image的manifest文件的sha256
///       │  │  ├──image展开后的文件目录
///
impl FileSystem {
    ///
    /// |Platform | Value                | Example        |
    /// | ------- | -------------------- | -------------- |
    /// | Linux   | `$HOME`              | /home/alice    |
    /// | macOS   | `$HOME`              | /Users/Alice   |
    /// | Windows | `{FOLDERID_Profile}` | C:\Users\Alice |
    pub fn home(&self) -> Result<PathBuf> {
        let path = dirs::home_dir()
            .and_then(|path| Some(path.join(".hpmq")))
            .ok_or(anyhow!("找不到HOME路径"))?;
        std::fs::create_dir_all(&path)?;
        Ok(path)
    }
    pub fn layer(&self) -> Result<PathBuf> {
        let path = self.home()?.join("layerdb");
        std::fs::create_dir_all(&path)?;
        Ok(path)
    }
    pub fn layer_contents(&self) -> Result<PathBuf> {
        let path = self.home()?.join("layerdb").join("contents");
        std::fs::create_dir_all(&path)?;
        Ok(path)
    }
    pub fn layer_blobs(&self) -> Result<PathBuf> {
        let path = self.home()?.join("layerdb").join("blobs").join("sha256");
        std::fs::create_dir_all(&path)?;
        Ok(path)
    }
    pub fn manifest_sha256(&self) -> Result<PathBuf> {
        let path = self.home()?.join("imagedb").join("sha256");
        std::fs::create_dir_all(&path)?;
        Ok(path)
    }
    pub fn config_sha256(&self) -> Result<PathBuf> {
        let path = self.home()?.join("configdb").join("sha256");
        std::fs::create_dir_all(&path)?;
        Ok(path)
    }
    pub fn images_json(&self) -> Result<PathBuf> {
        let path = self.home()?.join("imagedb");
        std::fs::create_dir_all(&path)?;
        Ok(path.join("images.json"))
    }
    pub fn container(&self) -> Result<PathBuf> {
        let path = self.home()?.join("containerdb");
        std::fs::create_dir_all(&path)?;
        Ok(path)
    }

    pub fn exist_config(&self, sha256_digest: &String) -> Result<bool> {
        let config_path = self.config_sha256()?;
        Ok(config_path.join(sha256_digest).exists())
    }
    pub fn exist_layer(&self, sha256_digest: &String) -> Result<bool> {
        let layer_path = self.layer_blobs()?;
        Ok(layer_path.join(sha256_digest).exists())
    }
    pub fn exist_container(&self, sha256_digest: &String) -> Result<bool> {
        let layer_path = self.container()?;
        Ok(layer_path.join(sha256_digest).exists())
    }

    pub fn save_config(&self, sha256_digest: &String, data: &[u8]) -> Result<()> {
        let config_path = self.config_sha256()?;
        Ok(std::fs::write(config_path.join(sha256_digest), data)?)
    }
    pub fn save_manifest(&self, sha256_digest: &String, data: &[u8]) -> Result<()> {
        let manifest_path = self.manifest_sha256()?;
        Ok(std::fs::write(manifest_path.join(sha256_digest), data)?)
    }
    pub fn save_layer(&self, sha256_digest: &String, data: &[u8]) -> Result<()> {
        let config_path = self.layer_blobs()?;
        Ok(std::fs::write(config_path.join(sha256_digest), data)?)
    }
}