Kouhei Sutou
null+****@clear*****
Sun Mar 23 21:09:47 JST 2014
Kouhei Sutou 2014-03-23 21:09:47 +0900 (Sun, 23 Mar 2014) New Revision: c7b3f40c15f84e8d5f9e879942fc470104937dcc https://github.com/droonga/droonga-client-ruby/commit/c7b3f40c15f84e8d5f9e879942fc470104937dcc Message: Add --messages-per-second option Modified files: bin/droonga-send Modified: bin/droonga-send (+10 -2) =================================================================== --- bin/droonga-send 2014-03-23 21:09:35 +0900 (8be307a) +++ bin/droonga-send 2014-03-23 21:09:47 +0900 (c045303) @@ -27,6 +27,7 @@ options = { servers = [] default_server = "droonga:localhost:24224/droonga" +messages_per_second = Droonga::Client::RateLimiter::NO_LIMIT def parse_server(server) connect_info, tag = server.split(/\//, 2) @@ -41,7 +42,7 @@ end parser = OptionParser.new parser.banner += " REQUEST_JSON_FILE1 REQUEST_JSON_FILE2 ..." parser.separator("") -parser.separator("Connect:") +parser.separator("Connection:") parser.on("--server=PROTOCOL:HOST:PORT/TAG", "Droonga server to be connected.", "Use multiple servers to use round-robin requests.", @@ -49,6 +50,12 @@ parser.on("--server=PROTOCOL:HOST:PORT/TAG", "(#{default_server})") do |server| servers << server end +parser.on("--messages-per-second=N", Integer, + "Apply rate limitation by N messages/second.", + "'#{Droonga::Client::RateLimiter::NO_LIMIT}' means no limit.", + "(#{messages_per_second})") do |n| + messages_per_second = n +end parser.separator("") parser.separator("Report:") parser.on("--[no-]report-request", @@ -61,7 +68,8 @@ request_json_files = parser.parse!(ARGV) servers << default_server if servers.empty? clients = servers.collect do |server| options = parse_server(server) - Droonga::Client.new(options) + client = Droonga::Client.new(options) + Droonga::Client::RateLimiter.new(client, messages_per_second) end client_index = 0 -------------- next part -------------- HTML����������������������������...ダウンロード
