prom

package

v0.11.0 Latest Latest Go to latest Published: Jul 25, 2023 License: Apache-2.0, BSD-2-Clause Imports: 17 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

View Source

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

This section is empty.

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

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

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

Test use

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

NewPrometheusClient returns a prometheus.Client

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

func (fcr *FlowControlRuntime) String() string

type Provider interface {
	providers.Interface

	GetPromClient() promapiv1.API
}

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

NewProvider return a prometheus data provider

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

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.