Navigation Menu

Skip to content

Commit

Permalink
Add "Client" suffix for DataAbsorber.
Browse files Browse the repository at this point in the history
Because there is another Droonga::Plugins::System::AbsorbDataHandler::DataAbsober.
  • Loading branch information
piroor committed Apr 15, 2015
1 parent 05a82ef commit cc4389c
Show file tree
Hide file tree
Showing 3 changed files with 9 additions and 9 deletions.
8 changes: 4 additions & 4 deletions bin/droonga-engine-absorb-data
Expand Up @@ -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"
Expand Down Expand Up @@ -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
Expand Down Expand Up @@ -163,7 +163,7 @@ class AbsorbDataCommand
:loop => @loop,
},
}
Droonga::DataAbsorber.new(absorber_options)
Droonga::DataAbsorberClient.new(absorber_options)
end

def absorb
Expand Down
8 changes: 4 additions & 4 deletions bin/droonga-engine-join
Expand Up @@ -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"

Expand Down Expand Up @@ -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
Expand Down Expand Up @@ -173,7 +173,7 @@ class JoinCommand
:loop => @loop,
},
}
Droonga::DataAbsorber.new(absorber_options)
Droonga::DataAbsorberClient.new(absorber_options)
end

def set_source_node_role
Expand Down
Expand Up @@ -19,7 +19,7 @@
require "droonga/catalog_fetcher"

module Droonga
class DataAbsorber
class DataAbsorberClient
include Loggable

DEFAULT_MESSAGES_PER_SECOND = 100
Expand Down

0 comments on commit cc4389c

Please sign in to comment.