prometheus

Documentation

Overview

Package prometheus contains the implementation of Prometheus (monitoring system and time series database) based data source

Index

• Variables
• func NewDataSource(retrierSet *retry.RetrierSet, cfg *config.TPrometheusConfig, ...) datasource.DataSource[any]
• type CloseFunc
• type PromQLBuilder
  • func NewPromQLBuilder(logger *zap.Logger) PromQLBuilder
  • func (p PromQLBuilder) From(from string) PromQLBuilder
  • func (p PromQLBuilder) ToQuery() (*prompb.Query, error)
  • func (p PromQLBuilder) WithEndTime(end time.Time) PromQLBuilder
  • func (p PromQLBuilder) WithStartTime(start time.Time) PromQLBuilder
  • func (p PromQLBuilder) WithYdbWhere(where *protos.TSelect_TWhere, filtering protos.TReadSplitsRequest_EFiltering) (PromQLBuilder, error)
• type ReadClient
  • func NewReadClient(dsi *api_common.TGenericDataSourceInstance, cfg *config.TPrometheusConfig) (*ReadClient, error)
  • func (rc *ReadClient) Read(ctx context.Context, pbQuery *prompb.Query) (storage.SeriesSet, CloseFunc, error)
  • func (rc *ReadClient) Schema(ctx context.Context, metric string) ([]*Ydb.Column, error)

Variables

var (
	ErrEmptyTimeSeries = errors.New("empty time series")
)

Functions

func NewDataSource

func NewDataSource(retrierSet *retry.RetrierSet, cfg *config.TPrometheusConfig, cc conversion.Collection) datasource.DataSource[any]

Types

type CloseFunc

type CloseFunc func()

type PromQLBuilder

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

func NewPromQLBuilder

func NewPromQLBuilder(logger *zap.Logger) PromQLBuilder

func (PromQLBuilder) From

func (p PromQLBuilder) From(from string) PromQLBuilder

func (PromQLBuilder) ToQuery

func (p PromQLBuilder) ToQuery() (*prompb.Query, error)

func (PromQLBuilder) WithEndTime

func (p PromQLBuilder) WithEndTime(end time.Time) PromQLBuilder

func (PromQLBuilder) WithStartTime

func (p PromQLBuilder) WithStartTime(start time.Time) PromQLBuilder

func (PromQLBuilder) WithYdbWhere

func (p PromQLBuilder) WithYdbWhere(where *protos.TSelect_TWhere, filtering protos.TReadSplitsRequest_EFiltering) (PromQLBuilder, error)

type ReadClient

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

func NewReadClient

func NewReadClient(dsi *api_common.TGenericDataSourceInstance, cfg *config.TPrometheusConfig) (*ReadClient, error)

func (*ReadClient) Read

func (rc *ReadClient) Read(ctx context.Context, pbQuery *prompb.Query) (storage.SeriesSet, CloseFunc, error)

func (*ReadClient) Schema

func (rc *ReadClient) Schema(ctx context.Context, metric string) ([]*Ydb.Column, error)