Kouhei Sutou
null+****@clear*****
Mon Feb 17 15:39:00 JST 2014
Kouhei Sutou 2014-02-17 15:39:00 +0900 (Mon, 17 Feb 2014) New Revision: e1c979c5d57e7924e960ea9df2d2b9e0cc07b544 https://github.com/droonga/fluent-plugin-droonga/commit/e1c979c5d57e7924e960ea9df2d2b9e0cc07b544 Message: Remove unused files Removed files: lib/droonga/handler_plugin.rb lib/droonga/planner_plugin.rb Deleted: lib/droonga/handler_plugin.rb (+0 -44) 100644 =================================================================== --- lib/droonga/handler_plugin.rb 2014-02-17 14:48:46 +0900 (35312e9) +++ /dev/null @@ -1,44 +0,0 @@ -# -*- coding: utf-8 -*- -# -# Copyright (C) 2013 Droonga Project -# -# This library is free software; you can redistribute it and/or -# modify it under the terms of the GNU Lesser General Public -# License version 2.1 as published by the Free Software Foundation. -# -# This library is distributed in the hope that it will be useful, -# but WITHOUT ANY WARRANTY; without even the implied warranty of -# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU -# Lesser General Public License for more details. -# -# You should have received a copy of the GNU Lesser General Public -# License along with this library; if not, write to the Free Software -# Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA - -require "droonga/legacy_plugin" -require "droonga/message_processing_error" - -module Droonga - class HandlerPlugin < LegacyPlugin - extend PluginRegisterable - - def initialize(handler) - super() - @handler = handler - @context =****@handl***** - end - - def prefer_synchronous?(command) - false - end - - private - def run_command(command, message, messenger) - begin - super - rescue MessageProcessingError => error - messenger.error(error.status_code, error.response_body) - end - end - end -end Deleted: lib/droonga/planner_plugin.rb (+0 -54) 100644 =================================================================== --- lib/droonga/planner_plugin.rb 2014-02-17 14:48:46 +0900 (6f37608) +++ /dev/null @@ -1,54 +0,0 @@ -# -*- coding: utf-8 -*- -# -# Copyright (C) 2013-2014 Droonga Project -# -# This library is free software; you can redistribute it and/or -# modify it under the terms of the GNU Lesser General Public -# License version 2.1 as published by the Free Software Foundation. -# -# This library is distributed in the hope that it will be useful, -# but WITHOUT ANY WARRANTY; without even the implied warranty of -# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU -# Lesser General Public License for more details. -# -# You should have received a copy of the GNU Lesser General Public -# License along with this library; if not, write to the Free Software -# Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA - -require "droonga/legacy_plugin" -require "droonga/distributed_command_planner" - -module Droonga - class PlannerPlugin < LegacyPlugin - extend PluginRegisterable - - def initialize(planner) - super() - @planner = planner - end - - def scatter(message, options={}) - planner = DistributedCommandPlanner.new(message) - planner.scatter - planner.key = options[:key] - planner.reduce(options[:reduce]) - planner.plan - end - - def broadcast(message, options={}) - planner = DistributedCommandPlanner.new(message) - planner.broadcast(:write => options[:write]) - planner.reduce(options[:reduce]) - planner.plan - end - - private - def process_error(command, error, arguments) - if error.is_a?(MessageProcessingError) - raise error - else - super - end - end - end -end -------------- next part -------------- HTML����������������������������...Download