module SidekiqBulk

Public Instance Methods

push_bulk(items, limit: 10_000, &block) click to toggle source

# File lib/sidekiq/bulk.rb, line 4
def push_bulk(items, limit: 10_000, &block)
  job_ids = items.each_slice(limit).map do |group|
    push_bulk!(group, &block)
  end

  job_ids.flatten
end

push_bulk!(items, &block) click to toggle source

# File lib/sidekiq/bulk.rb, line 12
def push_bulk!(items, &block)
  if block
    args = items.map(&block)
  else
    args = items.map { |el| [el] }
  end

  Sidekiq::Client.push_bulk("class" => self, "args" => args)
end