prometheus

Documentation

Index

• type PromMetadataResponse
• type PromMetricInfo
• type PromMetricSeriesResponse
  • func (p *PromMetricSeriesResponse) Error() string
  • func (p *PromMetricSeriesResponse) IsSuccessResponse() bool
• type Prometheus
  • func New(c datasource.MetricConfig, logger log.Logger) *Prometheus
  • func (p *Prometheus) GetScrapeInterval() time.Duration
  • func (p *Prometheus) Metadata(ctx context.Context) (<-chan *datasource.MetricMetadata, error)
  • func (p *Prometheus) Proxy(ctx transporthttp.Context, target string) error
  • func (p *Prometheus) Query(ctx context.Context, req *datasource.MetricQueryRequest) (*datasource.MetricQueryResponse, error)

Types

type PromMetadataResponse

type PromMetadataResponse struct {
	Status string                      `json:"status"`
	Data   map[string][]PromMetricInfo `json:"data"`
}

type PromMetricInfo

type PromMetricInfo struct {
	Type string `json:"type"`
	Help string `json:"help"`
	Unit string `json:"unit"`
}

type PromMetricSeriesResponse

type PromMetricSeriesResponse struct {
	Status    string              `json:"status"`
	Data      []map[string]string `json:"data"`
	Err       string              `json:"error"`
	ErrorType string              `json:"errorType"`
}

func (*PromMetricSeriesResponse) Error

func (p *PromMetricSeriesResponse) Error() string

Error is response error

func (*PromMetricSeriesResponse) IsSuccessResponse

func (p *PromMetricSeriesResponse) IsSuccessResponse() bool

IsSuccessResponse is response success

type Prometheus

type Prometheus struct {
	// contains filtered or unexported fields
}

func New

func New(c datasource.MetricConfig, logger log.Logger) *Prometheus

func (*Prometheus) GetScrapeInterval

func (p *Prometheus) GetScrapeInterval() time.Duration

func (*Prometheus) Metadata

func (p *Prometheus) Metadata(ctx context.Context) (<-chan *datasource.MetricMetadata, error)

func (*Prometheus) Proxy

func (p *Prometheus) Proxy(ctx transporthttp.Context, target string) error

Proxy implements datasource.Metric.

func (*Prometheus) Query

func (p *Prometheus) Query(ctx context.Context, req *datasource.MetricQueryRequest) (*datasource.MetricQueryResponse, error)