Daijiro MORI
null+****@clear*****
Wed May 8 21:30:35 JST 2013
Daijiro MORI 2013-05-08 21:30:35 +0900 (Wed, 08 May 2013) New Revision: ed797908a0fbfcf07fcab88760085b8f53f54478 https://github.com/groonga/fluent-plugin-droonga/commit/ed797908a0fbfcf07fcab88760085b8f53f54478 Message: Get the merger_path from config.json. Modified files: lib/droonga/plugin/handler_merge.rb Modified: lib/droonga/plugin/handler_merge.rb (+3 -1) =================================================================== --- lib/droonga/plugin/handler_merge.rb 2013-05-08 20:40:05 +0900 (93c10dc) +++ lib/droonga/plugin/handler_merge.rb 2013-05-08 21:30:35 +0900 (d4f11d0) @@ -35,10 +35,10 @@ module Droonga command "merge.result" => :adapt_reply def adapt_request(request, *arguments) - add_route("merge.result") dataset = @config["datasets"][request["dataset"]] return unless dataset @mergers[envelope["id"]] = merger = Merger.new(dataset) + add_route(merger.merger_path) merger.routes.each do |route| post(request, route) end @@ -57,9 +57,11 @@ module Droonga class Merger attr_reader :routes attr_reader :result + attr_reader :merger_path def initialize(dataset) @dataset = dataset @merge_policy = dataset["merge_policy"] + @merger_path = dataset["merger_path"] || "merge.result" @routes = [] dataset["shards"].collect do |key, shard| n_replications = shard["instances"].size -------------- next part -------------- HTML����������������������������...Descargar
