ClusterCockpit/cc-backend
1
0
Fork 0
mirror of https://github.com/ClusterCockpit/cc-backend synced 2026-02-11 21:41:46 +01:00
Code Issues Packages Releases Activity

add timers to updateNodeStates

Browse Source
This commit is contained in:
Christoph Kluge
2026-02-05 15:24:11 +01:00
parent 4d13c37008
commit e3148b16eb
1 changed files with 8 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
internal/api/node.go
View File

@@ -15,6 +15,7 @@ import (
"github.com/ClusterCockpit/cc-backend/internal/repository" "github.com/ClusterCockpit/cc-backend/internal/repository"
"github.com/ClusterCockpit/cc-backend/pkg/archive" "github.com/ClusterCockpit/cc-backend/pkg/archive"
"github.com/ClusterCockpit/cc-backend/pkg/metricstore" "github.com/ClusterCockpit/cc-backend/pkg/metricstore"
cclog "github.com/ClusterCockpit/cc-lib/v2/ccLogger"
"github.com/ClusterCockpit/cc-lib/v2/schema" "github.com/ClusterCockpit/cc-lib/v2/schema"
) )
@@ -81,6 +82,8 @@ func (api *RestAPI) updateNodeStates(rw http.ResponseWriter, r *http.Request) {
m := make(map[string][]string) m := make(map[string][]string)
healthStates := make(map[string]schema.MonitoringState) healthStates := make(map[string]schema.MonitoringState)
startMs := time.Now()
for _, node := range req.Nodes { for _, node := range req.Nodes {
if sc, err := archive.GetSubClusterByNode(req.Cluster, node.Hostname); err == nil { if sc, err := archive.GetSubClusterByNode(req.Cluster, node.Hostname); err == nil {
m[sc] = append(m[sc], node.Hostname) m[sc] = append(m[sc], node.Hostname)
@@ -97,6 +100,9 @@ func (api *RestAPI) updateNodeStates(rw http.ResponseWriter, r *http.Request) {
} }
} }
cclog.Infof("Timer updateNodeStates, MemStore HealthCheck: %s", time.Since(startMs))
startDb := time.Now()
for _, node := range req.Nodes { for _, node := range req.Nodes {
state := determineState(node.States) state := determineState(node.States)
healthState := schema.MonitoringStateFailed healthState := schema.MonitoringStateFailed
@@ -115,4 +121,6 @@ func (api *RestAPI) updateNodeStates(rw http.ResponseWriter, r *http.Request) {
repo.UpdateNodeState(node.Hostname, req.Cluster, &nodeState) repo.UpdateNodeState(node.Hostname, req.Cluster, &nodeState)
} }
cclog.Infof("Timer updateNodeStates, SQLite Inserts: %s", time.Since(startDb))
} }