Contents

require 'helper'
require 'date'
require 'fluent/test/helpers'
require 'json'
require 'fluent/test/driver/filter'
require 'flexmock/test_unit'
require 'fluent/plugin/filter_elasticsearch_genid'

class ElasticsearchGenidFilterTest < Test::Unit::TestCase
  include FlexMock::TestCase
  include Fluent::Test::Helpers

  def setup
    Fluent::Test.setup
  end

  def create_driver(conf='')
    Fluent::Test::Driver::Filter.new(Fluent::Plugin::ElasticsearchGenidFilter).configure(conf)
  end

  def sample_record
    {'age' => 26, 'request_id' => '42', 'parent_id' => 'parent', 'routing_id' => 'routing'}
  end

  def test_configure
    d = create_driver
    assert_equal '_hash', d.instance.hash_id_key
  end

  data("default" => {"hash_id_key" => "_hash"},
       "custom_key" => {"hash_id_key" => "_edited"},
      )
  def test_filter(data)
    d = create_driver("hash_id_key #{data["hash_id_key"]}")
    flexmock(SecureRandom).should_receive(:uuid)
      .and_return("13a0c028-bf7c-4ae2-ad03-ec09a40006df")
    time = event_time("2017-10-15 15:00:23.34567890 UTC")
    d.run(default_tag: 'test') do
      d.feed(time, sample_record)
    end
    assert_equal(Base64.strict_encode64(SecureRandom.uuid),
                 d.filtered.map {|e| e.last}.first[d.instance.hash_id_key])
  end
end

Version data entries

78 entries across 78 versions & 1 rubygems

Version	Path
fluent-plugin-elasticsearch-2.12.1	test/plugin/test_filter_elasticsearch_genid.rb
fluent-plugin-elasticsearch-2.12.0	test/plugin/test_filter_elasticsearch_genid.rb
fluent-plugin-elasticsearch-2.11.11	test/plugin/test_filter_elasticsearch_genid.rb
fluent-plugin-elasticsearch-2.11.10	test/plugin/test_filter_elasticsearch_genid.rb
fluent-plugin-elasticsearch-2.11.9	test/plugin/test_filter_elasticsearch_genid.rb
fluent-plugin-elasticsearch-2.11.8	test/plugin/test_filter_elasticsearch_genid.rb
fluent-plugin-elasticsearch-2.11.7	test/plugin/test_filter_elasticsearch_genid.rb
fluent-plugin-elasticsearch-2.11.6	test/plugin/test_filter_elasticsearch_genid.rb
fluent-plugin-elasticsearch-2.11.5	test/plugin/test_filter_elasticsearch_genid.rb
fluent-plugin-elasticsearch-2.11.4	test/plugin/test_filter_elasticsearch_genid.rb
fluent-plugin-elasticsearch-2.11.3	test/plugin/test_filter_elasticsearch_genid.rb
fluent-plugin-elasticsearch-2.11.2	test/plugin/test_filter_elasticsearch_genid.rb
fluent-plugin-elasticsearch-2.11.1	test/plugin/test_filter_elasticsearch_genid.rb
fluent-plugin-elasticsearch-2.11.0	test/plugin/test_filter_elasticsearch_genid.rb
fluent-plugin-elasticsearch-2.10.5	test/plugin/test_filter_elasticsearch_genid.rb
fluent-plugin-elasticsearch-2.10.4	test/plugin/test_filter_elasticsearch_genid.rb
fluent-plugin-elasticsearch-2.10.2	test/plugin/test_filter_elasticsearch_genid.rb
fluent-plugin-elasticsearch-2.10.1	test/plugin/test_filter_elasticsearch_genid.rb
fluent-plugin-elasticsearch-2.10.0	test/plugin/test_filter_elasticsearch_genid.rb
fluent-plugin-elasticsearch-2.9.2	test/plugin/test_filter_elasticsearch_genid.rb