Sha256: 8b52f84928e2a868a93550d4fefe506175a6a0d4d0051715766dbef454a3cc5e
Contents?: true
Size: 753 Bytes
Versions: 10
Compression:
Stored size: 753 Bytes
Contents
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
10 entries across 10 versions & 1 rubygems