Browse Source

Merge pull request 'fix bugs' (#220) from tzwang/pcm-coordinator:master into master

Former-commit-id: 818b7110f1
alpha-0.0.1
tzwang 1 year ago
parent
commit
4b2087311a
1 changed files with 12 additions and 7 deletions
  1. +12
    -7
      api/internal/scheduler/database/aiStorage.go

+ 12
- 7
api/internal/scheduler/database/aiStorage.go View File

@@ -219,13 +219,17 @@ func (s *AiStorage) SaveClusterResources(adapterId string, clusterId string, clu
}
// prometheus
param := tracker.ClusterLoadRecord{
ClusterName: clusterName,
CpuAvail: cpuAvail,
CpuTotal: cpuTotal,
MemoryAvail: memAvail,
MemoryTotal: memTotal,
DiskAvail: diskAvail,
DiskTotal: diskTotal,
AdapterId: aId,
ClusterName: clusterName,
CpuAvail: cpuAvail,
CpuTotal: cpuTotal,
CpuUtilisation: clusterResource.CpuAvail / clusterResource.CpuTotal,
MemoryAvail: memAvail,
MemoryTotal: memTotal,
MemoryUtilisation: clusterResource.MemAvail / clusterResource.MemTotal,
DiskAvail: diskAvail,
DiskTotal: diskTotal,
DiskUtilisation: clusterResource.DiskAvail / clusterResource.DiskTotal,
}
tracker.SyncClusterLoad(param)
return nil
@@ -239,6 +243,7 @@ func (s *AiStorage) UpdateClusterResources(clusterResource *models.TClusterResou
}
// prometheus
param := tracker.ClusterLoadRecord{
AdapterId: clusterResource.AdapterId,
ClusterName: clusterResource.ClusterName,
CpuAvail: clusterResource.CpuAvail,
CpuTotal: clusterResource.CpuTotal,


Loading…
Cancel
Save