Fix vet errors
This commit is contained in:
parent
3836d1e2ec
commit
aee5c36313
@ -210,20 +210,20 @@ func (self *rawContainerHandler) getFsStats(stats *info.ContainerStats) error {
|
|||||||
for _, fs := range filesystems {
|
for _, fs := range filesystems {
|
||||||
stats.Filesystem = append(stats.Filesystem,
|
stats.Filesystem = append(stats.Filesystem,
|
||||||
info.FsStats{
|
info.FsStats{
|
||||||
fs.Device,
|
Device: fs.Device,
|
||||||
fs.Capacity,
|
Limit: fs.Capacity,
|
||||||
fs.Capacity - fs.Free,
|
Usage: fs.Capacity - fs.Free,
|
||||||
fs.DiskStats.ReadsCompleted,
|
ReadsCompleted: fs.DiskStats.ReadsCompleted,
|
||||||
fs.DiskStats.ReadsMerged,
|
ReadsMerged: fs.DiskStats.ReadsMerged,
|
||||||
fs.DiskStats.SectorsRead,
|
SectorsRead: fs.DiskStats.SectorsRead,
|
||||||
fs.DiskStats.ReadTime,
|
ReadTime: fs.DiskStats.ReadTime,
|
||||||
fs.DiskStats.WritesCompleted,
|
WritesCompleted: fs.DiskStats.WritesCompleted,
|
||||||
fs.DiskStats.WritesMerged,
|
WritesMerged: fs.DiskStats.WritesMerged,
|
||||||
fs.DiskStats.SectorsWritten,
|
SectorsWritten: fs.DiskStats.SectorsWritten,
|
||||||
fs.DiskStats.WriteTime,
|
WriteTime: fs.DiskStats.WriteTime,
|
||||||
fs.DiskStats.IoInProgress,
|
IoInProgress: fs.DiskStats.IoInProgress,
|
||||||
fs.DiskStats.IoTime,
|
IoTime: fs.DiskStats.IoTime,
|
||||||
fs.DiskStats.WeightedIoTime,
|
WeightedIoTime: fs.DiskStats.WeightedIoTime,
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
} else if len(self.externalMounts) > 0 {
|
} else if len(self.externalMounts) > 0 {
|
||||||
@ -239,20 +239,20 @@ func (self *rawContainerHandler) getFsStats(stats *info.ContainerStats) error {
|
|||||||
for _, fs := range filesystems {
|
for _, fs := range filesystems {
|
||||||
stats.Filesystem = append(stats.Filesystem,
|
stats.Filesystem = append(stats.Filesystem,
|
||||||
info.FsStats{
|
info.FsStats{
|
||||||
fs.Device,
|
Device: fs.Device,
|
||||||
fs.Capacity,
|
Limit: fs.Capacity,
|
||||||
fs.Capacity - fs.Free,
|
Usage: fs.Capacity - fs.Free,
|
||||||
fs.DiskStats.ReadsCompleted,
|
ReadsCompleted: fs.DiskStats.ReadsCompleted,
|
||||||
fs.DiskStats.ReadsMerged,
|
ReadsMerged: fs.DiskStats.ReadsMerged,
|
||||||
fs.DiskStats.SectorsRead,
|
SectorsRead: fs.DiskStats.SectorsRead,
|
||||||
fs.DiskStats.ReadTime,
|
ReadTime: fs.DiskStats.ReadTime,
|
||||||
fs.DiskStats.WritesCompleted,
|
WritesCompleted: fs.DiskStats.WritesCompleted,
|
||||||
fs.DiskStats.WritesMerged,
|
WritesMerged: fs.DiskStats.WritesMerged,
|
||||||
fs.DiskStats.SectorsWritten,
|
SectorsWritten: fs.DiskStats.SectorsWritten,
|
||||||
fs.DiskStats.WriteTime,
|
WriteTime: fs.DiskStats.WriteTime,
|
||||||
fs.DiskStats.IoInProgress,
|
IoInProgress: fs.DiskStats.IoInProgress,
|
||||||
fs.DiskStats.IoTime,
|
IoTime: fs.DiskStats.IoTime,
|
||||||
fs.DiskStats.WeightedIoTime,
|
WeightedIoTime: fs.DiskStats.WeightedIoTime,
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
2
fs/fs.go
2
fs/fs.go
@ -1,5 +1,5 @@
|
|||||||
// +build linux
|
// +build linux
|
||||||
//
|
|
||||||
// Provides Filesystem Stats
|
// Provides Filesystem Stats
|
||||||
package fs
|
package fs
|
||||||
|
|
||||||
|
@ -10,7 +10,7 @@ func TestGetDiskStatsMap(t *testing.T) {
|
|||||||
t.Errorf("Error calling getDiskStatMap %s", err)
|
t.Errorf("Error calling getDiskStatMap %s", err)
|
||||||
}
|
}
|
||||||
if len(diskStatsMap) != 20 {
|
if len(diskStatsMap) != 20 {
|
||||||
t.Errorf("diskStatsMap %s not valid", diskStatsMap)
|
t.Errorf("diskStatsMap %+v not valid", diskStatsMap)
|
||||||
}
|
}
|
||||||
keySet := map[string]string{
|
keySet := map[string]string{
|
||||||
"/dev/sdb1": "/dev/sdb1",
|
"/dev/sdb1": "/dev/sdb1",
|
||||||
@ -42,7 +42,7 @@ func TestGetDiskStatsMap(t *testing.T) {
|
|||||||
delete(keySet, device)
|
delete(keySet, device)
|
||||||
}
|
}
|
||||||
if len(keySet) != 0 {
|
if len(keySet) != 0 {
|
||||||
t.Errorf("diskStatsMap %s contains illegal keys %s", diskStatsMap, keySet)
|
t.Errorf("diskStatsMap %+v contains illegal keys %+v", diskStatsMap, keySet)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -256,7 +256,7 @@ func getMachineInfo(sysFs sysfs.SysFs) (*info.MachineInfo, error) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
for _, fs := range filesystems {
|
for _, fs := range filesystems {
|
||||||
machineInfo.Filesystems = append(machineInfo.Filesystems, info.FsInfo{fs.Device, fs.Capacity})
|
machineInfo.Filesystems = append(machineInfo.Filesystems, info.FsInfo{Device: fs.Device, Capacity: fs.Capacity})
|
||||||
}
|
}
|
||||||
|
|
||||||
return machineInfo, nil
|
return machineInfo, nil
|
||||||
|
@ -625,7 +625,7 @@ func TestSchedDebugReader(t *testing.T) {
|
|||||||
loads, err := NewSchedulerLoadReader()
|
loads, err := NewSchedulerLoadReader()
|
||||||
if testCase.Error != nil {
|
if testCase.Error != nil {
|
||||||
if err == nil {
|
if err == nil {
|
||||||
t.Fatal("expected error: %v", testCase.Error)
|
t.Fatalf("expected error: %v", testCase.Error)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
Loading…
Reference in New Issue
Block a user