Versions in this module Expand all Collapse all v0 v0.5.0 Oct 25, 2017 Changes in this version + var License = "GPLv3" + var Licensing = "Licensed under the GNU Public License 3.0" + var Name = "Faktory" + var RandomProcessWid = strconv.FormatInt(rand.Int63(), 32) + var Version = "0.5.0" + type Client struct + Location string + Options *ClientData + func Dial(srv *Server, password string) (*Client, error) + func Open() (*Client, error) + func (c *Client) Ack(jid string) error + func (c *Client) Beat() (string, error) + func (c *Client) Close() error + func (c *Client) Fail(jid string, err error, backtrace []byte) error + func (c *Client) Fetch(q ...string) (*Job, error) + func (c *Client) Flush() error + func (c *Client) Generic(cmdline string) (string, error) + func (c *Client) Info() (map[string]interface{}, error) + func (c *Client) Push(job *Job) error + type ClientData struct + Hostname string + Labels []string + PasswordHash string + Pid int + Salt string + Wid string + type Failure struct + Backtrace []string + ErrorMessage string + ErrorType string + FailedAt string + NextAt string + RetryCount int + type Job struct + Args []interface{} + At string + Backtrace int + CreatedAt string + Custom map[string]interface{} + EnqueuedAt string + Failure *Failure + Jid string + Queue string + ReserveFor int + Retry int + Type string + func NewJob(jobtype string, args ...interface{}) *Job + type ProtocolError struct + func (pe *ProtocolError) Error() string + type Server struct + Address string + Network string + Timeout time.Duration + func DefaultServer() *Server