prom

Documentation

Index

• func FilterLabelsDropAll(name string) bool
• func FilterLabelsKeepAll(name string) bool
• type ClickHouse
  • func (c *ClickHouse) Close()
  • func (c *ClickHouse) GetStep(from, to timeseries.Time) (timeseries.Duration, error)
  • func (c *ClickHouse) LabelValues(r *http.Request, w http.ResponseWriter, labelName string)
  • func (c *ClickHouse) MetricMetadata(r *http.Request, w http.ResponseWriter)
  • func (c *ClickHouse) Ping(ctx context.Context) error
  • func (c *ClickHouse) Querier(mint, maxt int64) (storage.Querier, error)
  • func (c *ClickHouse) QueryRange(ctx context.Context, query string, filterLabels FilterLabelsF, ...) ([]*model.MetricValues, error)
  • func (c *ClickHouse) Series(r *http.Request, w http.ResponseWriter)
• type Client
  • func NewClient(promConfig *db.IntegrationPrometheus, ...) (Client, error)
• type FilterLabelsF
• type HttpClient
  • func (c *HttpClient) Close()
  • func (c *HttpClient) GetStep(from, to timeseries.Time) (timeseries.Duration, error)
  • func (c *HttpClient) LabelValues(r *http.Request, w http.ResponseWriter, labelName string)
  • func (c *HttpClient) MetricMetadata(r *http.Request, w http.ResponseWriter)
  • func (c *HttpClient) Ping(ctx context.Context) error
  • func (c *HttpClient) QueryRange(ctx context.Context, query string, filterLabels FilterLabelsF, ...) ([]*model.MetricValues, error)
  • func (c *HttpClient) Series(r *http.Request, w http.ResponseWriter)
• type PrometheusResponse

Functions

func FilterLabelsDropAll

func FilterLabelsDropAll(name string) bool

func FilterLabelsKeepAll

func FilterLabelsKeepAll(name string) bool

Types

type ClickHouse

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

func (*ClickHouse) Close

func (c *ClickHouse) Close()

func (*ClickHouse) GetStep

func (c *ClickHouse) GetStep(from, to timeseries.Time) (timeseries.Duration, error)

func (*ClickHouse) LabelValues

func (c *ClickHouse) LabelValues(r *http.Request, w http.ResponseWriter, labelName string)

func (*ClickHouse) MetricMetadata

func (c *ClickHouse) MetricMetadata(r *http.Request, w http.ResponseWriter)

func (*ClickHouse) Ping

func (c *ClickHouse) Ping(ctx context.Context) error

func (*ClickHouse) Querier

func (c *ClickHouse) Querier(mint, maxt int64) (storage.Querier, error)

func (*ClickHouse) QueryRange

func (c *ClickHouse) QueryRange(ctx context.Context, query string, filterLabels FilterLabelsF, from, to timeseries.Time, step timeseries.Duration) ([]*model.MetricValues, error)

func (*ClickHouse) Series

func (c *ClickHouse) Series(r *http.Request, w http.ResponseWriter)

type Client

type Client interface {
	Ping(ctx context.Context) error
	GetStep(from, to timeseries.Time) (timeseries.Duration, error)
	QueryRange(ctx context.Context, query string, filterLabels FilterLabelsF, from, to timeseries.Time, step timeseries.Duration) ([]*model.MetricValues, error)
	MetricMetadata(r *http.Request, w http.ResponseWriter)
	LabelValues(r *http.Request, w http.ResponseWriter, labelName string)
	Series(r *http.Request, w http.ResponseWriter)
	Close()
}

func NewClient

func NewClient(promConfig *db.IntegrationPrometheus, clickhouseConfig *db.IntegrationClickhouse) (Client, error)

type FilterLabelsF

type FilterLabelsF func(name string) bool

type HttpClient

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

func (*HttpClient) Close

func (c *HttpClient) Close()

func (*HttpClient) GetStep

func (c *HttpClient) GetStep(from, to timeseries.Time) (timeseries.Duration, error)

func (*HttpClient) LabelValues

func (c *HttpClient) LabelValues(r *http.Request, w http.ResponseWriter, labelName string)

func (*HttpClient) MetricMetadata

func (c *HttpClient) MetricMetadata(r *http.Request, w http.ResponseWriter)

func (*HttpClient) Ping

func (c *HttpClient) Ping(ctx context.Context) error

func (*HttpClient) QueryRange

func (c *HttpClient) QueryRange(ctx context.Context, query string, filterLabels FilterLabelsF, from, to timeseries.Time, step timeseries.Duration) ([]*model.MetricValues, error)

func (*HttpClient) Series

func (c *HttpClient) Series(r *http.Request, w http.ResponseWriter)

type PrometheusResponse

type PrometheusResponse struct {
	Status    string      `json:"status"`
	Data      interface{} `json:"data,omitempty"`
	ErrorType errorType   `json:"errorType,omitempty"`
	Error     string      `json:"error,omitempty"`
	Warnings  []string    `json:"warnings,omitempty"`
	Infos     []string    `json:"infos,omitempty"`
}