go-pkg/asynq
2
0
Fork 0
mirror of https://github.com/hibiken/asynq.git synced 2024-12-27 00:02:19 +08:00
Code Issues Projects Releases Wiki Activity

Fix comments in Config

Browse Source
This commit is contained in:
Ken Hibino 2020-09-14 21:45:30 -07:00
parent 82b6828f43
commit a2d4ead989
1 changed files with 17 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
server.go
View File

@ -75,11 +75,13 @@ type Config struct {
// Priority is treated as follows to avoid starving low priority queues. // Priority is treated as follows to avoid starving low priority queues.
// //
// Example: // Example:
//
// Queues: map[string]int{ // Queues: map[string]int{
// "critical": 6, // "critical": 6,
// "default": 3, // "default": 3,
// "low": 1, // "low": 1,
// } // }
//
// With the above config and given that all queues are not empty, the tasks // With the above config and given that all queues are not empty, the tasks
// in "critical", "default", "low" should be processed 60%, 30%, 10% of // in "critical", "default", "low" should be processed 60%, 30%, 10% of
// the time respectively. // the time respectively.
@ -99,7 +101,10 @@ type Config struct {
// HandleError is invoked only if the task handler returns a non-nil error. // HandleError is invoked only if the task handler returns a non-nil error.
// //
// Example: // Example:
// func reportError(task *asynq.Task, err error, retried, maxRetry int) { //
// func reportError(ctx context, task *asynq.Task, err error) {
// retried, _ := asynq.GetRetryCount(ctx)
// maxRetry, _ := asynq.GetMaxRetry(ctx)
// if retried >= maxRetry { // if retried >= maxRetry {
// err = fmt.Errorf("retry exhausted for task %s: %w", task.Type, err) // err = fmt.Errorf("retry exhausted for task %s: %w", task.Type, err)
// } // }