add alerts as event intervals for viewing

pkg/monitor/alerts.go

@@ -1 +1,50 @@
 package monitor
+
+import (
+	"context"
+	"fmt"
+	"strings"
+	"time"
+
+	routeclient "github.com/openshift/client-go/route/clientset/versioned"
+	"github.com/openshift/library-go/test/library/metrics"
+	"github.com/openshift/origin/pkg/monitor/monitorapi"
+	prometheusv1 "github.com/prometheus/client_golang/api/prometheus/v1"
+	"k8s.io/client-go/kubernetes"
+	"k8s.io/client-go/rest"
+)
+
+func CreateEventIntervalsForAlerts(ctx context.Context, restConfig *rest.Config, startTime time.Time) ([]monitorapi.EventInterval, error) {
+	kubeClient, err := kubernetes.NewForConfig(restConfig)
+	if err != nil {
+		return nil, err
+	}
+	routeClient, err := routeclient.NewForConfig(restConfig)
+	if err != nil {
+		return nil, err
+	}
+	prometheusClient, err := metrics.NewPrometheusClient(ctx, kubeClient, routeClient)
+	if err != nil {
+		return nil, err
+	}
+
+	timeRange := prometheusv1.Range{
+		Start: startTime,
+		End:   time.Now(),
+		Step:  1 * time.Second,
+	}
+	alerts, warningsForQuery, err := prometheusClient.QueryRange(ctx, `ALERTS{alertstate="firing"}`, timeRange)
+	if err != nil {
+		return nil, err
+	}
+	if len(warningsForQuery) > 0 {
+		fmt.Printf("#### warnings \n\t%v\n", strings.Join(warningsForQuery, "\n\t"))
+	}
+
+	fmt.Printf("\n\n\n#### alertType=%v\n", alerts.Type())
+	fmt.Printf("\n\n\n#### alerts=%v\n\n\n", alerts.String())
+
+	ret := []monitorapi.EventInterval{}
+
+	return ret, nil
+}

pkg/test/ginkgo/cmd_runsuite.go

@@ -367,6 +367,15 @@ func (opt *Options) Run(suite *TestSuite) error {
 			sort.Sort(events)
 		}
 	}
+
+	// add events from alerts so we can create the intervals
+	alertEventIntervals, err := monitor.CreateEventIntervalsForAlerts(ctx, restConfig, start)
+	if err != nil {
+		fmt.Printf("\n\n\n#### alertErr=%v\n", err)
+	}
+	events = append(events, alertEventIntervals...)
+	sort.Sort(events)
+
 	events.Clamp(start, end)
 
 	if len(opt.JUnitDir) > 0 {