0.01
No commit activity in last 3 years
No release in over 3 years
Wouldn't be nice if you could directly queue your model method calls to Sidekiq? With Sidekiq::Delaty you can!
2005
2006
2007
2008
2009
2010
2011
2012
2013
2014
2015
2016
2017
2018
2019
2020
2021
2022
2023
2024
 Dependencies

Development

~> 1.3
>= 0
~> 3.0

Runtime

 Project Readme

Sidekiq::Delay Build Status Code Climate Coverage Status

Wouldn't be nice if you could easily queue model method calls to Sidekiq? With Sidekiq::Delay you can!

You have just to include a module and call delay before any method call. Actually, your model class have to respond to some methods, but if you are using ActiveRecord or Mongoid they already do.

NOTE: It doesn't support block arguments.

Installation

Add this line to your application's Gemfile:

gem 'sidekiq-delay'

And then execute:

$ bundle

Or install it yourself as:

$ gem install sidekiq-delay

Usage

First you have to include Sidekiq::Delay at your model.

  class Band
    include Mongoid::Document
    include Sidekiq::Delay

    field :name

    def play!
      # a long task
      sleep 3
    end
  end

Now you can delay method calls to a Sidekiq queue.

  band = Band.create(name: 'Daft Punk')
  band.delay.play!

How it works

It queues a job with model class, model id, method name and args. Later, at Sidekiq, it finds your model using class and id and calls method with args. Your class must respond to find(id) and return same model.

NOTE: Your model must be stored at database before delay any call.

Custom works

What if you class doesn't respond to find or you want to use another Sidekiq plugin? You can easily write a custom worker. You have just to set your model to use it with worker method.

Your worker just need to include Sidekiq::Delay::Strategy or extend Sidekiq::Delay::Worker.

  class TeamWorker
    include Sidekiq::Worker
    include Sidekiq::Delay::Strategy

    def record(klass, id)
      klass.custom_find(id)
    end
  end

  class Team
    include Mongoid::Document
    include Sidekiq::Delay

    worker TeamWorker

    field :name

    def self.custom_find(id)
      find(id)
    end

    def play!
      # a long task
      sleep 3
    end
  end

Contributing

  1. Fork it
  2. Create your feature branch (git checkout -b my-new-feature)
  3. Commit your changes (git commit -am 'Add some feature')
  4. Push to the branch (git push origin my-new-feature)
  5. Create new Pull Request