Versions in this module Expand all Collapse all v0 v0.5.0 Oct 25, 2017 Changes in this version + var DefaultTimeout = 1800 + var EventHandlers = make([]func(*Server) error, 0) + func CurrentState(s *Server) (map[string]interface{}, error) + func OnStart(x func(*Server) error) + type ClientWorker struct + Hostname string + Labels []string + PasswordHash string + Pid int + Salt string + StartedAt time.Time + Wid string + func (worker *ClientWorker) BusyCount() int + func (worker *ClientWorker) IsQuiet() bool + func (worker *ClientWorker) Signal(sig string) + type Connection struct + func (c *Connection) Close() + func (c *Connection) Error(cmd string, err error) error + func (c *Connection) Identity() string + func (c *Connection) Number(val int) error + func (c *Connection) Ok() error + func (c *Connection) Result(msg []byte) error + type FailPayload struct + Backtrace []string + ErrorMessage string + ErrorType string + Jid string + type Reservation struct + Expiry string + Job *faktory.Job + Since string + Wid string + type RuntimeStats struct + Commands int64 + Connections int64 + Failures int64 + Processed int64 + StartedAt time.Time + type Server struct + Options *ServerOptions + Password string + Stats *RuntimeStats + TLSConfig *tls.Config + func NewServer(opts *ServerOptions) (*Server, error) + func (s *Server) Fail(jid, msg, errtype string, backtrace []string) error + func (s *Server) Fetch(fn func(*faktory.Job) error, ctx context.Context, queues ...string) (*faktory.Job, error) + func (s *Server) Heartbeats() map[string]*ClientWorker + func (s *Server) Start() error + func (s *Server) Stop(f func()) + func (s *Server) Store() storage.Store + type ServerOptions struct + Binding string + ConfigDirectory string + DisableTls bool + Environment string + StorageDirectory string + type TimedSet interface + AddElement func(string, string, []byte) error + RemoveElement func(string, string) error