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

tumble/service.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 tumble
 
 import (
         "fmt"
         "net/http"
         "net/url"
         "strconv"
         "strings"
         "time"
 
         "github.com/luci/luci-go/appengine/gaemiddleware"
         "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/common/sync/parallel"
         "github.com/luci/luci-go/server/router"
 
         ds "github.com/luci/gae/service/datastore"
         "github.com/luci/gae/service/info"
 
         "golang.org/x/net/context"
 )
 
 const (
@@ skipping 190 matching lines @@
                 return
         }
 
         cfg := getConfig(c)
 
         logging.Infof(c, "Processing tasks in namespace %q", info.GetNamespace(c))
         err = processShard(c, cfg, time.Unix(tstamp, 0).UTC(), sid, loop)
         if err != nil {
                 logging.Errorf(c, "failure! %s", err)
 
-                if errors.IsTransient(err) {
+                if retry.Tag.In(err) {
                         rw.Header().Add(transientHTTPHeader, "true")
                 }
                 rw.WriteHeader(http.StatusInternalServerError)
                 fmt.Fprintf(rw, "error: %s", err)
         } else {
                 rw.Write([]byte("ok"))
         }
 }
 
 // getDatastoreNamespaces returns a list of all of the namespaces in the
@@ skipping 37 matching lines @@
                 query.Set("ns", ns)
         }
         if !loop {
                 query.Set("single", "1")
         }
         if len(query) > 0 {
                 v += "?" + query.Encode()
         }
         return v
 }