server

May 20, 2024

Changes in this version

type Server

+ TLSPrivateKey string

+ TLSPublicCert string

Jun 7, 2022

Changes in this version

type ClientData

+ func (worker *ClientData) ConnectionCount() int

Jul 14, 2021

Changes in this version

+ var DefaultMaxPoolSize = 1000

type ClientData

+ Username string

Mar 1, 2021

Changes in this version

+ var AlwaysMatch = func(value string) bool

+ var CommandSet = map[string]command

+ type ClientBeat struct

+ CurrentState string

+ RssKb int64

+ Wid string

+ type ClientData struct

+ Hostname string

+ Labels []string

+ PasswordHash string

+ Pid int

+ RssKb int64

+ StartedAt time.Time

+ Version uint8

+ Wid string

+ func (worker *ClientData) IsConsumer() bool

+ func (worker *ClientData) IsQuiet() bool

+ func (worker *ClientData) Signal(newstate WorkerState)

type Server

+ Subsystems []Subsystem

+ func (s *Server) AddTask(everySec int64, task Taskable)

+ func (s *Server) Boot() error

+ func (s *Server) CurrentState() (map[string]interface{}, error)

+ func (s *Server) Manager() manager.Manager

+ func (s *Server) Register(x Subsystem)

+ func (s *Server) Reload()

+ func (s *Server) Run() error

+ func (s *Server) Stopper() chan bool

type ServerOptions

+ GlobalConfig map[string]interface{}

+ Password string

+ PoolSize int

+ RedisSock string

+ func (so *ServerOptions) Config(subsys string, key string, defval interface{}) interface{}

+ func (so *ServerOptions) String(subsys string, key string, defval string) string

+ type Subsystem interface

+ Name func() string

+ Reload func(*Server) error

+ Start func(*Server) error

+ type Taskable interface

+ Execute func() error

+ Name func() string

+ Stats func() map[string]interface{}

+ type WorkerState int

+ const Quiet

+ const Running

+ const Terminate

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