Kouhei Sutou
null+****@clear*****
Wed Nov 28 15:45:15 JST 2012
Kouhei Sutou 2012-11-28 15:45:15 +0900 (Wed, 28 Nov 2012) New Revision: a708e96c929b39cf8a4e364e00329ad7f6c6e48e https://github.com/groonga/fluent-plugin-groonga/commit/a708e96c929b39cf8a4e364e00329ad7f6c6e48e Log: Really support GQTP output Modified files: lib/fluent/plugin/out_groonga.rb Modified: lib/fluent/plugin/out_groonga.rb (+14 -0) =================================================================== --- lib/fluent/plugin/out_groonga.rb 2012-11-28 15:45:02 +0900 (bda90c1) +++ lib/fluent/plugin/out_groonga.rb 2012-11-28 15:45:15 +0900 (f2268f6) @@ -119,6 +119,20 @@ module Fluent config_param :host, :string, :default => "localhost" config_param :port, :integer, :default => 10041 + + def start + @client = GQTP::Client.new(:host => @host, + :port => @port, + :connection => :synchronous) + end + + def shutdown + end + + def send(command) + @client.send(command.to_command_format) do |header, body| + end + end end class CommandClient -------------- next part -------------- HTML����������������������������...ダウンロード
