Contents

require 'securerandom'
require 'base64'
require 'fluent/plugin/filter'

module Fluent::Plugin
  class ElasticsearchGenidFilter < Filter
    Fluent::Plugin.register_filter('elasticsearch_genid', self)

    config_param :hash_id_key, :string, :default => '_hash'

    def initialize
      super
    end

    def configure(conf)
      super
    end

    def filter(tag, time, record)
      record[@hash_id_key] = Base64.strict_encode64(SecureRandom.uuid)
      record
    end

  end
end

Version data entries

82 entries across 82 versions & 1 rubygems

Version	Path
fluent-plugin-elasticsearch-4.0.9	lib/fluent/plugin/filter_elasticsearch_genid.rb
fluent-plugin-elasticsearch-4.0.8	lib/fluent/plugin/filter_elasticsearch_genid.rb
fluent-plugin-elasticsearch-4.0.7	lib/fluent/plugin/filter_elasticsearch_genid.rb
fluent-plugin-elasticsearch-4.0.6	lib/fluent/plugin/filter_elasticsearch_genid.rb
fluent-plugin-elasticsearch-4.0.5	lib/fluent/plugin/filter_elasticsearch_genid.rb
fluent-plugin-elasticsearch-4.0.4	lib/fluent/plugin/filter_elasticsearch_genid.rb
fluent-plugin-elasticsearch-4.0.3	lib/fluent/plugin/filter_elasticsearch_genid.rb
fluent-plugin-elasticsearch-4.0.3.rc1	lib/fluent/plugin/filter_elasticsearch_genid.rb
fluent-plugin-elasticsearch-4.0.2	lib/fluent/plugin/filter_elasticsearch_genid.rb
fluent-plugin-elasticsearch-4.0.1	lib/fluent/plugin/filter_elasticsearch_genid.rb
fluent-plugin-elasticsearch-4.0.0	lib/fluent/plugin/filter_elasticsearch_genid.rb
fluent-plugin-elasticsearch-3.8.0	lib/fluent/plugin/filter_elasticsearch_genid.rb
fluent-plugin-elasticsearch-3.7.1	lib/fluent/plugin/filter_elasticsearch_genid.rb
fluent-plugin-elasticsearch-3.7.0	lib/fluent/plugin/filter_elasticsearch_genid.rb
fluent-plugin-elasticsearch-3.6.1	lib/fluent/plugin/filter_elasticsearch_genid.rb
fluent-plugin-elasticsearch-3.6.0	lib/fluent/plugin/filter_elasticsearch_genid.rb
fluent-plugin-elasticsearch-3.5.6	lib/fluent/plugin/filter_elasticsearch_genid.rb
fluent-plugin-elasticsearch-3.5.5	lib/fluent/plugin/filter_elasticsearch_genid.rb
fluent-plugin-elasticsearch-3.5.3	lib/fluent/plugin/filter_elasticsearch_genid.rb
fluent-plugin-elasticsearch-3.5.2	lib/fluent/plugin/filter_elasticsearch_genid.rb