golang使用github.com/fsouza/go-dockerclient訪問container的stats信息

例子使用/fsouza/go-dockerclient收集一個container的stats信息，包括CPU percent，Memory Usage和Limit；對于其他值，方法類似參閱API文檔獲取對應(yīng)的項(xiàng)即可。

package main

import (
    "fmt"
    "time"

    docker  "github.com/fsouza/go-dockerclient"
)

func main() {
    var endpoint string = "unix:///var/run/docker.sock"
    var client *docker.Client
    var err error

    client, err = docker.NewClient(endpoint)
    if err != nil {
        panic(err)
    }

    statsChan := make(chan *docker.Stats)
    doneChan  := make(chan bool)
    statsOpts := docker.StatsOptions{
        ID: "352d14882ad2",    // Replace container ID here
        Stats: statsChan,
        Done: doneChan,
        Stream: false,
    }

    go func() {
        err := client.Stats(statsOpts)
        if err != nil {
            // panic: io: read/write on closed pipe
            panic(err)
        }
    }()

    time.Sleep(2 * time.Second)
        
    doneChan <- true
    stats := <- statsChan
            
    //close(statsChan)  // client.Stats() will close it
    close(doneChan)

    if stats != nil {
        // Refer from 
        // https://github.com/moby/moby/blob/c0699cd4a43ccc3b1e3624379e46e9ed94f7428c/cli/command/container/stats_helpers.go
        cpuPercent  := 0.0
        cpuDelta    := float64(stats.CPUStats.CPUUsage.TotalUsage) - float64(stats.PreCPUStats.CPUUsage.TotalUsage)
        systemDelta := float64(stats.CPUStats.SystemCPUUsage) - float64(stats.PreCPUStats.SystemCPUUsage)
        if systemDelta > 0.0 && cpuDelta > 0.0 {
            cpuPercent = (cpuDelta / systemDelta) * float64(len(stats.CPUStats.CPUUsage.PercpuUsage)) * 100.0
        }
        fmt.Println("CPU Percent=", cpuPercent)

        fmt.Println("Memory Usage:", stats.MemoryStats.Usage)
        fmt.Println("Memory Limit:", stats.MemoryStats.Limit)
    }
}

這里需要注意的幾點(diǎn)是：

1. client.Stats()是一個阻塞函數(shù)，不會返回，需要在獨(dú)立的goroutine里面運(yùn)行。
2. client.Stats的返回需要給StatsOptions.Done chan丟消息進(jìn)去。
3. 然后從StatsOptions.Stats chan取出stats數(shù)據(jù)結(jié)構(gòu)。注意要判斷取出的stats是否為空。
4. time.Sleep(2 * time.Second)貌似是必須的，如果設(shè)置成1s，經(jīng)測試拿不到正確的返回值。
5. 關(guān)于CPU Percent的計(jì)算方法是參考下面文檔的：
   https://github.com/moby/moby/blob/c0699cd4a43ccc3b1e3624379e46e9ed94f7428c/cli/command/container/stats_helpers.go

運(yùn)行結(jié)果如下：

$ go build && ./main
CPU Percent= 0
Memory Usage: 294912
Memory Limit: 63634374656