class

Crabbit::CompressionCodecs

Inherits Reference < Object

Thread-safe registry of codecs used for Stream sub-entry batches.

Constructors

new(codecs : Enumerable(CompressionCodec))

Creates a registry containing only codecs.

Source
new

Creates a registry containing None, Gzip, Snappy, LZ4, and Zstandard.

Source

Instance methods

dup

Returns an independent registry containing the current codec objects.

Source
fetch(compression : Compression) : CompressionCodec

Returns the codec registered for compression.

Raises CompressionError when no implementation is installed.

Source
register(codec : CompressionCodec) : self

Registers or replaces the implementation for codec.compression.

Returns self for chaining.

Source