Minor fixes

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")
-)

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
 `)

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.