Documentation
¶
Index ¶
- Constants
- type Aggregator
- type AggregatorConverter
- type AggregatorConverterImpl
- type AggregatorParameter
- type AlignmentParameterConverter
- type AnyParameterConverter
- type GroupBy
- type GroupByConverter
- type GroupByConverterImpl
- type KairosDBClient
- type KairosDBDatasource
- type MetricQuery
- type MetricQueryConverter
- type MetricQueryConverterImpl
- type MetricRequest
- type ParameterConverter
- type SamplingParameterConverter
- type StringParameterConverter
Constants ¶
View Source
const ( MILLISECONDS = "milliseconds" SECONDS = "seconds" MINUTES = "minutes" HOURS = "hours" DAYS = "days" WEEKS = "weeks" MONTHS = "months" YEARS = "years" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Aggregator ¶
type Aggregator struct {
Name string `json:"name"`
Parameters []*AggregatorParameter `json:"parameters"`
}
type AggregatorConverter ¶
type AggregatorConverter interface {
Convert(aggregator *Aggregator) (map[string]interface{}, error)
}
type AggregatorConverterImpl ¶
type AggregatorConverterImpl struct {
// contains filtered or unexported fields
}
func NewAggregatorConverterImpl ¶
func NewAggregatorConverterImpl(paramConverterMappings map[string]ParameterConverter) *AggregatorConverterImpl
func (*AggregatorConverterImpl) Convert ¶
func (c *AggregatorConverterImpl) Convert(aggregator *Aggregator) (map[string]interface{}, error)
type AggregatorParameter ¶
type AlignmentParameterConverter ¶
type AlignmentParameterConverter struct{}
func (*AlignmentParameterConverter) Convert ¶
func (c *AlignmentParameterConverter) Convert(param *AggregatorParameter) (map[string]interface{}, error)
type AnyParameterConverter ¶
type AnyParameterConverter struct{}
func (*AnyParameterConverter) Convert ¶
func (c *AnyParameterConverter) Convert(param *AggregatorParameter) (map[string]interface{}, error)
type GroupByConverter ¶
type GroupByConverterImpl ¶
type GroupByConverterImpl struct{}
type KairosDBClient ¶
type KairosDBClient interface {
QueryMetrics(ctx context.Context, dsInfo *datasource.DatasourceInfo, request *remote.MetricQueryRequest) ([]*remote.MetricQueryResults, error)
}
type KairosDBDatasource ¶
type KairosDBDatasource struct {
plugin.NetRPCUnsupportedPlugin
// contains filtered or unexported fields
}
func NewKairosDBDatasource ¶
func NewKairosDBDatasource(client KairosDBClient, converter MetricQueryConverter) *KairosDBDatasource
func (*KairosDBDatasource) ParseQueryResult ¶
func (ds *KairosDBDatasource) ParseQueryResult(results *remote.MetricQueryResults) *datasource.QueryResult
func (*KairosDBDatasource) Query ¶
func (ds *KairosDBDatasource) Query(ctx context.Context, dsRequest *datasource.DatasourceRequest) (*datasource.DatasourceResponse, error)
type MetricQuery ¶
type MetricQuery struct {
Name string `json:"metricName"`
Aggregators []*Aggregator `json:"aggregators"`
GroupBy *GroupBy `json:"groupBy"`
Tags map[string][]string `json:"tags"`
}
type MetricQueryConverter ¶
type MetricQueryConverter interface {
Convert(query *MetricQuery) (*remote.MetricQuery, error)
}
type MetricQueryConverterImpl ¶
type MetricQueryConverterImpl struct {
// contains filtered or unexported fields
}
func NewMetricQueryConverterImpl ¶
func NewMetricQueryConverterImpl(aggregatorConverter AggregatorConverter, groupByConverter GroupByConverter) *MetricQueryConverterImpl
func (*MetricQueryConverterImpl) Convert ¶
func (c *MetricQueryConverterImpl) Convert(query *MetricQuery) (*remote.MetricQuery, error)
type MetricRequest ¶
type MetricRequest struct {
Query *MetricQuery `json:"query"`
RefID string `json:"refId"`
}
type ParameterConverter ¶
type ParameterConverter interface {
Convert(param *AggregatorParameter) (map[string]interface{}, error)
}
type SamplingParameterConverter ¶
type SamplingParameterConverter struct{}
func (*SamplingParameterConverter) Convert ¶
func (c *SamplingParameterConverter) Convert(param *AggregatorParameter) (map[string]interface{}, error)
type StringParameterConverter ¶
type StringParameterConverter struct{}
func (*StringParameterConverter) Convert ¶
func (c *StringParameterConverter) Convert(param *AggregatorParameter) (map[string]interface{}, error)
Directories
¶
| Path | Synopsis |
|---|---|
|
internal
|
|
|
mock_datasource
Package mock_datasource is a generated GoMock package.
|
Package mock_datasource is a generated GoMock package. |
Click to show internal directories.
Click to hide internal directories.