2
0
mirror of https://github.com/hibiken/asynq.git synced 2024-12-27 00:02:19 +08:00

Fix doc indentation

This commit is contained in:
Ken Hibino 2021-01-28 19:37:17 -08:00
parent 430b01c9aa
commit 8eafa03ca7

View File

@ -5,27 +5,18 @@
/* /*
Package inspeq provides helper types and functions to inspect queues and tasks managed by Asynq. Package inspeq provides helper types and functions to inspect queues and tasks managed by Asynq.
Inspector is used to query and mutate the state of queues. Inspector is used to query and mutate the state of queues and tasks.
inspector := inspeq.New(asynq.RedisConnOpt{Addr: "localhost:6379"}) Example:
// Query tasks from a queue. inspector := inspeq.New(asynq.RedisClientOpt{Addr: "localhost:6379"})
archived, err := inspector.ListArchivedTasks("my_queue")
if err != nil {
// handle error
}
// Take action on a task. tasks, err := inspector.ListArchivedTasks("my-queue")
for _, t := range archived {
if err := inspector.RunTaskByKey(t.Key()); err != nil { for _, t := range tasks {
if err := inspector.DeleteTaskByKey(t.Key()); err != nil {
// handle error // handle error
} }
} }
// Take action on all tasks of a specified state.
n, err := inspector.DeleteAllRetryTasks("my_queue")
if err != nil {
// handle error
}
*/ */
package inspeq package inspeq