block: rename GetCompressor to MakeCompressor

Author: RaduBerinde

sstable/blob/blob.go

@@ -131,7 +131,7 @@ func NewFileWriter(fn base.DiskFileNum, w objstorage.Writable, opts FileWriterOp
 	fw.flushGov = opts.FlushGovernor
 	fw.indexEncoder.Init()
 	fw.checksummer = block.Checksummer{Type: opts.ChecksumType}
-	fw.compressor = block.GetCompressor(opts.Compression)
+	fw.compressor = block.MakeCompressor(opts.Compression)
 	fw.cpuMeasurer = opts.CpuMeasurer
 	fw.writeQueue.ch = make(chan compressedBlock)
 	fw.writeQueue.wg.Add(1)

sstable/block/compression_test.go

@@ -18,7 +18,7 @@ func TestBufferRandomized(t *testing.T) {
 	t.Logf("seed %d", seed)
 	rng := rand.New(rand.NewPCG(0, seed))
 
-	compressor := GetCompressor(SnappyCompression)
+	compressor := MakeCompressor(SnappyCompression)
 	defer compressor.Close()
 	var checksummer Checksummer
 	checksummer.Init(ChecksumTypeCRC32c)

sstable/block/compressor.go

@@ -13,9 +13,9 @@ type Compressor struct {
 	compressor compression.Compressor
 }
 
-// GetCompressor returns a Compressor that applies the given compression. Close
+// MakeCompressor returns a Compressor that applies the given compression. Close
 // must be called when it is no longer needed.
-func GetCompressor(c Compression) Compressor {
+func MakeCompressor(c Compression) Compressor {
 	s := c.setting()
 	return Compressor{
 		algorithm:  s.Algorithm,

sstable/colblk_writer.go

@@ -194,7 +194,7 @@ func newColumnarWriter(
 	w.cpuMeasurer = cpuMeasurer
 	go w.drainWriteQueue()
 
-	w.compressor = block.GetCompressor(w.opts.Compression)
+	w.compressor = block.MakeCompressor(w.opts.Compression)
 	return w
 }
 

sstable/layout.go

@@ -918,7 +918,7 @@ func (w *layoutWriter) writeBlock(
 	b []byte, compression block.Compression, buf *blockBuf,
 ) (block.Handle, error) {
 	// TODO(radu): store a compressor in the layoutWriter.
-	compressor := block.GetCompressor(compression)
+	compressor := block.MakeCompressor(compression)
 	defer compressor.Close()
 	pb := block.CompressAndChecksum(&buf.dataBuf, b, compressor, &buf.checksummer)
 	h, err := w.writePrecompressedBlock(pb)

sstable/rowblk_writer.go

@@ -490,7 +490,7 @@ func (d *dataBlockBuf) finish() {
 
 func (d *dataBlockBuf) compressAndChecksum(c block.Compression) {
 	// TODO(radu): pass a Compressor here.
-	compressor := block.GetCompressor(c)
+	compressor := block.MakeCompressor(c)
 	defer compressor.Close()
 	d.physical = block.CompressAndChecksum(&d.dataBuf, d.uncompressed, compressor, &d.checksummer)
 }
@@ -1933,7 +1933,7 @@ func (w *RawRowWriter) copyDataBlocks(
 func (w *RawRowWriter) addDataBlock(b, sep []byte, bhp block.HandleWithProperties) error {
 	blockBuf := &w.dataBlockBuf.blockBuf
 	// TODO(radu): store a compressor in w.layout.
-	compressor := block.GetCompressor(w.layout.compression)
+	compressor := block.MakeCompressor(w.layout.compression)
 	defer compressor.Close()
 	pb := block.CompressAndChecksum(
 		&blockBuf.dataBuf,

sstable/suffix_rewriter.go

@@ -170,7 +170,7 @@ func rewriteDataBlocksInParallel(
 			// We'll assume all blocks are _roughly_ equal so round-robin static partition
 			// of each worker doing every ith block is probably enough.
 			err := func() error {
-				compressor := block.GetCompressor(opts.Compression)
+				compressor := block.MakeCompressor(opts.Compression)
 				defer compressor.Close()
 				for i := worker; i < len(input); i += concurrency {
 					bh := input[i]

sstable/valblk/writer.go

@@ -56,7 +56,7 @@ func NewWriter(
 		blockFinishedFunc: blockFinishedFunc,
 		blocks:            w.blocks[:0],
 	}
-	w.compressor = block.GetCompressor(compression)
+	w.compressor = block.MakeCompressor(compression)
 	w.checksummer.Init(checksumType)
 	w.buf = block.NewTempBuffer()
 	return w