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

[ci skip] Update todos

Browse Source
This commit is contained in:
Ken Hibino 2019-12-09 06:52:43 -08:00
parent 8932ca41b3
commit 764edc35e3
2 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
asynq.go
View File

@ -4,7 +4,7 @@ import "github.com/go-redis/redis/v7"
/* /*
TODOs: 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 - [P0] Go docs + CONTRIBUTION.md + Github issue template
- [P1] Add Support for multiple queues and priority - [P1] Add Support for multiple queues and priority
- [P1] User defined max-retry count - [P1] User defined max-retry count
@ -24,6 +24,7 @@ type Task struct {
} }
// RedisConfig specifies redis configurations. // RedisConfig specifies redis configurations.
// TODO(hibiken): Support more configuration.
type RedisConfig struct { type RedisConfig struct {
Addr string Addr string
Password string Password string

4
client.go
View File

@ -9,7 +9,7 @@ import (
// A Client is responsible for scheduling tasks. // 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. // immediately or some time in the future.
// //
// Clients are safe for concurrent use by multiple goroutines. // 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 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. // otherwise returns non-nil error.
func (c *Client) Process(task *Task, processAt time.Time) error { func (c *Client) Process(task *Task, processAt time.Time) error {
msg := &rdb.TaskMessage{ msg := &rdb.TaskMessage{