Kouhei Sutou
null+****@clear*****
Fri Sep 2 16:59:41 JST 2016
Kouhei Sutou 2016-09-02 16:59:41 +0900 (Fri, 02 Sep 2016) New Revision: 2ddfbb0dd5b318a0b412965225d4bd58edf9907f https://github.com/groonga/fluent-plugin-groonga/commit/2ddfbb0dd5b318a0b412965225d4bd58edf9907f Message: Add more default emit target commands Modified files: lib/fluent/plugin/in_groonga.rb Modified: lib/fluent/plugin/in_groonga.rb (+24 -5) =================================================================== --- lib/fluent/plugin/in_groonga.rb 2016-09-02 16:54:00 +0900 (e7cbfaa) +++ lib/fluent/plugin/in_groonga.rb 2016-09-02 16:59:41 +0900 (05ee2cb) @@ -89,13 +89,29 @@ module Fluent config_param :real_host, :string config_param :real_port, :integer, :default => nil DEFAULT_EMIT_COMMANDS = [ - /\Atable_/, - /\Acolumn_/, + "clearlock", + "column_copy", + "column_create", + "column_remove", + "column_rename", + "config_delete", + "config_set", "delete", - /\Aplugin_/, + "load", + "lock_acquire", + "lock_clear", + "lock_release", + "logical_table_remove", + "object_remove", + "plugin_register", + "plugin_unregister", "register", + "reindex", + "table_copy", + "table_create", + "table_remove", + "table_rename", "truncate", - "load", ] config_param :emit_commands, :default => DEFAULT_EMIT_COMMANDS do |value| commands = value.split(/\s*,\s*/) @@ -232,7 +248,10 @@ module Fluent private def need_emit?(response) - return true if @request_handler.command == "load" + case @request_handler.command + when "load", "object_remove" + return true + end case response when Array -------------- next part -------------- HTML����������������������������...Download
