-
Notifications
You must be signed in to change notification settings - Fork 55
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
feat(mysql): dbactuator增加获取主机信息 close #1060
- Loading branch information
Showing
15 changed files
with
391 additions
and
34 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,21 @@ | ||
| package cmutil | ||
|
|
||
| import ( | ||
| "os" | ||
| "path/filepath" | ||
| ) | ||
|
|
||
| // DirSize get directory size like du | ||
| func DirSize(path string) (int64, error) { | ||
| var totalSize int64 | ||
| err := filepath.Walk(path, func(_ string, info os.FileInfo, err error) error { | ||
| if err != nil { | ||
| return err | ||
| } | ||
| if !info.IsDir() { | ||
| totalSize += info.Size() | ||
| } | ||
| return err | ||
| }) | ||
| return totalSize, err | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,118 @@ | ||
| package cmutil | ||
|
|
||
| import ( | ||
| "strings" | ||
|
|
||
| "github.com/pkg/errors" | ||
| "github.com/shirou/gopsutil/v3/cpu" | ||
| "github.com/shirou/gopsutil/v3/disk" | ||
| "github.com/shirou/gopsutil/v3/mem" | ||
| ) | ||
|
|
||
| // MemoryInfo return memory info | ||
| type MemoryInfo struct { | ||
| Total uint64 `json:"total"` | ||
| Free uint64 `json:"free"` | ||
| Shared uint64 `json:"shared"` | ||
| Buffer uint64 `json:"buffer"` | ||
| SwapTotal uint64 `json:"swap_total"` | ||
| SwapFree uint64 `json:"swap_free"` | ||
| } | ||
|
|
||
| // GetMemoryInfo Get Memory Info | ||
| func GetMemoryInfo() (*MemoryInfo, error) { | ||
| memStat, err := mem.VirtualMemory() | ||
| if err != nil { | ||
| return nil, errors.Wrap(err, "fail to get memory") | ||
| } | ||
| memInfo := MemoryInfo{ | ||
| Total: memStat.Total, | ||
| Free: memStat.Free, | ||
| Shared: memStat.Shared, | ||
| Buffer: memStat.Buffers, | ||
| SwapTotal: memStat.SwapTotal, | ||
| SwapFree: memStat.SwapFree, | ||
| } | ||
| return &memInfo, nil | ||
| } | ||
|
|
||
| // DiskPartInfo return disk partition info | ||
| type DiskPartInfo struct { | ||
| Device string `json:"device"` | ||
| Mountpoint string `json:"mountpoint"` | ||
| Fstype string `json:"fstype"` | ||
|
|
||
| Path string `json:"path"` | ||
| Total uint64 `json:"total"` | ||
| // Free 不包括 fs reserved block 部分 | ||
| Free uint64 `json:"free"` | ||
| // Used truly used, not include reserved | ||
| Used uint64 `json:"used"` | ||
| // Reserved = Total - Free - Used | ||
| Reserved uint64 `json:"reserved"` | ||
| UsedPercent float64 `json:"used_percent"` | ||
| InodesTotal uint64 `json:"inodes_total"` | ||
| InodesUsed uint64 `json:"inodes_used"` | ||
| InodesUsedPercent float64 `json:"inodes_used_percent"` | ||
| } | ||
|
|
||
| // GetDiskPartInfo 获取目录的信息 | ||
| // 空间使用，挂载设备。比如 path = /data/dbbak/123，获取的是目录对应的挂载设备的信息 | ||
| func GetDiskPartInfo(path string, noCheckDevice bool) (*DiskPartInfo, error) { | ||
| info := DiskPartInfo{Path: path} | ||
| if !noCheckDevice { | ||
| // 获取目录对应的挂载点 | ||
| osStatArgs := []string{"--format", "%m", path} | ||
| if stdout, stderr, err := ExecCommand(false, "", "stat", osStatArgs...); err != nil { | ||
| return nil, errors.Wrapf(err, "stat to get path mount %s", stderr) | ||
| } else { | ||
| info.Mountpoint = strings.TrimSpace(stdout) | ||
| } | ||
| // get more mountpoint device info | ||
| partInfo, err := disk.Partitions(false) | ||
| if err != nil { | ||
| return nil, errors.Wrap(err, "get disk partitions") | ||
| } | ||
| for _, p := range partInfo { | ||
| if p.Mountpoint == info.Mountpoint { | ||
| info.Device = p.Device | ||
| info.Fstype = p.Fstype | ||
| } | ||
| } | ||
| if info.Device == "" { | ||
| return nil, errors.Errorf("fail to get device(mounted %s) for path %s", info.Mountpoint, info.Path) | ||
| } | ||
| if info.Mountpoint != info.Path { | ||
| // use du to get directory used size? | ||
| } | ||
| } | ||
|
|
||
| // 获取挂载点的分区使用信息 | ||
| pathInfo, err := disk.Usage(path) | ||
| if err != nil { | ||
| return nil, errors.Wrap(err, "get disk info") | ||
| } | ||
| info.Total = pathInfo.Total | ||
| info.Free = pathInfo.Free | ||
| info.Used = pathInfo.Used | ||
| info.UsedPercent = pathInfo.UsedPercent | ||
| info.Reserved = pathInfo.Total - pathInfo.Used - pathInfo.Free | ||
| info.InodesTotal = pathInfo.InodesTotal | ||
| info.InodesUsed = pathInfo.InodesUsed | ||
| info.InodesUsedPercent = float64(100.0*pathInfo.InodesUsed) / float64(pathInfo.InodesTotal) | ||
| return &info, nil | ||
| } | ||
|
|
||
| // CPUInfo return cpu processor info | ||
| type CPUInfo struct { | ||
| CoresLogical int `json:"cores_logical"` | ||
| } | ||
|
|
||
| // GetCPUInfo Get CPU Info | ||
| func GetCPUInfo() (*CPUInfo, error) { | ||
| cores, err := cpu.Counts(true) | ||
| if err != nil { | ||
| return nil, errors.Wrap(err, "cpu.Counts") | ||
| } | ||
| return &CPUInfo{CoresLogical: cores}, nil | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.