Method getContainerStats

core/stats_linux.go:28–67

(container *runtimeapi.Container)

)

func (ds *dockerService) getContainerStats(container *runtimeapi.Container) (*runtimeapi.ContainerStats, error) {
	containerID := container.Id
	statsJSON, err := ds.client.GetContainerStats(containerID)
	if err != nil {
		return nil, err
	}

	dockerStats := statsJSON.Stats
	timestamp := time.Now().UnixNano()
	containerStats := &runtimeapi.ContainerStats{
		Attributes: &runtimeapi.ContainerAttributes{
			Id:          containerID,
			Metadata:    container.Metadata,
			Labels:      container.Labels,
			Annotations: container.Annotations,
		},
		Cpu: &runtimeapi.CpuUsage{
			Timestamp: timestamp,
			UsageCoreNanoSeconds: &runtimeapi.UInt64Value{
				Value: dockerStats.CPUStats.CPUUsage.TotalUsage,
			},
		},
		Memory: &runtimeapi.MemoryUsage{
			Timestamp: timestamp,
			WorkingSetBytes: &runtimeapi.UInt64Value{
				Value: dockerStats.MemoryStats.Usage,
			},
		},
	}

	cstat := ds.containerStatsCache.getStats(containerID)
	if cstat != nil && cstat.isInitialized() {
		containerStats.WritableLayer = &runtimeapi.FilesystemUsage{
			Timestamp: timestamp,
			FsId:      &runtimeapi.FilesystemIdentifier{Mountpoint: ds.dockerRootDir},
			UsedBytes: &runtimeapi.UInt64Value{Value: cstat.getContainerRWSize()},
		}
	}
	return containerStats, nil
}