Contents

require_relative "queue_metric_tracker"

module WorkerRoulette
  class BatchSize
    include ::QueueMetricTracker

    def track(sender, work_orders, _remaining)
      return unless enabled?

      batch_size = work_orders.length
      return if batch_size == 0

      if value = calculate_stats(:batch_size, batch_size)
        tracker_send(message("batch_size", channel(sender), value))
      end
    end
  end
end

Version data entries

7 entries across 7 versions & 1 rubygems

Version	Path
nexia_worker_roulette-0.2.9	lib/worker_roulette/batch_size.rb
nexia_worker_roulette-0.2.8	lib/worker_roulette/batch_size.rb
nexia_worker_roulette-0.2.7	lib/worker_roulette/batch_size.rb
nexia_worker_roulette-0.2.6	lib/worker_roulette/batch_size.rb
nexia_worker_roulette-0.2.5	lib/worker_roulette/batch_size.rb
nexia_worker_roulette-0.2.4	lib/worker_roulette/batch_size.rb
nexia_worker_roulette-0.2.3	lib/worker_roulette/batch_size.rb