Lease leases tasks from a queue. leaseTime is in seconds. The number of tasks fetched will be at most maxTasks.
(c context.Context, maxTasks int, queueName string, leaseTime int)
| 434 | // leaseTime is in seconds. |
| 435 | // The number of tasks fetched will be at most maxTasks. |
| 436 | func Lease(c context.Context, maxTasks int, queueName string, leaseTime int) ([]*Task, error) { |
| 437 | return lease(c, maxTasks, queueName, leaseTime, false, nil) |
| 438 | } |
| 439 | |
| 440 | // LeaseByTag leases tasks from a queue, grouped by tag. |
| 441 | // If tag is empty, then the returned tasks are grouped by the tag of the task with earliest ETA. |
nothing calls this directly
no test coverage detected
searching dependent graphs…