go-pkg/asynq
2
0
Fork 0
mirror of https://github.com/hibiken/asynq.git synced 2024-11-10 11:31:58 +08:00
Code Issues Projects Releases Wiki Activity

Misc cleanup

Browse Source
This commit is contained in:
Ken Hibino 2021-05-19 16:39:02 -07:00
parent 96c51fdc23
commit 8aeeb61c9d
1 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
inspector.go
View File

@ -137,15 +137,14 @@ func (i *Inspector) History(qname string, n int) ([]*DailyStats, error) {
var ( var (
// ErrQueueNotFound indicates that the specified queue does not exist. // ErrQueueNotFound indicates that the specified queue does not exist.
ErrQueueNotFound = errors.New("queue not found") ErrQueueNotFound = errors.New("queue not found")
// ErrQueueNotEmpty indicates that the specified queue is not empty. // ErrQueueNotEmpty indicates that the specified queue is not empty.
ErrQueueNotEmpty = errors.New("queue is not empty") ErrQueueNotEmpty = errors.New("queue is not empty")
// ErrTaskNotFound indicates that the specified task cannot be found in the queue. // ErrTaskNotFound indicates that the specified task cannot be found in the queue.
ErrTaskNotFound = errors.New("task not found") ErrTaskNotFound = errors.New("task not found")
) )
type taskNotFoundError struct {
}
// DeleteQueue removes the specified queue. // DeleteQueue removes the specified queue.
// //
// If force is set to true, DeleteQueue will remove the queue regardless of // If force is set to true, DeleteQueue will remove the queue regardless of