Documentation
¶
Index ¶
- type Dispatcher
- func (ds *Dispatcher) Dispatch(queueName string, job job.Job) error
- func (ds *Dispatcher) DispatchBatch(queueName string, jobs []job.Job) error
- func (ds *Dispatcher) DispatchBatchWithDelay(queueName string, jobs []job.Job, delay time.Duration) error
- func (ds *Dispatcher) DispatchWithDelay(queueName string, job job.Job, delay time.Duration) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Dispatcher ¶
type Dispatcher struct {
// contains filtered or unexported fields
}
func NewDispatcher ¶
func NewDispatcher(store adapter.Store, statsCollector *stats.Collector) *Dispatcher
func (*Dispatcher) DispatchBatch ¶
func (ds *Dispatcher) DispatchBatch(queueName string, jobs []job.Job) error
DispatchBatch adds multiple jobs to the queue in a single call.
func (*Dispatcher) DispatchBatchWithDelay ¶
func (ds *Dispatcher) DispatchBatchWithDelay(queueName string, jobs []job.Job, delay time.Duration) error
DispatchBatchWithDelay adds multiple jobs to the store for the given queue after a delay.
func (*Dispatcher) DispatchWithDelay ¶
DispatchWithDelay adds a job to the store for the given queue after a delay.
Source Files
Click to show internal directories.
Click to hide internal directories.