prometheus_loop.go

package main

import (
	"context"
	"log"
	"time"

	"github.com/govau/cloud.gov.au/www"
)

func prometheusLoop(
	ctx context.Context,
	pollFrequency time.Duration,
	prom *www.CachingPrometheus,
	qs map[string]string,
) {
	work := func() {
		for _, q := range qs {
			go func(q string) {
				log.Println("Querying prometheus...")
				_, err := prom.Query(ctx, q, time.Now())
				if err != nil {
					log.Println(err)
				}
			}(q)
		}
	}
	work()
	for {
		select {
		case <-time.After(pollFrequency):
			work()
		}
	}
}