From 1363896ca9832070af17919cf1d71c65a3c2e643 Mon Sep 17 00:00:00 2001
From: Jackie Li <jackie.li@fuseim.com>
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