Documentation ¶
Index ¶
- Constants
- type Options
- type Router
- func (r *Router) Dispatch(f func() error, callback ...queue.Finalizer) queue.Task
- func (r *Router) DispatchPath(path string, f func() error, callback ...queue.Finalizer) queue.Task
- func (r *Router) DispatchPathTask(path string, task queue.Task)
- func (r *Router) DispatchTask(f queue.Task)
- func (r *Router) Stop()
- func (r *Router) StopByID(id string)
Constants ¶
View Source
const ( DefaultWorkerSize = 100 DefaultWorkerSpwanSize = 10 DefaultWorkerCap = 10 )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Options ¶
type Options func(*Router)
func WithNewQueueFunc ¶
func WithWorkerGroupCap ¶
func WithWorkerSize ¶
func WithWorkerSpwanSize ¶
Click to show internal directories.
Click to hide internal directories.