LeaseByTag leases tasks from a queue, grouped by tag. If tag is empty, then the returned tasks are grouped by the tag of the task with earliest ETA. leaseTime is in seconds. The number of tasks fetched will be at most maxTasks.
(c context.Context, maxTasks int, queueName string, leaseTime int, tag string)
| 442 | // leaseTime is in seconds. |
| 443 | // The number of tasks fetched will be at most maxTasks. |
| 444 | func LeaseByTag(c context.Context, maxTasks int, queueName string, leaseTime int, tag string) ([]*Task, error) { |
| 445 | return lease(c, maxTasks, queueName, leaseTime, true, []byte(tag)) |
| 446 | } |
| 447 | |
| 448 | // Purge removes all tasks from a queue. |
| 449 | func Purge(c context.Context, queueName string) error { |
nothing calls this directly
no test coverage detected
searching dependent graphs…