adding system cpu and memory metrics

Author: sudhirbitsgoa

cache/redis.go

@@ -0,0 +1,23 @@
+package cache
+
+import (
+	"fmt"
+
+	"gopkg.in/redis.v5"
+)
+
+var Client *redis.Client
+
+/**
+ * redis client
+ */
+func RedisConnect() {
+	Client = redis.NewClient(&redis.Options{
+		Addr:     "localhost:6379",
+		Password: "", // no password set
+		DB:       0,  // use default DB
+	})
+
+	pong, err := Client.Ping().Result()
+	fmt.Println(pong, err)
+}

debug

@@ -8,16 +8,21 @@ import (
 	//
 	//    sw "github.com/myname/myrepo/go"
 	//
+
 	"log"
 	"net/http"
 
+	cache "server/cache"
 	sw "server/mylib"
+	sy "server/system"
 )
 
 func main() {
 	log.Printf("Server started")
 
 	router := sw.NewRouter()
-
+	sy.Iterator()
+	sy.CPUIterator()
+	cache.RedisConnect()
 	log.Fatal(http.ListenAndServe(":8080", router))
 }

main.go

@@ -0,0 +1,29 @@
+package system
+
+import (
+	"fmt"
+	"time"
+
+	"github.com/shirou/gopsutil/cpu"
+)
+
+/**
+  This will read system memory
+**/
+func readcpu() []float64 {
+	v, _ := cpu.Percent(0, false)
+
+	// almost every return value is a struct
+	// fmt.Printf("Total: %v, Free:%v, UsedPercent:%f%%\n", v., v.Free, v.UsedPercent)
+
+	// convert to JSON. String() is also implemented
+	// fmt.Println("this is cool", v)
+	return v
+}
+
+func CPUIterator() {
+	c := time.Tick(time.Second)
+	for now := range c {
+		fmt.Println(now, readcpu())
+	}
+}

system/cpu.go

@@ -0,0 +1,29 @@
+package system
+
+import (
+	"fmt"
+	"time"
+
+	"github.com/shirou/gopsutil/mem"
+)
+
+/**
+  This will read system memory
+**/
+func readmemory() *mem.VirtualMemoryStat {
+	v, _ := mem.VirtualMemory()
+
+	// almost every return value is a struct
+	fmt.Printf("Total: %v, Free:%v, UsedPercent:%f%%\n", v.Total, v.Free, v.UsedPercent)
+
+	// convert to JSON. String() is also implemented
+	fmt.Println(v)
+	return v
+}
+
+func Iterator() {
+	c := time.Tick(time.Second)
+	for now := range c {
+		fmt.Print(now, readmemory())
+	}
+}