Packages

rihanna

0.2.0
2.3.1 2.3.0 2.2.2 2.2.1 2.2.0 2.1.1 2.1.0 2.0.0 1.3.5 1.3.4 1.3.3 1.3.2 1.3.1 1.3.0 1.2.3 1.2.2 1.2.1 1.2.0 1.1.4 1.1.3 1.1.2 1.1.1 1.1.0 1.0.1 1.0.0 0.7.2 0.6.2 0.6.1 0.6.0 0.5.3 0.5.2 0.5.1 0.5.0 0.4.1 0.4.0 0.3.0 0.2.0 0.1.0

Rihanna is a database-backed job queue.

HexDocs

Current section

Files

Jump to
Readme
38 Versions
3 Dependencies
Dependants
Files
Activity
rihanna lib rihanna.ex
Raw

lib/rihanna.ex 

defmodule Rihanna do

  @moduledoc """

  TODO: Write some documentation for Rihanna.

  """

  def enqueue(mfa = {mod, fun, args}) when is_atom(mod) and is_atom(fun) and is_list(args) do

    job = %Rihanna.Job{

      mfa: mfa,

      state: "ready_to_run"

    }



    Rihanna.Repo.insert(job)

  end



  def enqueue(_) do

    raise ArgumentError, """

    Rihanna.Enqueue requires one argument in the form {mod, fun, args}.



    For example, to run IO.puts("Hello"):



    > Rihanna.enqueue({IO, :puts, ["Hello"]})

    """

  end

end