class Sidekiq::Datadog::Monitor::Data

Attributes

agent_host[R]
agent_port[R]
batch[R]
cron[R]
env[R]
queue[R]
tags[R]

Public Class Methods

initialize!(options) click to toggle source
# File lib/sidekiq/datadog/monitor/data.rb, line 8
def initialize!(options)
  @agent_port, @agent_host, @queue = options.fetch_values(:agent_port, :agent_host, :queue)
  @tags = options[:tags] || []
  @cron = options[:cron] || '*/1 * * * *'
  @batch = options[:batch] || false

  Sidekiq.configure_server do |config|
    SidekiqScheduler::Scheduler.dynamic = true

    config.on(:startup) do
      start
    end
  end
rescue StandardError => e
  raise Sidekiq::Datadog::Monitor::Error, e.message
end

Private Class Methods

start() click to toggle source
# File lib/sidekiq/datadog/monitor/data.rb, line 27
def start
  Sidekiq.set_schedule('send_metrics',
                       { 'cron' => cron, 'class' => 'Sidekiq::Datadog::Monitor::MetricsWorker', 'queue' => queue })
end