resque

README

go-resque

Simple Resque queue client for Go.

Introduction

This is a fork of go-resque (one of many).

Differences from the original are:

• it is a Go module
• travis config is updated to use newer Go versions
• all drivers except one removed
• this driver is go-redis v9
• driver update required changes in some signatures to include context.Context
• also, in newer Redis versions some commands are deprecated, and I used suggested replacements (namely, ZRANGE instead of ZRANGEBYSCORE)

Installation

Installation is simple and familiar for Go programmers:

go get github.com/skaurus/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 (
	"context"

	"github.com/go-redis/redis/v9"            // Redis client from go-redis package
	"github.com/skaurus/go-resque"            // Import this package
	_ "github.com/skaurus/go-resque/redis.v9" // Use go-redis v9
)

func main() {
	var err error

	// Create new Redis client to use for enqueuing
	client := redis.NewClient(&redis.Options{
		Addr: "127.0.0.1:6379",
		DB:   0,
	})
	// Create enqueuer instance
	enqueuer := resque.NewRedisEnqueuer(context.Background(), "redis.v9", client, "resque:")

	// Enqueue the job into the "go" queue with appropriate client
	_, err = enqueuer.Enqueue(context.Background(), "go", "Demo::Job")
	if err != nil {
		panic(err)
	}

	// Enqueue into the "default" queue with passing one parameter to the Demo::Job.perform
	_, err = enqueuer.Enqueue(context.Background(), "default", "Demo::Job", 1)
	if err != nil {
		panic(err)
	}

	// Enqueue into the "extra" queue with passing multiple
	// parameters to the Demo::Job.perform so it will fail
	_, err = enqueuer.Enqueue(context.Background(), "extra", "Demo::Job", 1, 2, "woot")
	if err != nil {
		panic(err)
	}
}

Simple enough? I hope so.

Contributing

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

Documentation

Index

• func Register(name string, driver driver.Enqueuer)
• type MockRedisDriver
• type RedisEnqueuer
  • func NewRedisEnqueuer(ctx context.Context, drvName string, client interface{}, nameSpace string) *RedisEnqueuer
  • func (enqueuer *RedisEnqueuer) Enqueue(ctx context.Context, queue, jobClass string, args ...interface{}) (int64, error)
  • func (enqueuer *RedisEnqueuer) EnqueueIn(ctx context.Context, delay time.Duration, queue, jobClass string, ...) (bool, error)

Functions

func Register

func Register(name string, driver driver.Enqueuer)

Types

type MockRedisDriver

type MockRedisDriver struct {
	driver.Enqueuer
}

type RedisEnqueuer

type RedisEnqueuer struct {
	// contains filtered or unexported fields
}

func NewRedisEnqueuer

func NewRedisEnqueuer(ctx context.Context, drvName string, client interface{}, nameSpace string) *RedisEnqueuer

func (*RedisEnqueuer) Enqueue

func (enqueuer *RedisEnqueuer) Enqueue(ctx context.Context, queue, jobClass string, args ...interface{}) (int64, error)

func (*RedisEnqueuer) EnqueueIn

func (enqueuer *RedisEnqueuer) EnqueueIn(ctx context.Context, delay time.Duration, queue, jobClass string, args ...interface{}) (bool, error)

EnqueueIn enque a job at a duration