YUKI Hiroshi
null+****@clear*****
Wed Apr 15 13:22:39 JST 2015
YUKI Hiroshi 2015-04-15 13:22:39 +0900 (Wed, 15 Apr 2015) New Revision: cc4389c290ad8a3e932c60ce44db151e2635078b https://github.com/droonga/droonga-engine/commit/cc4389c290ad8a3e932c60ce44db151e2635078b Message: Add "Client" suffix for DataAbsorber. Because there is another Droonga::Plugins::System::AbsorbDataHandler::DataAbsober. Modified files: bin/droonga-engine-absorb-data bin/droonga-engine-join Renamed files: lib/droonga/data_absorber_client.rb (from lib/droonga/data_absorber.rb) Modified: bin/droonga-engine-absorb-data (+4 -4) =================================================================== --- bin/droonga-engine-absorb-data 2015-04-15 13:09:16 +0900 (59d7382) +++ bin/droonga-engine-absorb-data 2015-04-15 13:22:39 +0900 (ee2e5f2) @@ -23,7 +23,7 @@ require "coolio" require "droonga/engine/version" require "droonga/catalog_generator" require "droonga/path" -require "droonga/data_absorber" +require "droonga/data_absorber_client" require "droonga/serf" require "droonga/client" require "droonga/node_metadata" @@ -59,8 +59,8 @@ class AbsorbDataCommand options.tag = Droonga::CatalogGenerator::DEFAULT_TAG options.dataset = Droonga::CatalogGenerator::DEFAULT_DATASET options.receiver_host = Socket.gethostname - options.messages_per_second = Droonga::DataAbsorber::DEFAULT_MESSAGES_PER_SECOND - options.progress_interval_seconds = Droonga::DataAbsorber::DEFAULT_PROGRESS_INTERVAL_SECONDS + options.messages_per_second = Droonga::DataAbsorberClient::DEFAULT_MESSAGES_PER_SECOND + options.progress_interval_seconds = Droonga::DataAbsorberClient::DEFAULT_PROGRESS_INTERVAL_SECONDS options.verbose = false parser = OptionParser.new parser.version = Droonga::Engine::VERSION @@ -163,7 +163,7 @@ class AbsorbDataCommand :loop => @loop, }, } - Droonga::DataAbsorber.new(absorber_options) + Droonga::DataAbsorberClient.new(absorber_options) end def absorb Modified: bin/droonga-engine-join (+4 -4) =================================================================== --- bin/droonga-engine-join 2015-04-15 13:09:16 +0900 (6281cca) +++ bin/droonga-engine-join 2015-04-15 13:22:39 +0900 (f815d4a) @@ -27,7 +27,7 @@ require "droonga/catalog_fetcher" require "droonga/catalog_generator" require "droonga/catalog_loader" require "droonga/safe_file_writer" -require "droonga/data_absorber" +require "droonga/data_absorber_client" require "droonga/serf" require "droonga/node_metadata" @@ -100,13 +100,13 @@ class JoinCommand "Maximum number of records per second to be copied. " + "'#{Droonga::Client::RateLimiter::NO_LIMIT}' means no limit.", :as => Integer, - :default => Droonga::DataAbsorber::DEFAULT_MESSAGES_PER_SECOND) + :default => Droonga::DataAbsorberClient::DEFAULT_MESSAGES_PER_SECOND) option.separator("Miscellaneous:") option.on("progress-interval-seconds=", "Interval seconds to report progress.", :as => Integer, - :default => Droonga::DataAbsorber::DEFAULT_PROGRESS_INTERVAL_SECONDS) + :default => Droonga::DataAbsorberClient::DEFAULT_PROGRESS_INTERVAL_SECONDS) option.on(:verbose, "Output details for internal operations.", :default => false) end @@ -173,7 +173,7 @@ class JoinCommand :loop => @loop, }, } - Droonga::DataAbsorber.new(absorber_options) + Droonga::DataAbsorberClient.new(absorber_options) end def set_source_node_role Renamed: lib/droonga/data_absorber_client.rb (+1 -1) 99% =================================================================== --- lib/droonga/data_absorber.rb 2015-04-15 13:09:16 +0900 (b002ffc) +++ lib/droonga/data_absorber_client.rb 2015-04-15 13:22:39 +0900 (096c4b5) @@ -19,7 +19,7 @@ require "droonga/catalog_generator" require "droonga/catalog_fetcher" module Droonga - class DataAbsorber + class DataAbsorberClient include Loggable DEFAULT_MESSAGES_PER_SECOND = 100 -------------- next part -------------- HTML����������������������������...Descargar
