metrics

type Callback interface {
	// Name identifies the monitor test
	Name() string

	// StartSeries is invoked when the metrics analyzer discovers a new series
	StartSeries(metric prometheustypes.Metric)

	// NewInterval is invoked when the metrics analyzer discovers a new interval
	NewInterval(metric prometheustypes.Metric, from, to *prometheustypes.SamplePair)

	// EndSeries is invoked when the metrics reaches the end of the given series
	EndSeries()
}

type PrometheusQueryRunner struct {
	Client      prometheusv1.API
	QueryString string
	Step        time.Duration
}

type QueryRunner interface {
	RunQuery(ctx context.Context, from, to time.Time) (prometheustypes.Value, error)
}

type RateSeriesAnalyzer struct{}

type SeriesAnalyzer interface {
	Analyze(ctx context.Context, query QueryRunner, start, end time.Time, callback Callback) error
}