prom

Documentation

Index

• Constants
• func ComputeWindowShards(window *promapiv1.Range, maxPointsLimitPerTimeSeries int) []*promapiv1.Range
• func MergeSortedTimeSeries(ts1, ts2 *common.TimeSeries) *common.TimeSeries
• func NewContext(client prometheus.Client, maxPointsPerTimeSeries int) *context
• func NewContextByAPI(api promapiv1.API, maxPointsPerTimeSeries int) *context
• func NewPrometheusClient(config *providers.PromConfig) (prometheus.Client, error)
• type FlowControlRuntime
  • func (fcr *FlowControlRuntime) String() string
• type Provider
  • func NewProvider(config *providers.PromConfig) (Provider, error)
• type QueryShardResult
• type QueryShards

Constants

const (
	PrometheusClientID = "prom"
	// max number of points each time series of prometheus
	PrometheusPointsLimitPerTimeSeries = 11000
)

Functions

func ComputeWindowShards

func ComputeWindowShards(window *promapiv1.Range, maxPointsLimitPerTimeSeries int) []*promapiv1.Range

func MergeSortedTimeSeries

func MergeSortedTimeSeries(ts1, ts2 *common.TimeSeries) *common.TimeSeries

func NewContext

func NewContext(client prometheus.Client, maxPointsPerTimeSeries int) *context

NewContext creates a new Prometheus querying context from the given client.

func NewContextByAPI

func NewContextByAPI(api promapiv1.API, maxPointsPerTimeSeries int) *context

Test use

func NewPrometheusClient

func NewPrometheusClient(config *providers.PromConfig) (prometheus.Client, error)

NewPrometheusClient returns a prometheus.Client

Types

type FlowControlRuntime

type FlowControlRuntime struct {
	// Current InfFight limit.
	InFightLimit int
	// Current InfFight requests.
	InFight int
}

func (*FlowControlRuntime) String

func (fcr *FlowControlRuntime) String() string

type Provider

type Provider interface {
	providers.Interface

	GetPromClient() promapiv1.API
}

func NewProvider

func NewProvider(config *providers.PromConfig) (Provider, error)

NewProvider return a prometheus data provider

type QueryShardResult

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

type QueryShards

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

shard by time slice only, because we can not decide what the query is, how many time series it will return, it depends on the application level.