module COMOClient

Constants

VERSION

Attributes

configuration[W]

Public Class Methods

configuration() click to toggle source
# File lib/como_client.rb, line 31
def self.configuration
  @configuration ||= Configuration.new
end
configure() { |configuration| ... } click to toggle source
# File lib/como_client.rb, line 39
def self.configure
  yield(configuration)
  self.run
end
logger() click to toggle source
# File lib/como_client.rb, line 13
def self.logger
  @@logger ||= defined?(Rails) ? Rails.logger : Logger.new(STDOUT)
end
logger=(logger) click to toggle source
# File lib/como_client.rb, line 17
def self.logger=(logger)
  @@logger = logger
end
reset() click to toggle source
# File lib/como_client.rb, line 35
def self.reset
  @configuration = Configuration.new
end
run() click to toggle source
# File lib/como_client.rb, line 44
def self.run

  COMOClient.logger.debug("initialise metrics push service...")
  if @pushTask and @pushTask.running?
    COMOClient.logger.debug("push service is already running!")
    return true
  end

  COMOClient::Metrics.register
  @pushTask = Concurrent::TimerTask.new(execution_interval: @configuration.push_interval, timeout_interval: 20){COMOClient::Tasks::PeriodicPush.push}
  @pushTask.add_observer(COMOClient::Tasks::Observer.new)
  @pushTask.execute
  COMOClient.logger.info("push service initialised")
  @pushTask.running?
end
stop() click to toggle source
# File lib/como_client.rb, line 60
def self.stop
  @pushTask.shutdown
end