datasource

package
v3.0.3-0...-dc8e22f Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 16, 2019 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

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 AggregatorParameter struct {
	Name  string `json:"name"`
	Text  string `json:"text"`
	Type  string `json:"type"`
	Value string `json:"value"`
}

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 GroupBy

type GroupBy struct {
	Tags []string `json:"tags"`
}

type GroupByConverter

type GroupByConverter interface {
	Convert(groupBy *GroupBy) ([]*remote.Grouper, error)
}

type GroupByConverterImpl

type GroupByConverterImpl struct{}

func (*GroupByConverterImpl) Convert

func (c *GroupByConverterImpl) Convert(groupBy *GroupBy) ([]*remote.Grouper, error)

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

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

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL