goku

README

goku

Golang Queue

Documentation

Index

• Constants
• Variables
• type Application
  • func NewRedis(name string, connInfo RedisConn, options interface{}, j ...Job) (Application, error)
• type Job
  • func NewJob(q string, fn interface{}, pt payloadType) (Job, error)
• type Options
• type Payload
• type Redis
  • func (r *Redis) AddJob(jobs ...Job) error
  • func (r *Redis) Enqueue(q string, p Payload) error
  • func (r *Redis) GetAppName() string
  • func (r *Redis) Start() error
• type RedisConn

Constants

const (
	POLLFREQ   = 10
	NUMWORKERS = 3
)

Variables

var (
	STRING = payloadType{"string"}
	INT    = payloadType{"int"}
)

Types

type Application

type Application interface {
	AddJob(j ...Job) error
	Enqueue(q string, p Payload) error
	GetAppName() string
	Start() error
}

func NewRedis

func NewRedis(name string, connInfo RedisConn, options interface{}, j ...Job) (Application, error)

type Job

type Job interface {
	Perform(data []byte) error
	GetQName() string
}

func NewJob

func NewJob(q string, fn interface{}, pt payloadType) (Job, error)

type Options

type Options struct {
	PollFreq   int
	NumWorkers int
}

type Payload

type Payload struct {
	PayloadType payloadType `json:"payloadType"`
	Data        []byte      `json:"data"`
}

type Redis

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

func (*Redis) AddJob

func (r *Redis) AddJob(jobs ...Job) error

func (*Redis) Enqueue

func (r *Redis) Enqueue(q string, p Payload) error

func (*Redis) GetAppName

func (r *Redis) GetAppName() string

func (*Redis) Start

func (r *Redis) Start() error

type RedisConn

type RedisConn gr.UniversalOptions

RedisConn . . . redis connection info