()
| 17 | ) |
| 18 | |
| 19 | func init() { |
| 20 | RegisterCompressor("s2-default", newS2Compressor(headerS2Default)) |
| 21 | RegisterCompressor("s2-better", newS2Compressor(headerS2Better, s2.WriterBetterCompression())) |
| 22 | RegisterCompressor("s2-parallel-4", newS2Compressor(headerS2Parallel4, s2.WriterConcurrency(s2Parallel4Concurrency))) |
| 23 | RegisterCompressor("s2-parallel-8", newS2Compressor(headerS2Parallel8, s2.WriterConcurrency(s2Parallel8Concurrency))) |
| 24 | } |
| 25 | |
| 26 | func newS2Compressor(id HeaderID, opts ...s2.WriterOption) Compressor { |
| 27 | return &s2Compressor{id, compressionHeader(id), sync.Pool{ |
nothing calls this directly
no test coverage detected