history

Documentation

Index

• Constants
• type HistoryProvider
• type PrometheusHistoryProvider
  • func NewPrometheusHistoryProvider(config PrometheusHistoryProviderConfig) (provider PrometheusHistoryProvider, err error)
  • func (p *PrometheusHistoryProvider) AddPromethuesModelToHistoryMetric(promeValue promethuesmodel.Value, metricHistoryMetric *metric.HistoryMetric)
  • func (p *PrometheusHistoryProvider) Query(ctx context.Context, expression string) (metric.HistoryMetric, error)
  • func (p *PrometheusHistoryProvider) QueryRange(ctx context.Context, expression string, duration time.Duration) (metric.HistoryMetric, error)
• type PrometheusHistoryProviderConfig

Constants

const (
	DEFAULT_MAX_QUERY_SIZE = 1 << 20
)

Types

type HistoryProvider

type HistoryProvider interface {
	Query(ctx context.Context, expression string) (metric.HistoryMetric, error)
	QueryRange(ctx context.Context, expression string, duration time.Duration) (metric.HistoryMetric, error)
}

type PrometheusHistoryProvider

type PrometheusHistoryProvider struct {
	ClientAPI    prometheusv1.API
	QueryStep    time.Duration
	QueryMaxSize int
}

func NewPrometheusHistoryProvider

func NewPrometheusHistoryProvider(config PrometheusHistoryProviderConfig) (provider PrometheusHistoryProvider, err error)

func (*PrometheusHistoryProvider) AddPromethuesModelToHistoryMetric

func (p *PrometheusHistoryProvider) AddPromethuesModelToHistoryMetric(promeValue promethuesmodel.Value, metricHistoryMetric *metric.HistoryMetric)

func (*PrometheusHistoryProvider) Query

func (p *PrometheusHistoryProvider) Query(ctx context.Context, expression string) (metric.HistoryMetric, error)

can

func (*PrometheusHistoryProvider) QueryRange

func (p *PrometheusHistoryProvider) QueryRange(ctx context.Context, expression string, duration time.Duration) (metric.HistoryMetric, error)

type PrometheusHistoryProviderConfig

type PrometheusHistoryProviderConfig struct {
	Address      string
	QueryTimeout time.Duration
	QueryStep    time.Duration
}