WAL compression always enabled

Ganesh Vernekar · Ganesh Vernekar · commit 05127b016acf · 2019-08-12T19:05:28.000+05:30
Signed-off-by: Ganesh Vernekar &lt;cs15btech11018@iith.ac.in&gt;
diff --git a/pkg/ingester/wal.go b/pkg/ingester/wal.go
@@ -67,7 +67,7 @@ func newWAL(cfg WALConfig, ingester *Ingester) (WAL, error) {
 	if cfg.metricsRegisterer != nil {
 		samplesRegistry = prometheus.WrapRegistererWith(prometheus.Labels{"kind": "samples"}, cfg.metricsRegisterer)
 	}
-	samples, err := wal.New(util.Logger, samplesRegistry, path.Join(cfg.dir, "samples"))
+	samples, err := wal.New(util.Logger, samplesRegistry, path.Join(cfg.dir, "samples"), true)
 	if err != nil {
 		return nil, err
 	}
@@ -76,7 +76,7 @@ func newWAL(cfg WALConfig, ingester *Ingester) (WAL, error) {
 	if cfg.metricsRegisterer != nil {
 		checkpointsRegistry = prometheus.WrapRegistererWith(prometheus.Labels{"kind": "checkpoints"}, cfg.metricsRegisterer)
 	}
-	checkpoints, err := wal.New(util.Logger, checkpointsRegistry, path.Join(cfg.dir, "checkpoints"))
+	checkpoints, err := wal.New(util.Logger, checkpointsRegistry, path.Join(cfg.dir, "checkpoints"), true)
 	if err != nil {
 		return nil, err
 	}

Original file line number	Diff line number	Diff line change
`@@ -67,7 +67,7 @@ func newWAL(cfg WALConfig, ingester *Ingester) (WAL, error) {`
`67`	`67`	`if cfg.metricsRegisterer != nil {`
`68`	`68`	`samplesRegistry = prometheus.WrapRegistererWith(prometheus.Labels{"kind": "samples"}, cfg.metricsRegisterer)`
`69`	`69`	`}`
`70`		`- samples, err := wal.New(util.Logger, samplesRegistry, path.Join(cfg.dir, "samples"))`
	`70`	`+ samples, err := wal.New(util.Logger, samplesRegistry, path.Join(cfg.dir, "samples"), true)`
`71`	`71`	`if err != nil {`
`72`	`72`	`return nil, err`
`73`	`73`	`}`
`@@ -76,7 +76,7 @@ func newWAL(cfg WALConfig, ingester *Ingester) (WAL, error) {`
`76`	`76`	`if cfg.metricsRegisterer != nil {`
`77`	`77`	`checkpointsRegistry = prometheus.WrapRegistererWith(prometheus.Labels{"kind": "checkpoints"}, cfg.metricsRegisterer)`
`78`	`78`	`}`
`79`		`- checkpoints, err := wal.New(util.Logger, checkpointsRegistry, path.Join(cfg.dir, "checkpoints"))`
	`79`	`+ checkpoints, err := wal.New(util.Logger, checkpointsRegistry, path.Join(cfg.dir, "checkpoints"), true)`
`80`	`80`	`if err != nil {`
`81`	`81`	`return nil, err`
`82`	`82`	`}`