Use errors.Is for error handling (#1187)

go-kit · Sep 28, 2021 · 9a1a7ad · 9a1a7ad
1 parent 2e73545
commit 9a1a7ad
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 4 deletions.
diff --git a/sd/consul/instancer.go b/sd/consul/instancer.go
@@ -70,7 +70,7 @@ func (s *Instancer) loop(lastIndex uint64) {
 		index := lastIndex
 		instances, index, err = s.getInstances(lastIndex, s.quitc)
 		switch {
-		case err == errStopped:
+		case errors.Is(err, errStopped):
 			return // stopped via quitc
 		case err != nil:
 			s.logger.Log("err", err)

diff --git a/transport/http/jsonrpc/server_test.go b/transport/http/jsonrpc/server_test.go
@@ -152,7 +152,7 @@ func TestServerBadEncode(t *testing.T) {
 func TestServerErrorEncoder(t *testing.T) {
 	errTeapot := errors.New("teapot")
 	code := func(err error) int {
-		if err == errTeapot {
+		if errors.Is(err, errTeapot) {
 			return http.StatusTeapot
 		}
 		return http.StatusInternalServerError

diff --git a/transport/http/server_test.go b/transport/http/server_test.go
@@ -59,7 +59,7 @@ func TestServerBadEncode(t *testing.T) {
 func TestServerErrorEncoder(t *testing.T) {
 	errTeapot := errors.New("teapot")
 	code := func(err error) int {
-		if err == errTeapot {
+		if errors.Is(err, errTeapot) {
 			return http.StatusTeapot
 		}
 		return http.StatusInternalServerError

diff --git a/transport/nats/subscriber_test.go b/transport/nats/subscriber_test.go
@@ -116,7 +116,7 @@ func TestSubscriberErrorEncoder(t *testing.T) {
 
 	errTeapot := errors.New("teapot")
 	code := func(err error) error {
-		if err == errTeapot {
+		if errors.Is(err, errTeapot) {
 			return err
 		}
 		return errors.New("dang")