K8s events (#248)

* K8s events collected

* collect events

* collect events

Author: manavellamnimble

pkg/collect/cluster_resources.go

@@ -163,6 +163,16 @@ func ClusterResources(c *Collector) (map[string][]byte, error) {
 		return nil, err
 	}
 
+	//Events
+	events, eventsErrors := events(ctx, client, namespaceNames)
+	for k, v := range events {
+		clusterResourcesOutput[path.Join("cluster-resources/events", k)] = v
+	}
+	clusterResourcesOutput["cluster-resources/events-errors.json"], err = marshalNonNil(eventsErrors)
+	if err != nil {
+		return nil, err
+	}
+
 	return clusterResourcesOutput, nil
 }
 
@@ -478,6 +488,29 @@ func authCanI(ctx context.Context, client *kubernetes.Clientset, namespaces []st
 	return authListByNamespace, errorsByNamespace
 }
 
+func events(ctx context.Context, client *kubernetes.Clientset, namespaces []string) (map[string][]byte, map[string]string) {
+	eventsByNamespace := make(map[string][]byte)
+	errorsByNamespace := make(map[string]string)
+
+	for _, namespace := range namespaces {
+		events, err := client.CoreV1().Events(namespace).List(ctx, metav1.ListOptions{})
+		if err != nil {
+			errorsByNamespace[namespace] = err.Error()
+			continue
+		}
+
+		b, err := json.MarshalIndent(events.Items, "", "  ")
+		if err != nil {
+			errorsByNamespace[namespace] = err.Error()
+			continue
+		}
+
+		eventsByNamespace[namespace+".json"] = b
+	}
+
+	return eventsByNamespace, errorsByNamespace
+}
+
 // not exprted from: https://github.com/kubernetes/kubernetes/blob/master/pkg/kubectl/cmd/auth/cani.go#L339
 func convertToPolicyRule(status authorizationv1.SubjectRulesReviewStatus) []rbacv1.PolicyRule {
 	ret := []rbacv1.PolicyRule{}