v0.8.3

CHANGELOG.md

@@ -7,6 +7,12 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 ## [Unreleased]
 
+## [0.8.3] - 2020-05-08
+
+### Added
+
+- `Close` method is added to `Client`.
+
 ## [0.8.2] - 2020-05-03
 
 ### Fixed

README.md

@@ -147,6 +147,7 @@ const redisAddr = "127.0.0.1:6379"
 func main() {
     r := asynq.RedisClientOpt{Addr: redisAddr}
     c := asynq.NewClient(r)
+    defer c.Close()
 
     // ----------------------------------------------------
     // Example 1: Enqueue task to be processed immediately.

client.go

@@ -209,6 +209,11 @@ func (c *Client) EnqueueIn(d time.Duration, task *Task, opts ...Option) error {
 	return c.enqueueAt(time.Now().Add(d), task, opts...)
 }
 
+// Close closes the connection with redis server.
+func (c *Client) Close() error {
+	return c.rdb.Close()
+}
+
 func (c *Client) enqueueAt(t time.Time, task *Task, opts ...Option) error {
 	c.mu.Lock()
 	defer c.mu.Unlock()