Contents

module Flydata
  module Helper
    class ActionOwnership
      attr_accessor :action_name

      # Resource change flag
      # true -> action must be taken exclusively
      attr_accessor :resource_change

      # action_class has a actual logic
      attr_accessor :action_class

      # Owner should be nil(channel) or worker
      attr_accessor :owner

      # last processeed time should be updated when worker return
      # action ownership to channel
      attr_accessor :last_processed_time

      attr_accessor :retry_count

      def initialize(action_name, resource_change = false, action_class = nil)
        @action_name = action_name
        @resource_change = resource_change
        @action_class = action_class
        @owner = nil
        @last_processed_time = -1
        @retry_count = 0
      end

      def processing?
        !@owner.nil?
      end

      def reset_retry_count
        @retry_count = 0
      end

      def increment_retry_count
        @retry_count += 1
      end

      def self.action_ownership_map
        [
          self.new(:check_remote_actions, false, Action::CheckRemoteActions),
          self.new(:check_abnormal_shutdown, false, Action::CheckAbnormalShutdown),
          self.new(:send_logs, false, Action::SendLogs),
          self.new(:stop_agent, true, Action::StopAgent),
          self.new(:restart_agent, true, Action::RestartAgent),
          self.new(:update_helper_config, false, Action::UpdateHelperConfig),
          self.new(:repair, true, Action::Repair),
        ].inject({}) do |h, action|
          h[action.action_name] = action
          h
        end
      end
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
flydata-0.7.19	lib/flydata/helper/action_ownership.rb
flydata-0.7.18	lib/flydata/helper/action_ownership.rb
flydata-0.7.17	lib/flydata/helper/action_ownership.rb
flydata-0.7.16	lib/flydata/helper/action_ownership.rb