diff --git a/asynq.go b/asynq.go index d1abfa0..210ef69 100644 --- a/asynq.go +++ b/asynq.go @@ -138,7 +138,7 @@ func (opt RedisFailoverClientOpt) MakeRedisClient() interface{} { }) } -// RedisFailoverClientOpt is used to creates a redis client that connects to +// RedisClusterClientOpt is used to creates a redis client that connects to // redis cluster. type RedisClusterClientOpt struct { // A seed list of host:port addresses of cluster nodes. diff --git a/server_test.go b/server_test.go index 32e79b5..0343ada 100644 --- a/server_test.go +++ b/server_test.go @@ -70,7 +70,7 @@ func TestServerRun(t *testing.T) { go func() { select { case <-time.After(10 * time.Second): - t.Fatal("server did not stop after receiving TERM signal") + panic("server did not stop after receiving TERM signal") case <-done: } }()