class
Crabbit::CompressionCodecs
- Crabbit::CompressionCodecs
- Reference
- Object
Overview
Thread-safe registry of codecs used for Stream sub-entry batches.
Defined in:
crabbit/compression.crConstructors
-
.new(codecs : Enumerable(CompressionCodec))
Creates a registry containing only codecs.
-
.new
Creates a registry containing None, Gzip, Snappy, LZ4, and Zstandard.
Instance Method Summary
-
#dup : self
Returns an independent registry containing the current codec objects.
-
#fetch(compression : Compression) : CompressionCodec
Returns the codec registered for compression.
-
#register(codec : CompressionCodec) : self
Registers or replaces the implementation for
codec.compression.
Constructor Detail
Instance Method Detail
Returns the codec registered for compression.
Raises CompressionError when no implementation is installed.
Registers or replaces the implementation for codec.compression.
Returns self for chaining.