Versions in this module Expand all Collapse all v0 v0.0.1 Jun 30, 2020 Changes in this version + type Client struct + RetryCount string + func NewClient(server *Server) Client + func (c *Client) Clone() *Client + func (c *Client) GetResult(taskId string, timeout time.Duration, sleepTime time.Duration) (message.Result, error) + func (c *Client) Send(groupName string, workerName string, args ...interface{}) (string, error) + func (c *Client) SetTaskCtl(name string, value interface{}) *Client + type Server struct + ResultExpires int + StatusExpires int + func NewServer(c config.Config) Server + func (t *Server) Add(groupName string, workerName string, w interface{}) + func (t *Server) GetClient() Client + func (t *Server) GetNextMessageGoroutine(groupName string) + func (t *Server) GetQueryName(groupName string) string + func (t *Server) GetResult(id string) (message.Result, error) + func (t *Server) MakeWorkerReady() + func (t *Server) Next(groupName string) (message.Message, error) + func (t *Server) Run(groupName string, numWorkers int) + func (t *Server) Send(groupName string, workerName string, ctl controller.TaskCtl, ...) (string, error) + func (t *Server) SetResult(result message.Result) error + func (t *Server) Shutdown(ctx context.Context) error + func (t *Server) WorkerGoroutine(groupName string)
Go to main page