Navigation Menu

Skip to content

Commit

Permalink
Use OpenStruct instead of Hash
Browse files Browse the repository at this point in the history
  • Loading branch information
piroor committed Jun 27, 2014
1 parent bc668b7 commit 6900d1a
Showing 1 changed file with 23 additions and 17 deletions.
40 changes: 23 additions & 17 deletions bin/droonga-engine-absorb-data
Expand Up @@ -22,73 +22,79 @@ require "open3"
require "droonga/engine/version"
require "droonga/data_absorber"

options = {
:drndump => "drndump",
:client => "droonga-request",
}
options = OpenStruct.new
options.drndump = "drndump"
options.client = "droonga-request"
parser = OptionParser.new
parser.version = Droonga::Engine::VERSION

parser.separator("")
parser.separator("Source:")
parser.on("--source-host=HOST",
"Host name of the source cluster to be connected.") do |host|
options[:source_host] = host
options.source_host = host
end
parser.on("--source-port=PORT", Integer,
"Port number of the source cluster to be connected.") do |port|
options[:port] = port
options.port = port
end

parser.separator("")
parser.separator("Destination:")
parser.on("--destination-host=HOST",
"Host name of this cluster to be connected.") do |host|
options[:destination_host] = host
options.destination_host = host
end
parser.on("--destination-port=PORT", Integer,
"Port number of this cluster to be connected.") do |port|
options[:port] = port
options.port = port
end

parser.separator("")
parser.separator("Data:")
parser.on("--tag=TAG",
"Tag name to be used to communicate with Droonga system.") do |tag|
options[:tag] = tag
options.tag = tag
end
parser.on("--dataset=DATASET",
"Dataset to be absorbed.") do |dataset|
options[:dataset] = dataset
options.dataset = dataset
end

parser.separator("")
parser.separator("Droonga protocol:")
parser.on("--receiver-host=HOST",
"Host name of this node to be received a response from clusters.") do |host|
options[:destination_host] = host
options.destination_host = host
end
parser.on("--receiver-port=PORT", Integer,
"Port number of this node to be received a response from clusters.") do |port|
options[:receiver_port] = port
options.receiver_port = port
end

parser.separator("")
parser.separator("Commands:")
parser.on("--drndump=PATH",
"Path to the drndump command.",
"(#{options[:client]})") do |path|
options[:drndump] = path
"(#{options.client})") do |path|
options.drndump = path
end
parser.on("--droonga-request=PATH",
"Path to the droonga-request command.",
"(#{options[:client]})") do |path|
options[:client] = path
"(#{options.client})") do |path|
options.client = path
end

parser.parse!(ARGV)

Droonga::DataAbsorber.absorb(options) do |dump|
Droonga::DataAbsorber.absorb(:drndump => options.drndump,
:client => options.client,
:dataset => options.dataset,
:source_host => options.replica_source_host,
:destination_host => options.my_host,
:port => options.port,
:tag => options.tag,
:receiver_port => options.receiver_port) do |dump|
puts dump
end

Expand Down

0 comments on commit 6900d1a

Please sign in to comment.