From 1363896ca9832070af17919cf1d71c65a3c2e643 Mon Sep 17 00:00:00 2001 From: Jackie Li Date: Mon, 1 Jul 2019 21:14:39 +0100 Subject: [PATCH] add todo --- api.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/api.go b/api.go index c0df39d..9f5cb03 100644 --- a/api.go +++ b/api.go @@ -47,6 +47,7 @@ func New(redisDSN string) (*Process, error) { worker := server.NewWorker("worker0", runtime.NumCPU()) worker.LaunchAsync(errChan) + // TODO: use redis pool redisConn, err := redis.Dial("tcp", strings.Replace(redisDSN, "redis://", "", -1)) if err != nil { return nil, errors.Wrap(err, "init new process") @@ -211,6 +212,7 @@ type JobQuery struct { // OpenJobQuery returns a new job query func OpenJobQuery(redisDSN string) (*JobQuery, error) { host := strings.Replace(redisDSN, "redis://", "", -1) + // TODO: use redis pool redisConn, err := redis.Dial("tcp", host) if err != nil { return nil, err