jobserver

README

jobserver

Overview

This is a job queue that uses SQLite as its backend. It's specifically designed to do what I want, and probably isn't in line with what you want. Please do go ahead and use it though, if you like it!

License

3-clause BSD. A copy is included with the source.

Documentation

Index

• Variables
• type Client
  • func Dial(addr string) (*Client, error)
  • func (c *Client) Delete(queue, id string) error
  • func (c *Client) Peek(queue string) (*Job, error)
  • func (c *Client) Ping() (time.Duration, error)
  • func (c *Client) Put(queue, id, content string, priority float64, holdUntil time.Time, ...) error
  • func (c *Client) Reserve(queue string) (*Job, error)
  • func (c *Client) ReserveWait(queue string) (*Job, error)
  • func (c *Client) SetRetries(n int)
  • func (c *Client) SetTimeout(t time.Duration)
• type ErrUnhandledType
• type Job

Variables

var (
	ErrTimeout  = errors.New("timed out")
	ErrNoJobs   = errors.New("no jobs")
	ErrNotFound = errors.New("not found")
)

Types

type Client

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

func Dial

func Dial(addr string) (*Client, error)

func (*Client) Delete

func (c *Client) Delete(queue, id string) error

func (*Client) Peek

func (c *Client) Peek(queue string) (*Job, error)

func (*Client) Ping

func (c *Client) Ping() (time.Duration, error)

func (*Client) Put

func (c *Client) Put(queue, id, content string, priority float64, holdUntil time.Time, ttr time.Duration) error

func (*Client) Reserve

func (c *Client) Reserve(queue string) (*Job, error)

func (*Client) ReserveWait

func (c *Client) ReserveWait(queue string) (*Job, error)

func (*Client) SetRetries

func (c *Client) SetRetries(n int)

func (*Client) SetTimeout

func (c *Client) SetTimeout(t time.Duration)

type ErrUnhandledType

type ErrUnhandledType error

type Job

type Job struct {
	ID        string
	Queue     string
	Priority  float64
	HoldUntil time.Time
	TTR       time.Duration
	Content   string
}