fixed types
This commit is contained in:
parent
3d68cef8ba
commit
aee5ce47a2
1 changed files with 8 additions and 8 deletions
16
node.go
16
node.go
|
|
@ -29,10 +29,10 @@ type Node struct {
|
|||
Status NodeStatus `json:"status"`
|
||||
CPU float64 `json:"cpu"`
|
||||
MaxCPU float64 `json:"maxcpu"`
|
||||
Mem int64 `json:"mem"`
|
||||
MaxMem int64 `json:"maxmem"`
|
||||
Disk int64 `json:"disk"`
|
||||
MaxDisk int64 `json:"maxdisk"`
|
||||
Mem uint64 `json:"mem"`
|
||||
MaxMem uint64 `json:"maxmem"`
|
||||
Disk uint64 `json:"disk"`
|
||||
MaxDisk uint64 `json:"maxdisk"`
|
||||
serverList ServerList `json:"-"`
|
||||
}
|
||||
|
||||
|
|
@ -106,10 +106,10 @@ func FilterNodeName(name string) NodeFilter {
|
|||
}
|
||||
}
|
||||
|
||||
func FilterMaxCores(cores int64) NodeFilter {
|
||||
func FilterMaxCores(cores uint64) NodeFilter {
|
||||
return func(nl *NodeList) {
|
||||
for i, n := range *nl {
|
||||
if cores > int64(n.MaxCPU) {
|
||||
if cores > uint64(n.MaxCPU) {
|
||||
nl.remove(i)
|
||||
}
|
||||
}
|
||||
|
|
@ -121,7 +121,7 @@ const (
|
|||
gib = mib * 1024
|
||||
)
|
||||
|
||||
func FilterFreeMem(mem int64) NodeFilter {
|
||||
func FilterFreeMem(mem uint64) NodeFilter {
|
||||
return func(nl *NodeList) {
|
||||
for i, n := range *nl {
|
||||
if (mem * gib) >= n.MaxMem-n.Mem {
|
||||
|
|
@ -132,7 +132,7 @@ func FilterFreeMem(mem int64) NodeFilter {
|
|||
}
|
||||
|
||||
// Useful? only local disk?
|
||||
func FilterFreeDisk(disk int64) NodeFilter {
|
||||
func FilterFreeDisk(disk uint64) NodeFilter {
|
||||
return func(nl *NodeList) {
|
||||
for i, n := range *nl {
|
||||
if (disk * gib) >= n.MaxDisk-n.Disk {
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue