WARNING!

Currently README is OUTDATED! Work in progress!

Use v0.1.0 if you need previous implementation.

go-resque

Simple Resque queue client for Go.

Installation

Installation is simple and familiar for Go programmers:

go get github.com/kavu/go-resque

Usage

Let's assume that you have such Resque Job (taken from Resque examples):

module Demo
  class Job
    def self.perform(params)
      puts "Processed a job!"
    end
  end
end

So, we can enqueue this job from Go.

package main

import (
  "github.com/kavu/go-resque" // Import this package
  _ "github.com/kavu/go-resque/godis" // Use godis driver
  "github.com/simonz05/godis/redis" // Redis client from godis package
)

func main() {
  client := redis.New("tcp:127.0.0.1:6379", 0, "") // Create new Redis client to use for enqueuing
  enqueuer := resque.NewRedisEnqueuer("godis", client) // Create enqueuer instance

  // Enqueue the job into the "go" queue with appropriate client
  enqueuer.Enqueue("go", "Demo::Job")

  // Enqueue into the "default" queue with passing one parameter to the Demo::Job.perform
  enqueuer.Enqueue("default", "Demo::Job", 1)

  // Enqueue into the "default" queue with passing multiple
  // parameters to the Demo::Job.perform so it will fail
  enqueuer.Enqueue("default", "Demo::Job", 1, 2, "woot")
}

Simple enough? I hope so.

Contributing

Just open pull request or ping me directly on e-mail, if you want to discuss some ideas.

One more thing

This package was done in one evening like an experiment and Proof of Concept, so, please, don't judge me so harsh.