Documentation ¶
Index ¶
- func WorkerGoroutines(goroutines int) func(*Client)
- func WorkerLogger(logger log.Logger) func(*Client)
- func WorkerProcessor(processor Processor) func(*Client)
- func WorkerPuller(puller Puller) func(*Client)
- func WorkerPusher(pusher Pusher) func(*Client)
- func WorkerTimeout(timeout time.Duration) func(*Client)
- type Client
- type Processor
- type Puller
- type Pusher
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func WorkerGoroutines ¶
WorkerGoroutines set the quantity of goroutines used to process the queue.
func WorkerLogger ¶
WorkerLogger set the worker logger.
func WorkerProcessor ¶
WorkerProcessor set the processor at Worker.
func WorkerPuller ¶
WorkerPuller set the puller at worker.
func WorkerPusher ¶
WorkerPusher set the pusher at worker.
func WorkerTimeout ¶
WorkerTimeout set the default timeout duration for a task to process.
Types ¶
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
Client implements the logic to process tasks.
Click to show internal directories.
Click to hide internal directories.