machinery

Oct 22, 2019

Changes in this version

type Worker

+ func (worker *Worker) SetTaskFinishedCallback(callback func(signature *tasks.Signature))

+ func (worker *Worker) SetTaskStartedCallback(callback func(signature *tasks.Signature))

Dec 18, 2018

Changes in this version

+ func ParseGCPPubSubURL(url string) (string, string, error)

Sep 24, 2018

Changes in this version

type Server

+ func NewServerWithBrokerBackend(cnf *config.Config, brokerServer brokersiface.Broker, ...) *Server

Aug 23, 2018

Changes in this version

type Worker

+ func (worker *Worker) GetServer() *Server

Aug 4, 2018

Changes in this version

type Server

+ func (server *Server) NewCustomQueueWorker(consumerTag string, concurrency int, queue string) *Worker

type Worker

+ Queue string

+ func (worker *Worker) CustomQueue() string

May 4, 2018

Changes in this version

type Worker

+ func (worker *Worker) SetErrorHandler(handler func(err error))

Mar 4, 2018

Changes in this version

type Server

+ func (server *Server) SendChainWithContext(ctx context.Context, chain *tasks.Chain) (*backends.ChainAsyncResult, error)

+ func (server *Server) SendChordWithContext(ctx context.Context, chord *tasks.Chord, sendConcurrency int) (*backends.ChordAsyncResult, error)

+ func (server *Server) SendGroupWithContext(ctx context.Context, group *tasks.Group, sendConcurrency int) ([]*backends.AsyncResult, error)

+ func (server *Server) SendTaskWithContext(ctx context.Context, signature *tasks.Signature) (*backends.AsyncResult, error)

Nov 15, 2017

Changes in this version

type Worker

+ func (worker *Worker) LaunchAsync(errorsChan chan<- error)

Aug 27, 2017

Changes in this version

+ func BackendFactory(cnf *config.Config) (backends.Interface, error)

+ func BrokerFactory(cnf *config.Config) (brokers.Interface, error)

+ func ParseRedisSocketURL(url string) (path, password string, db int, err error)

+ func ParseRedisURL(url string) (host, password string, db int, err error)

+ type Server struct

+ func NewServer(cnf *config.Config) (*Server, error)

+ func (server *Server) GetBackend() backends.Interface

+ func (server *Server) GetBroker() brokers.Interface

+ func (server *Server) GetConfig() *config.Config

+ func (server *Server) GetRegisteredTask(name string) (interface{}, error)

+ func (server *Server) GetRegisteredTaskNames() []string

+ func (server *Server) IsTaskRegistered(name string) bool

+ func (server *Server) NewWorker(consumerTag string, concurrency int) *Worker

+ func (server *Server) RegisterTask(name string, taskFunc interface{}) error

+ func (server *Server) RegisterTasks(namedTaskFuncs map[string]interface{}) error

+ func (server *Server) SendChain(chain *tasks.Chain) (*backends.ChainAsyncResult, error)

+ func (server *Server) SendChord(chord *tasks.Chord, sendConcurrency int) (*backends.ChordAsyncResult, error)

+ func (server *Server) SendGroup(group *tasks.Group, sendConcurrency int) ([]*backends.AsyncResult, error)

+ func (server *Server) SendTask(signature *tasks.Signature) (*backends.AsyncResult, error)

+ func (server *Server) SetBackend(backend backends.Interface)

+ func (server *Server) SetBroker(broker brokers.Interface)

+ func (server *Server) SetConfig(cnf *config.Config)

+ type Worker struct

+ Concurrency int

+ ConsumerTag string

+ func (worker *Worker) Launch() error

+ func (worker *Worker) Process(signature *tasks.Signature) error

+ func (worker *Worker) Quit()