From 8117ce89720529865e75365ac3ea093a7e62f6bc Mon Sep 17 00:00:00 2001 From: Ken Hibino Date: Sun, 9 May 2021 19:20:54 -0700 Subject: [PATCH] Minor fixes --- internal/base/base.go | 8 -------- internal/rdb/rdb.go | 4 ++-- internal/rdb/rdb_test.go | 2 +- 3 files changed, 3 insertions(+), 11 deletions(-) diff --git a/internal/base/base.go b/internal/base/base.go index 5384e76..db9c145 100644 --- a/internal/base/base.go +++ b/internal/base/base.go @@ -7,7 +7,6 @@ package base import ( "context" - "errors" "fmt" "sync" "time" @@ -590,10 +589,3 @@ type Broker interface { PublishCancelation(id string) error Close() error } - -// List of canonical errors. -var ( - ErrNotFound = errors.New("not found") - ErrFailedPrecondition = errors.New("failed precondition") - ErrInternal = errors.New("internal error") -) diff --git a/internal/rdb/rdb.go b/internal/rdb/rdb.go index 1969664..f71158c 100644 --- a/internal/rdb/rdb.go +++ b/internal/rdb/rdb.go @@ -95,9 +95,9 @@ if not ok then end redis.call("HSET", KEYS[2], "msg", ARGV[3], - "state", "pending", + "state", "pending", "timeout", ARGV[4], - "deadline", ARGV[5]) + "deadline", ARGV[5]) redis.call("LPUSH", KEYS[3], ARGV[1]) return 1 `) diff --git a/internal/rdb/rdb_test.go b/internal/rdb/rdb_test.go index 234cc14..830d2c5 100644 --- a/internal/rdb/rdb_test.go +++ b/internal/rdb/rdb_test.go @@ -112,7 +112,7 @@ func TestEnqueue(t *testing.T) { } deadline := r.client.HGet(taskKey, "deadline").Val() // "deadline" field if want := strconv.Itoa(int(tc.msg.Deadline)); deadline != want { - t.Errorf("deadline field under task-ke is set to %v, want %v", deadline, want) + t.Errorf("deadline field under task-key is set to %v, want %v", deadline, want) } // Check queue is in the AllQueues set.