bergquist
34 lines
801 B
Go
34 lines
801 B
Go
package graphite
|
|
|
|
import (
|
|
"fmt"
|
|
|
|
"github.com/grafana/grafana/pkg/bus"
|
|
m "github.com/grafana/grafana/pkg/models"
|
|
)
|
|
|
|
// AlertDatasource is bacon
|
|
type AlertDatasource interface {
|
|
GetSeries(job *m.AlertJob, datasource m.DataSource) (m.TimeSeriesSlice, error)
|
|
}
|
|
|
|
// GetSeries returns timeseries data from the datasource
|
|
func GetSeries(job *m.AlertJob) (m.TimeSeriesSlice, error) {
|
|
query := &m.GetDataSourceByIdQuery{
|
|
Id: job.Rule.DatasourceId,
|
|
OrgId: job.Rule.OrgId,
|
|
}
|
|
|
|
err := bus.Dispatch(query)
|
|
|
|
if err != nil {
|
|
return nil, fmt.Errorf("Could not find datasource for %d", job.Rule.DatasourceId)
|
|
}
|
|
|
|
if query.Result.Type == m.DS_GRAPHITE {
|
|
return GraphiteClient{}.GetSeries(*job, query.Result)
|
|
}
|
|
|
|
return nil, fmt.Errorf("Grafana does not support alerts for %s", query.Result.Type)
|
|
}
|