diff --git a/main.go b/main.go index f6b9490..b9283d6 100644 --- a/main.go +++ b/main.go @@ -8,6 +8,7 @@ import ( "log" "net/http" "os" + "time" _ "modernc.org/sqlite" ) @@ -47,7 +48,22 @@ func main() { log.Fatal(err) } - fmt.Printf("Starting HTTP listener on :%v", Config.Port) + fmt.Println("Getting loadAvg minutely from /proc/loadavg") + tickerLAvgMin := time.NewTicker(time.Minute) + done := make(chan bool) + + go func() { + for { + select { + case <-done: + return + case t := <-tickerLAvgMin.C: + fetchLoadMinutely(t) + } + } + }() + + fmt.Printf("Starting HTTP listener on :%v\n", Config.Port) http.Handle("/static/", http.FileServer(http.Dir("./"))) http.HandleFunc("/", httpRootHandler) err = http.ListenAndServe(fmt.Sprintf(":%v", Config.Port), nil) @@ -64,5 +80,28 @@ func httpRootHandler(w http.ResponseWriter, r *http.Request) { var p page p.Title = "Millics" t.Execute(w, p) - +} + +func initDB() { + // TODO: init DB + return +} + +func fetchLoadMinutely(t time.Time) { + file, err := os.Open("/proc/loadavg") + if err != nil { + fmt.Printf("Error fetching load: %v\n", err) + return + } + defer file.Close() + + var lavg1, lavg5, lavg15 float32 + ret, err := fmt.Fscanf(file, "%f %f %f", &lavg1, &lavg5, &lavg15) + if err != nil || ret != 3 { + fmt.Printf("Can't parse /proc/loadavg: %v\n", err) + return + } + + fmt.Printf("sysLoad %v: %v/%v/%v\n", t, lavg1, lavg5, lavg15) + return }