Yoji Shidara
null+****@clear*****
Thu Feb 13 16:58:05 JST 2014
Yoji Shidara 2014-02-13 16:58:05 +0900 (Thu, 13 Feb 2014) New Revision: 01e30c46a1a8ae475dd64ac09f1977e4f3e7b41a https://github.com/droonga/fluent-plugin-droonga/commit/01e30c46a1a8ae475dd64ac09f1977e4f3e7b41a Message: Hook catalog reload in DroongaOutput Modified files: lib/droonga/catalog_observer.rb lib/fluent/plugin/out_droonga.rb Modified: lib/droonga/catalog_observer.rb (+2 -0) =================================================================== --- lib/droonga/catalog_observer.rb 2014-02-13 16:44:19 +0900 (3aac895) +++ lib/droonga/catalog_observer.rb 2014-02-13 16:58:05 +0900 (8d0d9f3) @@ -23,6 +23,7 @@ module Droonga CHECK_INTERVAL = 1 attr_reader :catalog + attr_accessor :on_reload def initialize @catalog_path = catalog_path @@ -54,6 +55,7 @@ module Droonga def ensure_latest_catalog_loaded if catalog_updated? load_catalog! + on_reload.call(catalog) if on_reload end end Modified: lib/fluent/plugin/out_droonga.rb (+3 -0) =================================================================== --- lib/fluent/plugin/out_droonga.rb 2014-02-13 16:44:19 +0900 (aaad9a3) +++ lib/fluent/plugin/out_droonga.rb 2014-02-13 16:58:05 +0900 (fb78216) @@ -29,6 +29,9 @@ module Fluent super Droonga::PluginLoader.load_all @catalog_observer = Droonga::CatalogObserver.new + @catalog_observer.on_reload = lambda do |catalog| + $log.info "CATALOG RELOADED" + end @catalog_observer.start catalog = @catalog_observer.catalog @engine = Droonga::Engine.new(catalog, :name => @name) -------------- next part -------------- HTML����������������������������...Download