class Crabbit::CompressionCodecs

Overview

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

Defined in:

crabbit/compression.cr

Constructors

Instance Method Summary

Constructor Detail

def self.new(codecs : Enumerable(CompressionCodec)) #

Creates a registry containing only codecs.


[View source]
def self.new #

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


[View source]

Instance Method Detail

def dup : self #

Returns an independent registry containing the current codec objects.


[View source]
def fetch(compression : Compression) : CompressionCodec #

Returns the codec registered for compression.

Raises CompressionError when no implementation is installed.


[View source]
def register(codec : CompressionCodec) : self #

Registers or replaces the implementation for codec.compression.

Returns self for chaining.


[View source]