Allow setting TSDB block duration for receive service (thanos-io#1496)

* Allow setting TSDB block duration

Signed-off-by: Fawad Halim <[email protected]>

* PR feedback: corrected flag naming, made the flag hidden by default

Signed-off-by: Fawad Halim <[email protected]>

* Enable WALCompression on Receive service

Signed-off-by: Fawad Halim <[email protected]>

Author: fhalim

cmd/thanos/receive.go

@@ -60,6 +60,8 @@ func registerReceive(m map[string]setupFunc, app *kingpin.Application, name stri
 
 	replicationFactor := cmd.Flag("receive.replication-factor", "How many times to replicate incoming write requests.").Default("1").Uint64()
 
+	tsdbBlockDuration := modelDuration(cmd.Flag("tsdb.block-duration", "Duration for local TSDB blocks").Default("2h").Hidden())
+
 	m[name] = func(g *run.Group, logger log.Logger, reg *prometheus.Registry, tracer opentracing.Tracer, _ bool) error {
 		lset, err := parseFlagLabels(*labelStrs)
 		if err != nil {
@@ -106,6 +108,7 @@ func registerReceive(m map[string]setupFunc, app *kingpin.Application, name stri
 			*tenantHeader,
 			*replicaHeader,
 			*replicationFactor,
+			*tsdbBlockDuration,
 		)
 	}
 }
@@ -130,15 +133,17 @@ func runReceive(
 	tenantHeader string,
 	replicaHeader string,
 	replicationFactor uint64,
+	tsdbBlockDuration model.Duration,
 ) error {
 	logger = log.With(logger, "component", "receive")
 	level.Warn(logger).Log("msg", "setting up receive; the Thanos receive component is EXPERIMENTAL, it may break significantly without notice")
 
 	tsdbCfg := &tsdb.Options{
 		RetentionDuration: retention,
 		NoLockfile:        true,
-		MinBlockDuration:  model.Duration(time.Hour * 2),
-		MaxBlockDuration:  model.Duration(time.Hour * 2),
+		MinBlockDuration:  tsdbBlockDuration,
+		MaxBlockDuration:  tsdbBlockDuration,
+		WALCompression:    true,
 	}
 
 	localStorage := &tsdb.ReadyStorage{}