mirror of https://github.com/prometheus/prometheus
commit
6453f64000
|
@ -8,10 +8,6 @@ import (
|
||||||
"golang.org/x/net/context"
|
"golang.org/x/net/context"
|
||||||
)
|
)
|
||||||
|
|
||||||
var noop = testStmt(func(context.Context) error {
|
|
||||||
return nil
|
|
||||||
})
|
|
||||||
|
|
||||||
func TestQueryConcurrency(t *testing.T) {
|
func TestQueryConcurrency(t *testing.T) {
|
||||||
engine := NewEngine(nil, nil)
|
engine := NewEngine(nil, nil)
|
||||||
defer engine.Stop()
|
defer engine.Stop()
|
||||||
|
|
|
@ -925,8 +925,6 @@ func (p *parser) offset() time.Duration {
|
||||||
// [<metric_identifier>] <label_matchers>
|
// [<metric_identifier>] <label_matchers>
|
||||||
//
|
//
|
||||||
func (p *parser) vectorSelector(name string) *VectorSelector {
|
func (p *parser) vectorSelector(name string) *VectorSelector {
|
||||||
const ctx = "metric selector"
|
|
||||||
|
|
||||||
var matchers metric.LabelMatchers
|
var matchers metric.LabelMatchers
|
||||||
// Parse label matching if any.
|
// Parse label matching if any.
|
||||||
if t := p.peek(); t.typ == itemLeftBrace {
|
if t := p.peek(); t.typ == itemLeftBrace {
|
||||||
|
|
|
@ -36,7 +36,6 @@ const (
|
||||||
|
|
||||||
// Constants for instrumentation.
|
// Constants for instrumentation.
|
||||||
namespace = "prometheus"
|
namespace = "prometheus"
|
||||||
interval = "interval"
|
|
||||||
)
|
)
|
||||||
|
|
||||||
var (
|
var (
|
||||||
|
|
|
@ -28,8 +28,6 @@ import (
|
||||||
)
|
)
|
||||||
|
|
||||||
const (
|
const (
|
||||||
nerveNodePrefix = "member_"
|
|
||||||
|
|
||||||
nerveLabelPrefix = model.MetaLabelPrefix + "nerve_"
|
nerveLabelPrefix = model.MetaLabelPrefix + "nerve_"
|
||||||
nervePathLabel = nerveLabelPrefix + "path"
|
nervePathLabel = nerveLabelPrefix + "path"
|
||||||
nerveEndpointLabelPrefix = nerveLabelPrefix + "endpoint"
|
nerveEndpointLabelPrefix = nerveLabelPrefix + "endpoint"
|
||||||
|
|
|
@ -30,8 +30,6 @@ import (
|
||||||
)
|
)
|
||||||
|
|
||||||
const (
|
const (
|
||||||
serversetNodePrefix = "member_"
|
|
||||||
|
|
||||||
serversetLabelPrefix = model.MetaLabelPrefix + "serverset_"
|
serversetLabelPrefix = model.MetaLabelPrefix + "serverset_"
|
||||||
serversetStatusLabel = serversetLabelPrefix + "status"
|
serversetStatusLabel = serversetLabelPrefix + "status"
|
||||||
serversetPathLabel = serversetLabelPrefix + "path"
|
serversetPathLabel = serversetLabelPrefix + "path"
|
||||||
|
|
|
@ -14,7 +14,6 @@
|
||||||
package retrieval
|
package retrieval
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"errors"
|
|
||||||
"fmt"
|
"fmt"
|
||||||
"io"
|
"io"
|
||||||
"net/http"
|
"net/http"
|
||||||
|
@ -37,9 +36,6 @@ const (
|
||||||
scrapeHealthMetricName = "up"
|
scrapeHealthMetricName = "up"
|
||||||
scrapeDurationMetricName = "scrape_duration_seconds"
|
scrapeDurationMetricName = "scrape_duration_seconds"
|
||||||
|
|
||||||
// Capacity of the channel to buffer samples during ingestion.
|
|
||||||
ingestedSamplesCap = 256
|
|
||||||
|
|
||||||
// Constants for instrumentation.
|
// Constants for instrumentation.
|
||||||
namespace = "prometheus"
|
namespace = "prometheus"
|
||||||
interval = "interval"
|
interval = "interval"
|
||||||
|
@ -47,8 +43,6 @@ const (
|
||||||
)
|
)
|
||||||
|
|
||||||
var (
|
var (
|
||||||
errSkippedScrape = errors.New("scrape skipped due to throttled ingestion")
|
|
||||||
|
|
||||||
targetIntervalLength = prometheus.NewSummaryVec(
|
targetIntervalLength = prometheus.NewSummaryVec(
|
||||||
prometheus.SummaryOpts{
|
prometheus.SummaryOpts{
|
||||||
Namespace: namespace,
|
Namespace: namespace,
|
||||||
|
|
|
@ -21,7 +21,6 @@ import (
|
||||||
"math"
|
"math"
|
||||||
"net/http"
|
"net/http"
|
||||||
"net/url"
|
"net/url"
|
||||||
"regexp"
|
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
"github.com/prometheus/common/log"
|
"github.com/prometheus/common/log"
|
||||||
|
@ -36,10 +35,6 @@ const (
|
||||||
contentTypeJSON = "application/json"
|
contentTypeJSON = "application/json"
|
||||||
)
|
)
|
||||||
|
|
||||||
var (
|
|
||||||
illegalCharsRE = regexp.MustCompile(`[^a-zA-Z0-9_\-./]`)
|
|
||||||
)
|
|
||||||
|
|
||||||
// Client allows sending batches of Prometheus samples to OpenTSDB.
|
// Client allows sending batches of Prometheus samples to OpenTSDB.
|
||||||
type Client struct {
|
type Client struct {
|
||||||
url string
|
url string
|
||||||
|
|
Loading…
Reference in New Issue