From 764edc35e3938b8a8f20a6fc5752d27d26fcc85b Mon Sep 17 00:00:00 2001 From: Ken Hibino Date: Mon, 9 Dec 2019 06:52:43 -0800 Subject: [PATCH] [ci skip] Update todos --- asynq.go | 3 ++- client.go | 4 ++-- 2 files changed, 4 insertions(+), 3 deletions(-) diff --git a/asynq.go b/asynq.go index e32209a..bed372e 100644 --- a/asynq.go +++ b/asynq.go @@ -4,7 +4,7 @@ import "github.com/go-redis/redis/v7" /* TODOs: -- [P0] command to retry tasks from "retry", "dead" queue +- [P0] enqall command to enq all tasks from "scheduled" "retry", "dead" queue - [P0] Go docs + CONTRIBUTION.md + Github issue template - [P1] Add Support for multiple queues and priority - [P1] User defined max-retry count @@ -24,6 +24,7 @@ type Task struct { } // RedisConfig specifies redis configurations. +// TODO(hibiken): Support more configuration. type RedisConfig struct { Addr string Password string diff --git a/client.go b/client.go index a13b04b..c3ae3ea 100644 --- a/client.go +++ b/client.go @@ -9,7 +9,7 @@ import ( // A Client is responsible for scheduling tasks. // -// A Client is used to register task that should be processed +// A Client is used to register tasks that should be processed // immediately or some time in the future. // // Clients are safe for concurrent use by multiple goroutines. @@ -25,7 +25,7 @@ func NewClient(cfg *RedisConfig) *Client { // Process registers a task to be processed at the specified time. // -// Process returns nil if the task was registered successfully, +// Process returns nil if the task is registered successfully, // otherwise returns non-nil error. func (c *Client) Process(task *Task, processAt time.Time) error { msg := &rdb.TaskMessage{