bump prometheus and thanos to master

Signed-off-by: Ben Ye <yb532204897@gmail.com>

go.mod

@@ -11,7 +11,7 @@ require (
 	github.com/NYTimes/gziphandler v1.1.1
 	github.com/alecthomas/units v0.0.0-20190924025748-f65c72e2690d
 	github.com/armon/go-metrics v0.3.3
-	github.com/aws/aws-sdk-go v1.33.5
+	github.com/aws/aws-sdk-go v1.33.12
 	github.com/blang/semver v3.5.0+incompatible
 	github.com/bradfitz/gomemcache v0.0.0-20190913173617-a41fca850d0b
 	github.com/cespare/xxhash v1.1.0
@@ -44,19 +44,18 @@ require (
 	github.com/prometheus/alertmanager v0.21.0
 	github.com/prometheus/client_golang v1.7.1
 	github.com/prometheus/client_model v0.2.0
-	github.com/prometheus/common v0.10.0
-	github.com/prometheus/prometheus v1.8.2-0.20200722151933-4a8531a64b32
+	github.com/prometheus/common v0.11.1
+	github.com/prometheus/prometheus v1.8.2-0.20200805082714-e0cf219f0de2
 	github.com/rafaeljusto/redigomock v0.0.0-20190202135759-257e089e14a1
 	github.com/segmentio/fasthash v0.0.0-20180216231524-a72b379d632e
 	github.com/spf13/afero v1.2.2
 	github.com/stretchr/testify v1.5.1
-	github.com/thanos-io/thanos v0.13.1-0.20200731083140-69b87607decf
-	github.com/uber/jaeger-client-go v2.24.0+incompatible
+	github.com/thanos-io/thanos v0.13.1-0.20200807203500-9b578afb4763
+	github.com/uber/jaeger-client-go v2.25.0+incompatible
 	github.com/weaveworks/common v0.0.0-20200625145055-4b1847531bc9
 	go.etcd.io/bbolt v1.3.5-0.20200615073812-232d8fc87f50
 	go.etcd.io/etcd v0.5.0-alpha.5.0.20200520232829-54ba9589114f
 	go.uber.org/atomic v1.6.0
-	go.uber.org/zap v1.14.1 // indirect
 	golang.org/x/net v0.0.0-20200707034311-ab3426394381
 	golang.org/x/sync v0.0.0-20200625203802-6e8e738ad208
 	golang.org/x/time v0.0.0-20200630173020-3af7569d3a1e

pkg/compactor/compactor_test.go

@@ -760,7 +760,7 @@ func createTSDBBlock(t *testing.T, dir string, minT, maxT int64, externalLabels
 	for i, ts := range []int64{minT, maxT - 1} {
 		lbls := labels.Labels{labels.Label{Name: "series_id", Value: strconv.Itoa(i)}}
 
-		app := db.Appender()
+		app := db.Appender(context.Background())
 		_, err := app.Add(lbls, ts, float64(i))
 		require.NoError(t, err)
 

pkg/configs/legacy_promql/bench_test.go

@@ -60,7 +60,7 @@ func BenchmarkRangeQuery(b *testing.B) {
 	numIntervals := 8640 + 10000
 
 	for s := 0; s < numIntervals; s++ {
-		a := storage.Appender()
+		a := storage.Appender(context.Background())
 		ts := int64(s * 10000) // 10s interval.
 		for i, metric := range metrics {
 			err := a.AddFast(refs[i], ts, float64(s))

pkg/configs/legacy_promql/functions_test.go

@@ -31,7 +31,7 @@ func TestDeriv(t *testing.T) {
 	defer storage.Close()
 	engine := NewEngine(nil, nil, 10, 10*time.Second)
 
-	a := storage.Appender()
+	a := storage.Appender(context.Background())
 
 	metric := labels.FromStrings("__name__", "foo")
 	_, err := a.Add(metric, 1493712816939, 1.0)

pkg/configs/legacy_promql/test.go

@@ -421,7 +421,7 @@ func (t *Test) exec(tc testCommand) error {
 		t.clear()
 
 	case *loadCmd:
-		app := t.storage.Appender()
+		app := t.storage.Appender(context.Background())
 		if err := cmd.append(app); err != nil {
 			app.Rollback()
 			return err
@@ -617,8 +617,8 @@ func (a adapter) ChunkQuerier(ctx context.Context, mint, maxt int64) (storage.Ch
 }
 
 // Appender returns a new appender against the storage.
-func (a adapter) Appender() storage.Appender {
-	return a.db.Appender()
+func (a adapter) Appender(ctx context.Context) storage.Appender {
+	return a.db.Appender(ctx)
 }
 
 // Close closes the storage and all its underlying resources.

pkg/ingester/ingester_v2.go

@@ -418,7 +418,7 @@ func (i *Ingester) v2Push(ctx context.Context, req *client.WriteRequest) (*clien
 	startAppend := time.Now()
 
 	// Walk the samples, appending them to the users database
-	app := db.Appender()
+	app := db.Appender(ctx)
 	for _, ts := range req.Timeseries {
 		// Check if we already have a cached reference for this series. Be aware
 		// that even if we have a reference it's not guaranteed to be still valid.

pkg/ingester/ingester_v2_test.go

@@ -1692,7 +1692,7 @@ func TestHeadCompactionOnStartup(t *testing.T) {
 		l := labels.Labels{{Name: "n", Value: "v"}}
 		for i := 0; i < numFullChunks; i++ {
 			// Not using db.Appender() as it checks for compaction.
-			app := head.Appender()
+			app := head.Appender(context.Background())
 			_, err := app.Add(l, int64(i)*chunkRange+1, 9.99)
 			require.NoError(t, err)
 			_, err = app.Add(l, int64(i+1)*chunkRange, 9.99)

pkg/querier/querier_test.go

@@ -188,7 +188,7 @@ func mockTSDB(t *testing.T, mint model.Time, samples int, step, chunkOffset time
 		_ = head.Close()
 	})
 
-	app := head.Appender()
+	app := head.Appender(context.Background())
 
 	l := labels.Labels{
 		{Name: model.MetricNameLabel, Value: "foo"},

pkg/querier/queryrange/queryable_test.go

@@ -40,7 +40,7 @@ func TestSelect(t *testing.T) {
 				expected := &PrometheusResponse{
 					Status: "success",
 					Data: PrometheusData{
-						ResultType: parser.ValueTypeVector,
+						ResultType: string(parser.ValueTypeVector),
 					},
 				}
 
@@ -88,7 +88,7 @@ func TestSelect(t *testing.T) {
 			querier: mkQuerier(mockHandler(
 				&PrometheusResponse{
 					Data: PrometheusData{
-						ResultType: parser.ValueTypeVector,
+						ResultType: string(parser.ValueTypeVector),
 						Result: []SampleStream{
 							{
 								Labels: []client.LabelAdapter{
@@ -216,7 +216,7 @@ func TestSelectConcurrent(t *testing.T) {
 			// each request will return a single samplestream
 			querier := mkQuerier(mockHandler(&PrometheusResponse{
 				Data: PrometheusData{
-					ResultType: parser.ValueTypeVector,
+					ResultType: string(parser.ValueTypeVector),
 					Result: []SampleStream{
 						{
 							Labels: []client.LabelAdapter{

pkg/querier/queryrange/querysharding_test.go

@@ -37,7 +37,7 @@ func TestQueryshardingMiddleware(t *testing.T) {
 			next: mockHandler(&PrometheusResponse{
 				Status: "",
 				Data: PrometheusData{
-					ResultType: parser.ValueTypeVector,
+					ResultType: string(parser.ValueTypeVector),
 					Result:     []SampleStream{},
 				},
 				ErrorType: "",
@@ -67,7 +67,7 @@ func TestQueryshardingMiddleware(t *testing.T) {
 				)
 				out, err := handler.Do(context.Background(), qry)
 				require.Nil(t, err)
-				require.Equal(t, parser.ValueTypeMatrix, out.(*PrometheusResponse).Data.ResultType)
+				require.Equal(t, string(parser.ValueTypeMatrix), out.(*PrometheusResponse).Data.ResultType)
 				require.Equal(t, sampleMatrixResponse(), out)
 			},
 		},
@@ -119,7 +119,7 @@ func sampleMatrixResponse() *PrometheusResponse {
 	return &PrometheusResponse{
 		Status: StatusSuccess,
 		Data: PrometheusData{
-			ResultType: parser.ValueTypeMatrix,
+			ResultType: string(parser.ValueTypeMatrix),
 			Result: []SampleStream{
 				{
 					Labels: []client.LabelAdapter{

pkg/querier/queryrange/series_test.go

@@ -12,7 +12,7 @@ import (
 func Test_ResponseToSamples(t *testing.T) {
 	input := &PrometheusResponse{
 		Data: PrometheusData{
-			ResultType: parser.ValueTypeMatrix,
+			ResultType: string(parser.ValueTypeMatrix),
 			Result: []SampleStream{
 				{
 					Labels: []client.LabelAdapter{

pkg/querier/queryrange/value.go

@@ -89,7 +89,7 @@ func ResponseToSamples(resp Response) ([]SampleStream, error) {
 		return nil, errors.New(promRes.Error)
 	}
 	switch promRes.Data.ResultType {
-	case parser.ValueTypeVector, parser.ValueTypeMatrix:
+	case string(parser.ValueTypeVector), string(parser.ValueTypeMatrix):
 		return promRes.Data.Result, nil
 	}
 

pkg/ruler/compat.go

@@ -63,7 +63,7 @@ type PusherAppendable struct {
 }
 
 // Appender returns a storage.Appender
-func (t *PusherAppendable) Appender() storage.Appender {
+func (t *PusherAppendable) Appender(_ context.Context) storage.Appender {
 	return &pusherAppender{
 		pusher: t.pusher,
 		userID: t.userID,

pkg/storegateway/bucket_stores_test.go

@@ -241,7 +241,7 @@ func generateStorageBlock(t *testing.T, storageDir, userID string, metricName st
 
 	series := labels.Labels{labels.Label{Name: labels.MetricName, Value: metricName}}
 
-	app := db.Appender()
+	app := db.Appender(context.Background())
 	for ts := minT; ts < maxT; ts += step {
 		_, err = app.Add(series, ts, 1)
 		require.NoError(t, err)

pkg/storegateway/gateway_test.go

@@ -752,7 +752,7 @@ func mockTSDB(dir string, numSeries int, minT, maxT int64) error {
 	for i := 0; i < numSeries; i++ {
 		lbls := labels.Labels{labels.Label{Name: "series_id", Value: strconv.Itoa(i)}}
 
-		app := db.Appender()
+		app := db.Appender(context.Background())
 		if _, err := app.Add(lbls, minT+(step*int64(i)), float64(i)); err != nil {
 			return err
 		}