[errors] de-specialize Transient in favor of Tags.

appengine/gaeauth/server/internal/authdbimpl/handlers.go

 // Copyright 2015 The LUCI Authors. All rights reserved.
 // Use of this source code is governed under the Apache License, Version 2.0
 // that can be found in the LICENSE file.
 
 package authdbimpl
 
 import (
         "fmt"
         "io/ioutil"
         "net/http"
         "net/url"
 
         "golang.org/x/net/context"
         "google.golang.org/appengine"
 
         "github.com/luci/gae/service/info"
 
         "github.com/luci/luci-go/common/errors"
         "github.com/luci/luci-go/common/logging"
+        "github.com/luci/luci-go/common/retry"
         "github.com/luci/luci-go/server/auth/service"
         "github.com/luci/luci-go/server/router"
 )
 
 const (
         pubSubPullURLPath = "/auth/pubsub/authdb:pull" // dev server only
         pubSubPushURLPath = "/auth/pubsub/authdb:push"
 )
 
 // InstallHandlers installs PubSub related HTTP handlers.
@@ skipping 112 matching lines @@
         }
 
         replyOK(
                 c, rw, "Processed PubSub notification for rev %d: %d -> %d",
                 notify.Revision, info.Rev, latest.Rev)
 }
 
 // replyError sends HTTP 500 on transient errors, HTTP 400 on fatal ones.
 func replyError(c context.Context, rw http.ResponseWriter, err error) {
         logging.Errorf(c, "Error while processing PubSub notification - %s", err)
-        if errors.IsTransient(err) {
+        if retry.Tag.In(err) {
                 http.Error(rw, err.Error(), http.StatusInternalServerError)
         } else {
                 http.Error(rw, err.Error(), http.StatusBadRequest)
         }
 }
 
 // replyOK sends HTTP 200.
 func replyOK(c context.Context, rw http.ResponseWriter, msg string, args ...interface{}) {
         logging.Infof(c, msg, args...)
         rw.Write([]byte(fmt.Sprintf(msg, args...)))
 }