Contents

require 'daemon_runner'

module Cassandra
  module Utils
    class Daemon < ::DaemonRunner::Client

      def tasks
        [
          [seed_registry_task, 'run!'],
          [auto_clean_task, 'run!'],
          [health_stat, 'run!'],
          [compaction_stat, 'run!'],
          [cleanup_stat, 'run!']
        ]
      end

      private

      def seed_registry_task
        name = options[:seed_service_name]
        @seed_registry_task ||= ::Cassandra::Tasks::SeedRegistry.new(name)
      end

      def auto_clean_task
        @auto_clean_task ||= ::Cassandra::Tasks::Autoclean.new(options)
      end

      def health_stat
        @health_stat ||= ::Cassandra::Utils::Stats::Health.new
      end

      def compaction_stat
        @compaction_stat ||= ::Cassandra::Utils::Stats::Compaction.new
      end

      def cleanup_stat
        @cleanup_stat ||= ::Cassandra::Utils::Stats::Cleanup.new
      end
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
cassandra-utils-0.4.1	lib/cassandra/utils/daemon.rb
cassandra-utils-0.4.0	lib/cassandra/utils/daemon.rb