Sha256: 2483a104de438f6ee7c2a6573b099ff1fddcf06639dbbc17d91356a05795b8e6

Contents?: true

Size: 531 Bytes

Versions: 21

Compression:

Stored size: 531 Bytes

Contents

# frozen_string_literal: true

module Karafka
  module Web
    # Web reporting deserializer
    #
    # @note We use `symbolize_names` because we want to use the same convention of hash building
    #   for producing, consuming and displaying metrics related data
    class Deserializer
      # @param message [::Karafka::Messages::Message]
      # @return [Object] deserialized data
      def call(message)
        ::JSON.parse(
          message.raw_payload,
          symbolize_names: true
        )
      end
    end
  end
end

Version data entries

21 entries across 21 versions & 1 rubygems

Version Path
karafka-web-0.6.3 lib/karafka/web/deserializer.rb
karafka-web-0.6.2 lib/karafka/web/deserializer.rb
karafka-web-0.6.1 lib/karafka/web/deserializer.rb
karafka-web-0.6.0 lib/karafka/web/deserializer.rb
karafka-web-0.5.2 lib/karafka/web/deserializer.rb
karafka-web-0.5.1 lib/karafka/web/deserializer.rb
karafka-web-0.5.0 lib/karafka/web/deserializer.rb
karafka-web-0.4.1 lib/karafka/web/deserializer.rb
karafka-web-0.4.0 lib/karafka/web/deserializer.rb
karafka-web-0.3.1 lib/karafka/web/deserializer.rb
karafka-web-0.3.0 lib/karafka/web/deserializer.rb
karafka-web-0.2.5 lib/karafka/web/deserializer.rb
karafka-web-0.2.4 lib/karafka/web/deserializer.rb
karafka-web-0.2.3 lib/karafka/web/deserializer.rb
karafka-web-0.2.2 lib/karafka/web/deserializer.rb
karafka-web-0.2.1 lib/karafka/web/deserializer.rb
karafka-web-0.2.0 lib/karafka/web/deserializer.rb
karafka-web-0.1.3 lib/karafka/web/deserializer.rb
karafka-web-0.1.2 lib/karafka/web/deserializer.rb
karafka-web-0.1.1 lib/karafka/web/deserializer.rb