add slack and improve hpa

alerts/slack.go

@@ -0,0 +1,21 @@
+package alerts
+
+import (
+	"os"
+
+	"github.com/bluele/slack"
+)
+
+var (
+	token       = os.Getenv("SLACK_API_TOKEN")
+	channelName = os.Getenv("SLACK_CHANNEL")
+)
+
+func main() {
+
+	api := slack.New(token)
+	err := api.ChatPostMessage(channelName, "Hello, world!", nil)
+	if err != nil {
+		panic(err)
+	}
+}

checks/hpa.go

@@ -5,6 +5,7 @@ import (
 
 	"k8s.io/api/autoscaling/v1"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+	"k8s.io/apimachinery/pkg/watch"
 	"k8s.io/client-go/kubernetes"
 	"k8s.io/client-go/rest"
 )
@@ -29,17 +30,24 @@ func HPA() {
 
 	hpaWatch, _ := clientset.AutoscalingV1().HorizontalPodAutoscalers("").Watch(metav1.ListOptions{})
 
-	data := <-hpaWatch.ResultChan()
+	for {
+		select {
+		case event := <-hpaWatch.ResultChan():
+			handleEventz(event)
+		}
+	}
+}
 
-	hpa := data.Object.(*v1.HorizontalPodAutoscaler)
+func handleEventz(event watch.Event) {
+	hpa := event.Object.(*v1.HorizontalPodAutoscaler)
 
 	if hpa.Status.CurrentReplicas > hpa.Status.DesiredReplicas {
 		fmt.Println(hpa.ObjectMeta.Namespace + " is scaling DOWN")
 		fmt.Println("Current VS Desired Replicas: ", hpa.Status.CurrentReplicas, hpa.Status.DesiredReplicas)
-		fmt.Println("Current CPU utilization: ", hpa.Status.CurrentCPUUtilizationPercentage)
+		fmt.Println("Current CPU utilization: ", *hpa.Status.CurrentCPUUtilizationPercentage)
 	} else if hpa.Status.CurrentReplicas < hpa.Status.DesiredReplicas {
 		fmt.Println(hpa.ObjectMeta.Namespace + " is scaling up")
 		fmt.Println("Current VS Desired Replicas: ", hpa.Status.CurrentReplicas, hpa.Status.DesiredReplicas)
-		fmt.Println("Current CPU utilization: ", hpa.Status.CurrentCPUUtilizationPercentage)
+		fmt.Println("Current CPU utilization: ", *hpa.Status.CurrentCPUUtilizationPercentage)
 	}
 }

main.go

@@ -12,11 +12,11 @@ func main() {
 	fmt.Println("starting kubieous...")
 
 	// How often should the checks be performed
-	podCheckTimer := time.NewTicker(30 * time.Second)
-	nodeCheckTimer := time.NewTicker(60 * time.Second)
-	hpaCheckTimer := time.NewTicker(5 * time.Second)
+	podCheckTimer := time.NewTicker(99999 * time.Second)
+	nodeCheckTimer := time.NewTicker(99999 * time.Second)
 
-	checks.PodEventStream()
+	// checks.PodEventStream()
+	go checks.HPA()
 
 	// Montoring Loop
 	for {
@@ -25,8 +25,8 @@ func main() {
 			go checks.Pods()
 		case _ = <-nodeCheckTimer.C:
 			go checks.Nodes()
-		case _ = <-hpaCheckTimer.C:
-			go checks.HPA()
 		}
 	}
+
+	fmt.Println("stopping kubieous")
 }