Contents

require 'daemon_runner/shell_out'

module Cassandra
  module Utils
    module CLI
      class Base
        attr_reader :command, :stdout

        def cwd
          '/tmp'
        end

        def timeout
          300
        end

        def runner
          @command ||= DaemonRunner::ShellOut.new(command: command, cwd: cwd, timeout: timeout)
        end

        def output
          raise NotImplementedError, 'Must implement this in a subclass'
        end

        def run!
          runner
          @command.run!
          @stdout = @command.stdout
          out = output
          Utils::Statsd.new(metric_name).to_dd(out).push!
          out
        end
      end
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
cassandra-utils-0.4.1	lib/cassandra/utils/cli/base.rb
cassandra-utils-0.4.0	lib/cassandra/utils/cli/base.rb
cassandra-utils-0.3.2	lib/cassandra/utils/cli/base.rb