Contents

# frozen_string_literal: true

require "kafka/crc32_hash"
require "kafka/murmur2_hash"

module Kafka
  module Digest
    FUNCTIONS_BY_NAME = {
      :crc32 => Crc32Hash.new,
      :murmur2 => Murmur2Hash.new
    }.freeze

    def self.find_digest(name)
      digest = FUNCTIONS_BY_NAME.fetch(name) do
        raise LoadError, "Unknown hash function #{name}"
      end

      digest.load
      digest
    end
  end
end

Version data entries

9 entries across 9 versions & 3 rubygems

Version	Path
ruby-kafka-1.5.0	lib/kafka/digest.rb
ruby-kafka-aws-iam-1.4.5	lib/kafka/digest.rb
ruby-kafka-aws-iam-1.4.4	lib/kafka/digest.rb
ruby-kafka-aws-iam-1.4.3	lib/kafka/digest.rb
ruby-kafka-aws-iam-1.4.2	lib/kafka/digest.rb
ruby-kafka-aws-iam-1.4.1	lib/kafka/digest.rb
ruby-kafka-1.4.0	lib/kafka/digest.rb
ruby-kafka-temp-fork-0.0.2	lib/kafka/digest.rb
ruby-kafka-temp-fork-0.0.1	lib/kafka/digest.rb