Versions in this module Expand all Collapse all v0 v0.3.0 May 6, 2022 Changes in this version + const PrometheusClientID + const PrometheusPointsLimitPerTimeSeries + 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 *datasource.PromConfig) (prometheus.Client, error) + func NewProvider(config *datasource.PromConfig) (datasource.Interface, error) + type FlowControlRuntime struct + InFight int + InFightLimit int + func (fcr *FlowControlRuntime) String() string + type QueryShardResult struct + type QueryShards struct + type ThanosConfig struct + Dedup bool + Partial bool