| /dports/net-mgmt/prometheus2/prometheus-2.30.3/rules/ |
| H A D | alerting.go | 225 func (r *AlertingRule) sample(alert *Alert, ts time.Time) promql.Sample {
236 s := promql.Sample{
238 Point: promql.Point{T: timestamp.FromTime(ts), V: 1},
244 func (r *AlertingRule) forStateSample(alert *Alert, ts time.Time, v float64) promql.Sample {
254 s := promql.Sample{
256 Point: promql.Point{T: timestamp.FromTime(ts), V: v},
300 …(ctx context.Context, ts time.Time, query QueryFunc, externalURL *url.URL) (promql.Vector, error) {
313 var vec promql.Vector
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/loki/vendor/github.com/prometheus/prometheus/rules/ |
| H A D | alerting.go | 225 func (r *AlertingRule) sample(alert *Alert, ts time.Time) promql.Sample {
236 s := promql.Sample{
238 Point: promql.Point{T: timestamp.FromTime(ts), V: 1},
244 func (r *AlertingRule) forStateSample(alert *Alert, ts time.Time, v float64) promql.Sample {
254 s := promql.Sample{
256 Point: promql.Point{T: timestamp.FromTime(ts), V: v},
300 …t.Context, ts time.Time, query QueryFunc, externalURL *url.URL, limit int) (promql.Vector, error) {
313 var vec promql.Vector
|
| /dports/net-mgmt/thanos/thanos-0.11.0/vendor/github.com/prometheus/prometheus/rules/ |
| H A D | recording.go | 35 vector promql.Expr
50 func NewRecordingRule(name string, vector promql.Expr, lset labels.Labels) *RecordingRule {
65 func (rule *RecordingRule) Query() promql.Expr {
75 …Rule) Eval(ctx context.Context, ts time.Time, query QueryFunc, _ *url.URL) (promql.Vector, error) {
|
| H A D | manager.go | 158 type QueryFunc func(ctx context.Context, q string, t time.Time) (promql.Vector, error)
163 func EngineQueryFunc(engine *promql.Engine, q storage.Queryable) QueryFunc {
164 return func(ctx context.Context, qs string, t time.Time) (promql.Vector, error) {
174 case promql.Vector:
176 case promql.Scalar:
177 return promql.Vector{promql.Sample{
178 Point: promql.Point(v),
194 Eval(context.Context, time.Time, QueryFunc, *url.URL) (promql.Vector, error)
290 ctx = promql.NewOriginContext(ctx, map[string]string{
529 if _, ok := err.(promql.ErrQueryCanceled); !ok {
[all …]
|
| /dports/net-mgmt/bosun/bosun-0.9.0-preview/vendor/github.com/prometheus/prometheus/rules/ |
| H A D | manager.go | 122 type QueryFunc func(ctx context.Context, q string, t time.Time) (promql.Vector, error)
127 func EngineQueryFunc(engine *promql.Engine, q storage.Queryable) QueryFunc {
128 return func(ctx context.Context, qs string, t time.Time) (promql.Vector, error) {
138 case promql.Vector:
140 case promql.Scalar:
141 return promql.Vector{promql.Sample{
142 Point: promql.Point(v),
156 Eval(context.Context, time.Time, QueryFunc, *url.URL) (promql.Vector, error)
413 if _, ok := err.(promql.ErrQueryCanceled); !ok {
746 expr, err := promql.ParseExpr(r.Expr)
|
| /dports/net-mgmt/promscale/promscale-0.6.2/vendor/github.com/prometheus/prometheus/cmd/promtool/ |
| H A D | unittest.go | 156 suite, err := promql.NewLazyLoader(nil, tg.seriesLoadingString())
449 …(ctx context.Context, qs string, t time.Time, engine *promql.Engine, qu storage.Queryable) (promql…
459 case promql.Vector:
461 case promql.Scalar:
462 return promql.Vector{promql.Sample{
463 Point: promql.Point(v),
|
| /dports/net-mgmt/promscale/promscale-0.6.2/vendor/github.com/thanos-io/thanos/cmd/thanos/ |
| H A D | query.go | 435 engineOpts = promql.EngineOpts{
566 engineFactory(promql.NewEngine, engineOpts, dynamicLookbackDelta),
681 newEngine func(promql.EngineOpts) *promql.Engine,
682 eo promql.EngineOpts,
684 ) func(int64) *promql.Engine {
690 engines = make([]*promql.Engine, len(resolutions))
702 engines[i] = newEngine(promql.EngineOpts{
712 return func(maxSourceResolutionMillis int64) *promql.Engine {
|
| /dports/net-mgmt/prometheus1/prometheus-1.8.2/cmd/prometheus/ |
| H A D | config.go | 52 queryEngine promql.EngineOptions
255 &promql.StalenessDelta, "query.staleness-delta", promql.StalenessDelta,
283 if promql.StalenessDelta < 0 {
284 return fmt.Errorf("negative staleness delta: %s", promql.StalenessDelta)
288 cfg.storage.HeadChunkTimeout = promql.StalenessDelta
|
| /dports/net-mgmt/prometheus1/prometheus-1.8.2/rules/ |
| H A D | manager.go | 116 Eval(context.Context, model.Time, *promql.Engine, *url.URL) (model.Vector, error)
281 if _, ok := err.(promql.ErrQueryCanceled); !ok {
361 QueryEngine *promql.Engine
467 stmts, err := promql.ParseStmts(string(content))
476 case *promql.AlertStmt:
479 case *promql.RecordStmt:
|
| /dports/databases/prometheus-postgresql-adapter/prometheus-postgresql-adapter-0.6.0/vendor/github.com/prometheus/prometheus/rules/ |
| H A D | manager.go | 159 type QueryFunc func(ctx context.Context, q string, t time.Time) (promql.Vector, error)
164 func EngineQueryFunc(engine *promql.Engine, q storage.Queryable) QueryFunc {
165 return func(ctx context.Context, qs string, t time.Time) (promql.Vector, error) {
175 case promql.Vector:
177 case promql.Scalar:
178 return promql.Vector{promql.Sample{
179 Point: promql.Point(v),
195 Eval(context.Context, time.Time, QueryFunc, *url.URL) (promql.Vector, error)
512 if _, ok := err.(promql.ErrQueryCanceled); !ok {
860 expr, err := promql.ParseExpr(r.Expr)
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/cortexproject/cortex/pkg/querier/ |
| H A D | querier_benchmark_test.go | 10 var result *promql.Result
20 var r *promql.Result
|
| H A D | chunk_tar_test.go | 58 queryTracker := promql.NewActiveQueryTracker(dir, 1, log.NewNopLogger())
64 engine := promql.NewEngine(promql.EngineOpts{
|
| H A D | querier_test.go | 266 queryTracker := promql.NewActiveQueryTracker(dir, 10, log.NewNopLogger())
268 engine := promql.NewEngine(promql.EngineOpts{
350 engine := promql.NewEngine(promql.EngineOpts{
454 engine := promql.NewEngine(promql.EngineOpts{
546 engine := promql.NewEngine(promql.EngineOpts{
733 func testRangeQuery(t testing.TB, queryable storage.Queryable, end model.Time, q query) *promql.Res…
737 queryTracker := promql.NewActiveQueryTracker(dir, 10, log.NewNopLogger())
740 engine := promql.NewEngine(promql.EngineOpts{
884 queryTracker := promql.NewActiveQueryTracker(dir, 10, log.NewNopLogger())
886 engine := promql.NewEngine(promql.EngineOpts{
|
| /dports/net-mgmt/thanos/thanos-0.11.0/pkg/promclient/ |
| H A D | promclient.go | 380 case promql.ValueTypeVector:
384 case promql.ValueTypeScalar:
408 …t.Context, base *url.URL, query string, t time.Time, opts QueryOptions) (promql.Vector, []string, …
414 vec := make(promql.Vector, 0, len(vectorResult))
427 vec = append(vec, promql.Sample{
429 Point: promql.Point{T: int64(e.Timestamp), V: float64(e.Value)},
437 …og.Logger, base *url.URL, query string, t time.Time, opts QueryOptions) (promql.Vector, []string, …
|
| /dports/net-mgmt/promscale/promscale-0.6.2/pkg/api/ |
| H A D | common.go | 166 func setResponseHeaders(w http.ResponseWriter, samples *promql.Result, isExemplar bool, warnings st…
183 func respondQuery(w http.ResponseWriter, res *promql.Result, warnings storage.Warnings) {
186 case promql.Vector:
192 case promql.Matrix:
281 func marshalMatrixResponse(writer io.Writer, data promql.Matrix, warnings []string) error {
|
| H A D | marshal.go | 20 func marshalVectorResponse(writer io.Writer, data promql.Vector, warnings []string) error {
62 func marshalMatrixData(out *errorWrapper, data promql.Matrix) {
129 func marshalVectorData(out *errorWrapper, data promql.Vector) {
|
| H A D | query_exemplar.go | 19 func QueryExemplar(conf *Config, queryable promql.Queryable, metrics *Metrics) http.Handler {
24 func queryExemplar(queryable promql.Queryable, metrics *Metrics) http.HandlerFunc {
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/loki/pkg/logql/ |
| H A D | sharding.go | 336 func() (ok bool, ts int64, vec promql.Vector) {
337 var cur promql.Vector
380 case promql.Vector:
382 return newStepEvaluator(func() (bool, int64, promql.Vector) {
389 case promql.Matrix:
|
| H A D | sharding_test.go | 93 approximatelyEquals(t, res.Data.(promql.Matrix), shardedRes.Data.(promql.Matrix))
102 func approximatelyEquals(t *testing.T, as, bs promql.Matrix) {
|
| /dports/net-mgmt/promscale/promscale-0.6.2/vendor/github.com/prometheus/prometheus/web/ |
| H A D | federate.go | 92 vec := make(promql.Vector, 0, 8000)
131 vec = append(vec, promql.Sample{
133 Point: promql.Point{T: t, V: v},
236 type byName promql.Vector
|
| /dports/net-mgmt/prometheus2/prometheus-2.30.3/web/ |
| H A D | federate.go | 92 vec := make(promql.Vector, 0, 8000)
131 vec = append(vec, promql.Sample{
133 Point: promql.Point{T: t, V: v},
236 type byName promql.Vector
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/prometheus/prometheus/web/ |
| H A D | federate.go | 92 vec := make(promql.Vector, 0, 8000)
131 vec = append(vec, promql.Sample{
133 Point: promql.Point{T: t, V: v},
236 type byName promql.Vector
|
| /dports/net-mgmt/promscale/promscale-0.6.2/docs/ |
| H A D | cli.md | 89 …promql-enable-feature | string | "" | [EXPERIMENTAL] Enable optional PromQL features, separated by…
90 | promql-query-timeout | duration | 2 minutes | Maximum time a query may take before being aborted.…
91 | promql-default-subquery-step-interval | duration | 1 minute | Default step interval to be used fo…
92 | promql-lookback-delta | duration | 5 minute | The maximum look-back duration for retrieving metri…
93 | promql-max-samples | integer64 | 50000000 | Maximum number of samples a single query can load int…
94 | promql-max-points-per-ts | integer64 | 11000 | Maximum number of points per time-series in a que…
|
| /dports/net-mgmt/promscale/promscale-0.6.2/vendor/github.com/thanos-io/thanos/pkg/rules/ |
| H A D | manager_test.go | 83 return func(ctx context.Context, q string, t time.Time) (vectors promql.Vector, e error) {
88 return promql.Vector{}, nil
180 return func(ctx context.Context, q string, t time.Time) (promql.Vector, error) {
326 return func(ctx context.Context, q string, t time.Time) (promql.Vector, error) {
367 return func(ctx context.Context, q string, t time.Time) (promql.Vector, error) {
|
| /dports/net-mgmt/promscale/promscale-0.6.2/pkg/query/ |
| H A D | queryable.go | 18 func NewQueryable(q pgQuerier.Querier, labelsReader lreader.LabelsReader) promql.Queryable {
39 func (q queryable) SamplesQuerier(ctx context.Context, mint, maxt int64) (promql.SamplesQuerier, er…
|