Documentation ¶
Index ¶
- type Client
- func (c *Client) Clone() *Client
- func (c *Client) GetResult(taskId string, timeout time.Duration, sleepTime time.Duration) (message.Result, error)
- func (c *Client) GetStatus(taskId string, timeout time.Duration, sleepTime time.Duration) (int, error)
- func (c *Client) NewPromise(taskId string, handle InvarParamFunc, timeout time.Duration, ...) *Promise
- func (c *Client) Send(groupName string, workerName string, args ...interface{}) (string, error)
- func (c *Client) SetTaskCtl(name int, value interface{}) *Client
- type DelayServer
- func (b *DelayServer) BackendActivate()
- func (b *DelayServer) BrokerActivate()
- func (b *DelayServer) GetBackendPoolSize() int
- func (b *DelayServer) GetBrokerPoolSize() int
- func (b DelayServer) GetDelayGroupName(groupName string) string
- func (s *DelayServer) GetDelayMsgGoroutine()
- func (s *DelayServer) GetDelayMsgGoroutine_UpdateQueue(msg message.Message)
- func (b DelayServer) GetQueueName(groupName string) string
- func (s *DelayServer) GetReadyMsgGoroutine()
- func (s *DelayServer) GetReadyMsgGoroutine_Send(msg message.Message) (err error)
- func (b *DelayServer) GetResult(id string) (message.Result, error)
- func (s *DelayServer) IsRunning() bool
- func (s *DelayServer) IsStop() bool
- func (b *DelayServer) LSendMsg(groupName string, msg message.Message) error
- func (s *DelayServer) LSendQueue()
- func (b *DelayServer) Next(groupName string) (message.Message, error)
- func (s *DelayServer) Run()
- func (b *DelayServer) Send(groupName string, workerName string, ctl controller.TaskCtl, ...) (string, error)
- func (b *DelayServer) SendMsg(groupName string, msg message.Message) error
- func (s *DelayServer) SendReadyMsgGoroutine()
- func (s *DelayServer) SendReadyMsgGoroutine_Send(msg message.Message) (err error)
- func (b *DelayServer) SetBackendPoolSize(num int)
- func (b *DelayServer) SetBrokerPoolSize(num int)
- func (b *DelayServer) SetResult(result message.Result) error
- func (s *DelayServer) SetRunning()
- func (s *DelayServer) SetStop()
- func (s *DelayServer) Shutdown(ctx context.Context) error
- type InlineServer
- func (t *InlineServer) Add(workerName string, w interface{})
- func (b *InlineServer) BackendActivate()
- func (b *InlineServer) BrokerActivate()
- func (b *InlineServer) GetBackendPoolSize() int
- func (b *InlineServer) GetBrokerPoolSize() int
- func (b InlineServer) GetDelayGroupName(groupName string) string
- func (t *InlineServer) GetDelayMessageGoroutine()
- func (t *InlineServer) GetNextMessageGoroutine()
- func (b InlineServer) GetQueueName(groupName string) string
- func (b *InlineServer) GetResult(id string) (message.Result, error)
- func (t *InlineServer) IsRunning() bool
- func (t *InlineServer) IsStop() bool
- func (b *InlineServer) LSendMsg(groupName string, msg message.Message) error
- func (t *InlineServer) MakeWorkerReady()
- func (b *InlineServer) Next(groupName string) (message.Message, error)
- func (t *InlineServer) Run(numWorkers int)
- func (b *InlineServer) Send(groupName string, workerName string, ctl controller.TaskCtl, ...) (string, error)
- func (b *InlineServer) SendMsg(groupName string, msg message.Message) error
- func (b *InlineServer) SetBackendPoolSize(num int)
- func (b *InlineServer) SetBrokerPoolSize(num int)
- func (b *InlineServer) SetResult(result message.Result) error
- func (t *InlineServer) SetRunning()
- func (t *InlineServer) SetStop()
- func (t *InlineServer) Shutdown(ctx context.Context) error
- func (t *InlineServer) WorkerGoroutine()
- type InvarParamFunc
- type Promise
- type Server
- type SortQueue
- type VarParamFunc
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
func (*Client) GetResult ¶
func (c *Client) GetResult(taskId string, timeout time.Duration, sleepTime time.Duration) (message.Result, error)
taskId: timeout: sleepDuration:
func (*Client) GetStatus ¶
func (c *Client) GetStatus(taskId string, timeout time.Duration, sleepTime time.Duration) (int, error)
taskId: timeout: sleepDuration:
func (*Client) NewPromise ¶
func (*Client) SetTaskCtl ¶
type DelayServer ¶
func NewDelayServer ¶
func (*DelayServer) BackendActivate ¶
func (b *DelayServer) BackendActivate()
func (*DelayServer) BrokerActivate ¶
func (b *DelayServer) BrokerActivate()
func (*DelayServer) GetBackendPoolSize ¶
func (b *DelayServer) GetBackendPoolSize() int
func (*DelayServer) GetBrokerPoolSize ¶
func (b *DelayServer) GetBrokerPoolSize() int
func (DelayServer) GetDelayGroupName ¶
func (*DelayServer) GetDelayMsgGoroutine_UpdateQueue ¶
func (s *DelayServer) GetDelayMsgGoroutine_UpdateQueue(msg message.Message)
func (DelayServer) GetQueueName ¶
func (*DelayServer) GetReadyMsgGoroutine ¶
func (s *DelayServer) GetReadyMsgGoroutine()
从本地队列中获取到处理时间的任务,发送到readyMsgChan
func (*DelayServer) GetReadyMsgGoroutine_Send ¶
func (s *DelayServer) GetReadyMsgGoroutine_Send(msg message.Message) (err error)
func (*DelayServer) IsRunning ¶
func (s *DelayServer) IsRunning() bool
func (*DelayServer) IsStop ¶
func (s *DelayServer) IsStop() bool
func (*DelayServer) LSendQueue ¶
func (s *DelayServer) LSendQueue()
func (*DelayServer) Run ¶
func (s *DelayServer) Run()
func (*DelayServer) Send ¶
func (b *DelayServer) Send(groupName string, workerName string, ctl controller.TaskCtl, args ...interface{}) (string, error)
send msg to Queue t.Send("groupName", "workerName" , 1,"hi",1.2)
func (*DelayServer) SendReadyMsgGoroutine ¶
func (s *DelayServer) SendReadyMsgGoroutine()
从readyMsgChan中读取任务,传给inlineServer的Chan处理
func (*DelayServer) SendReadyMsgGoroutine_Send ¶
func (s *DelayServer) SendReadyMsgGoroutine_Send(msg message.Message) (err error)
func (*DelayServer) SetBackendPoolSize ¶
func (b *DelayServer) SetBackendPoolSize(num int)
func (*DelayServer) SetBrokerPoolSize ¶
func (b *DelayServer) SetBrokerPoolSize(num int)
func (*DelayServer) SetRunning ¶
func (s *DelayServer) SetRunning()
func (*DelayServer) SetStop ¶
func (s *DelayServer) SetStop()
type InlineServer ¶
func NewInlineServer ¶
func NewInlineServer(groupName string, c config.Config) InlineServer
func (*InlineServer) Add ¶
func (t *InlineServer) Add(workerName string, w interface{})
add worker to group w : worker func
func (*InlineServer) BackendActivate ¶
func (b *InlineServer) BackendActivate()
func (*InlineServer) BrokerActivate ¶
func (b *InlineServer) BrokerActivate()
func (*InlineServer) GetBackendPoolSize ¶
func (b *InlineServer) GetBackendPoolSize() int
func (*InlineServer) GetBrokerPoolSize ¶
func (b *InlineServer) GetBrokerPoolSize() int
func (InlineServer) GetDelayGroupName ¶
func (*InlineServer) GetDelayMessageGoroutine ¶
func (t *InlineServer) GetDelayMessageGoroutine()
func (*InlineServer) GetNextMessageGoroutine ¶
func (t *InlineServer) GetNextMessageGoroutine()
get next message if worker is ready
func (InlineServer) GetQueueName ¶
func (*InlineServer) IsRunning ¶
func (t *InlineServer) IsRunning() bool
func (*InlineServer) IsStop ¶
func (t *InlineServer) IsStop() bool
func (*InlineServer) MakeWorkerReady ¶
func (t *InlineServer) MakeWorkerReady()
func (*InlineServer) Run ¶
func (t *InlineServer) Run(numWorkers int)
func (*InlineServer) Send ¶
func (b *InlineServer) Send(groupName string, workerName string, ctl controller.TaskCtl, args ...interface{}) (string, error)
send msg to Queue t.Send("groupName", "workerName" , 1,"hi",1.2)
func (*InlineServer) SetBackendPoolSize ¶
func (b *InlineServer) SetBackendPoolSize(num int)
func (*InlineServer) SetBrokerPoolSize ¶
func (b *InlineServer) SetBrokerPoolSize(num int)
func (*InlineServer) SetRunning ¶
func (t *InlineServer) SetRunning()
func (*InlineServer) SetStop ¶
func (t *InlineServer) SetStop()
type InvarParamFunc ¶
type Promise ¶
type Promise struct {
// contains filtered or unexported fields
}
func (*Promise) Then ¶
func (p *Promise) Then(handle VarParamFunc) *Promise
type Server ¶
type Server struct { ServerMap map[string]*InlineServer // groupName:server DelayServerMap map[string]*DelayServer // groupName:server // contains filtered or unexported fields }
type SortQueue ¶
type VarParamFunc ¶
type VarParamFunc func(interface{}) (interface{}, error)
Click to show internal directories.
Click to hide internal directories.