Contents

require 'oj'
require_relative 'elasticsearch_compat'

module Fluent::Plugin
  module Serializer

    class Oj
      include TRANSPORT_CLASS::Transport::Serializer::Base

      # De-serialize a Hash from JSON string
      #
      def load(string, options={})
        ::Oj.load(string, options)
      end

      # Serialize a Hash to JSON string
      #
      def dump(object, options={})
        ::Oj.dump(object, options)
      end
    end
  end
end

Version data entries

11 entries across 11 versions & 1 rubygems

Version	Path
fluent-plugin-elasticsearch-5.4.3	lib/fluent/plugin/oj_serializer.rb
fluent-plugin-elasticsearch-5.4.2	lib/fluent/plugin/oj_serializer.rb
fluent-plugin-elasticsearch-5.4.1	lib/fluent/plugin/oj_serializer.rb
fluent-plugin-elasticsearch-5.4.0	lib/fluent/plugin/oj_serializer.rb
fluent-plugin-elasticsearch-5.3.0	lib/fluent/plugin/oj_serializer.rb
fluent-plugin-elasticsearch-5.2.5	lib/fluent/plugin/oj_serializer.rb
fluent-plugin-elasticsearch-5.2.4	lib/fluent/plugin/oj_serializer.rb
fluent-plugin-elasticsearch-5.2.3	lib/fluent/plugin/oj_serializer.rb
fluent-plugin-elasticsearch-5.2.2	lib/fluent/plugin/oj_serializer.rb
fluent-plugin-elasticsearch-5.2.1	lib/fluent/plugin/oj_serializer.rb
fluent-plugin-elasticsearch-5.2.0	lib/fluent/plugin/oj_serializer.rb