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 |