Vendor packages related to "Thanos" and "Prometheus" updated

runnable/flags.go

@@ -23,7 +23,7 @@ func regCommonServerFlags(cmd *kingpin.CmdClause) (
 	grpcTLSSrvCert *string,
 	grpcTLSSrvKey *string,
 	grpcTLSSrvClientCA *string,
-	peerFunc func(log.Logger, *prometheus.Registry, bool, string, bool) (*cluster.Peer, error)) {
+	peerFunc func(log.Logger, *prometheus.Registry, bool, string, bool) (cluster.Peer, error)) {
 
 	grpcBindAddr = cmd.Flag("grpc-address", "Listen ip:port address for gRPC endpoints (StoreAPI). Make sure this address is routable from other components if you use gossip, 'grpc-advertise-address' is empty and you require cross-node connection.").
 		Default("0.0.0.0:10901").String()
@@ -68,7 +68,7 @@ func regCommonServerFlags(cmd *kingpin.CmdClause) (
 		grpcTLSSrvCert,
 		grpcTLSSrvKey,
 		grpcTLSSrvClientCA,
-		func(logger log.Logger, reg *prometheus.Registry, waitIfEmpty bool, httpAdvertiseAddr string, queryAPIEnabled bool) (*cluster.Peer, error) {
+		func(logger log.Logger, reg *prometheus.Registry, waitIfEmpty bool, httpAdvertiseAddr string, queryAPIEnabled bool) (cluster.Peer, error) {
 			host, port, err := cluster.CalculateAdvertiseAddress(*grpcBindAddr, *grpcAdvertiseAddr)
 			if err != nil {
 				return nil, errors.Wrapf(err, "calculate advertise StoreAPI addr for gossip based on bindAddr: %s and advAddr: %s", *grpcBindAddr, *grpcAdvertiseAddr)

runnable/receiver.go

@@ -73,7 +73,7 @@ func RunReceiver(
 	httpMetricsBindAddr string,
 	remoteWriteAddress string,
 	dataDir string,
-	peer *cluster.Peer,
+	peer cluster.Peer,
 	component string,
 ) error {
 	level.Info(logger).Log("msg", "setting up receiver")
@@ -86,10 +86,10 @@ func RunReceiver(
 	}
 
 	tsdbCfg := &tsdb.Options{
-		Retention:        model.Duration(time.Hour * 24 * 15),
-		NoLockfile:       true,
-		MinBlockDuration: model.Duration(time.Hour * 2),
-		MaxBlockDuration: model.Duration(time.Hour * 2),
+		RetentionDuration: model.Duration(time.Hour * 24 * 15),
+		NoLockfile:        true,
+		MinBlockDuration:  model.Duration(time.Hour * 2),
+		MaxBlockDuration:  model.Duration(time.Hour * 2),
 	}
 
 	ctxWeb, cancelWeb := context.WithCancel(context.Background())