|
1 | 1 | package dockergen |
2 | 2 |
|
3 | 3 | import ( |
| 4 | + "bufio" |
4 | 5 | "os" |
| 6 | + "regexp" |
5 | 7 | "sync" |
6 | 8 |
|
7 | 9 | "github.com/fsouza/go-dockerclient" |
@@ -29,14 +31,15 @@ func SetServerInfo(d *docker.Env) { |
29 | 31 | mu.Lock() |
30 | 32 | defer mu.Unlock() |
31 | 33 | dockerInfo = Docker{ |
32 | | - Name: d.Get("Name"), |
33 | | - NumContainers: d.GetInt("Containers"), |
34 | | - NumImages: d.GetInt("Images"), |
35 | | - Version: dockerEnv.Get("Version"), |
36 | | - ApiVersion: dockerEnv.Get("ApiVersion"), |
37 | | - GoVersion: dockerEnv.Get("GoVersion"), |
38 | | - OperatingSystem: dockerEnv.Get("Os"), |
39 | | - Architecture: dockerEnv.Get("Arch"), |
| 34 | + Name: d.Get("Name"), |
| 35 | + NumContainers: d.GetInt("Containers"), |
| 36 | + NumImages: d.GetInt("Images"), |
| 37 | + Version: dockerEnv.Get("Version"), |
| 38 | + ApiVersion: dockerEnv.Get("ApiVersion"), |
| 39 | + GoVersion: dockerEnv.Get("GoVersion"), |
| 40 | + OperatingSystem: dockerEnv.Get("Os"), |
| 41 | + Architecture: dockerEnv.Get("Arch"), |
| 42 | + CurrentContainerID: GetCurrentContainerID(), |
40 | 43 | } |
41 | 44 | } |
42 | 45 |
|
@@ -139,12 +142,42 @@ type Mount struct { |
139 | 142 | } |
140 | 143 |
|
141 | 144 | type Docker struct { |
142 | | - Name string |
143 | | - NumContainers int |
144 | | - NumImages int |
145 | | - Version string |
146 | | - ApiVersion string |
147 | | - GoVersion string |
148 | | - OperatingSystem string |
149 | | - Architecture string |
| 145 | + Name string |
| 146 | + NumContainers int |
| 147 | + NumImages int |
| 148 | + Version string |
| 149 | + ApiVersion string |
| 150 | + GoVersion string |
| 151 | + OperatingSystem string |
| 152 | + Architecture string |
| 153 | + CurrentContainerID string |
| 154 | +} |
| 155 | + |
| 156 | +func GetCurrentContainerID() string { |
| 157 | + file, err := os.Open("/proc/self/cgroup") |
| 158 | + |
| 159 | + if err != nil { |
| 160 | + return "" |
| 161 | + } |
| 162 | + |
| 163 | + reader := bufio.NewReader(file) |
| 164 | + scanner := bufio.NewScanner(reader) |
| 165 | + scanner.Split(bufio.ScanLines) |
| 166 | + |
| 167 | + regex := "/docker/([[:alnum:]]{64})$" |
| 168 | + re := regexp.MustCompilePOSIX(regex) |
| 169 | + |
| 170 | + for scanner.Scan() { |
| 171 | + _, lines, err := bufio.ScanLines([]byte(scanner.Text()), true) |
| 172 | + if err == nil { |
| 173 | + if re.MatchString(string(lines)) { |
| 174 | + submatches := re.FindStringSubmatch(string(lines)) |
| 175 | + containerID := submatches[1] |
| 176 | + |
| 177 | + return containerID |
| 178 | + } |
| 179 | + } |
| 180 | + } |
| 181 | + |
| 182 | + return "" |
150 | 183 | } |
0 commit comments