Packages

mongodb_driver

1.6.0
1.6.3 1.6.2 1.6.1 1.6.0 1.5.6 1.5.5 1.5.4 1.5.2 1.5.1 1.5.0 1.4.1 1.4.0 1.2.1 1.2.0 1.1.0 1.0.3 1.0.2 1.0.1 1.0.0 0.9.2 0.9.1 0.9.0 0.9.0-rc.1 0.9.0-rc.0 0.8.4 0.8.3 0.8.2 0.8.1 0.8.0 0.7.4 0.7.3 0.7.2 0.7.1 0.7.0 0.6.5 0.6.4 0.6.3 0.6.2 0.6.1 0.6.0 0.5.7 0.5.6 0.5.5 0.5.4 0.5.3 0.5.2 0.5.1 0.5.0

The MongoDB driver for Elixir

HexDocs

Current section

Files

Jump to
Readme
48 Versions
4 Dependencies
Dependants
Files
Activity
mongodb_driver lib mongo compressor.ex
Raw

lib/mongo/compressor.ex 

defmodule Mongo.Compressor do

  @moduledoc false



  @zlib_compressor_id 2

  @zstd_module Enum.find([:zstd, :ezstd], &Code.ensure_loaded?/1)



  if @zstd_module do

    @zstd_compressor_id 3

  end



  def zstd_available?, do: not is_nil(@zstd_module)



  def compressors, do: if(zstd_available?(), do: ["zstd", "zlib"], else: ["zlib"])



  def compress(binary, :zlib) do

    {@zlib_compressor_id, :zlib.compress(binary)}

  end



  if @zstd_module do

    def compress(binary, :zstd) when is_binary(binary) do

      {@zstd_compressor_id, @zstd_module.compress(binary)}

    end



    def compress(iodata, :zstd) when is_list(iodata) do

      {@zstd_compressor_id,

       iodata

       |> IO.iodata_to_binary()

       |> @zstd_module.compress()}

    end

  end



  def uncompress(binary, @zlib_compressor_id) do

    :zlib.uncompress(binary)

  end



  if @zstd_module do

    def uncompress(binary, @zstd_compressor_id) do

      @zstd_module.decompress(binary)

    end

  end



  def uncompress(binary, :zlib) do

    :zlib.uncompress(binary)

  end



  if @zstd_module do

    def uncompress(binary, :zstd) do

      @zstd_module.decompress(binary)

    end

  end

end