Sha256: 5d1ca3d2d50362392d082f893adec7c5555ad00409231edc7b47c854d24dfdf1

Contents?: true

Size: 779 Bytes

Versions: 2

Compression:

Stored size: 779 Bytes

Contents

# frozen_string_literal: true

class RegularWorker
  include Sidekiq::Worker

  def perform(foo); end
end

class BatchedSizeWorker
  include Sidekiq::Worker

  sidekiq_options queue: :batched_size, batch_flush_size: 3, batch_size: 2

  def perform(foo); end
end

class BatchedIntervalWorker
  include Sidekiq::Worker

  sidekiq_options queue: :batched_interval, batch_flush_interval: 3600

  def perform(foo); end
end

class BatchedBothWorker
  include Sidekiq::Worker

  sidekiq_options(
    queue: :batched_both, batch_flush_interval: 3600, batch_flush_size: 3
  )

  def perform(foo); end
end

class BatchedUniqueArgsWorker
  include Sidekiq::Worker

  sidekiq_options(
    queue: :batched_unique_args, batch_flush_size: 3, batch_unique: true
  )

  def perform(foo); end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version Path
sidekiq-grouping-1.3.0 spec/support/test_workers.rb
sidekiq-grouping-1.2.0 spec/support/test_workers.rb