lib/fluent/plugin/out_dedup.rb in fluent-plugin-dedup-0.2.0 vs lib/fluent/plugin/out_dedup.rb in fluent-plugin-dedup-0.3.0

@@ -5,10 +5,11 @@
   Fluent::Plugin.register_output('dedup', self)
 
   config_param :key, :string, :default => nil
   config_param :file, :string, :default => nil
   config_param :cache_per_tag, :size, :default => 1
+  config_param :cache_ttl, :integer, :default => 0
 
   # Define `log` method for v0.10.42 or earlier
   unless method_defined?(:log)
     define_method("log") { $log }
   end
@@ -16,12 +17,10 @@
   def configure(conf)
     super
     unless conf.include?('key')
       raise Fluent::ConfigError, "config parameter `key` is required"
     end
-    @key = conf['key']
-    @file = conf['file']
     @states = {}
   end
 
   def start
     super
@@ -82,8 +81,12 @@
     end
     is_dup
   end
 
   def new_lru
-    LruRedux::ThreadSafeCache.new(@cache_per_tag)
+    if 0 < @cache_ttl
+      LruRedux::TTL::ThreadSafeCache.new(@cache_per_tag, @cache_ttl)
+    else
+      LruRedux::ThreadSafeCache.new(@cache_per_tag)
+    end
   end
 end