Print sysload minutely

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
 }