LogDog: Add collector service implementation.

common/retry/transient.go

 // Copyright 2015 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 package retry
 
 import (
         "time"
 
         "github.com/luci/luci-go/common/errors"
@@ skipping 17 matching lines @@
 
 // TransientOnly returns an Iterator that wraps another Iterator. It will fall
 // through to the wrapped Iterator if a transient error is encountered;
 // otherwise, it will not retry.
 func TransientOnly(i Iterator) Iterator {
         if i == nil {
                 return nil
         }
         return &transientOnlyIterator{i}
 }
+
+// TransientOnlyGenerator wraps a retry.Generator, retrying only in the event
+// of Transient errors.
+func TransientOnlyGenerator(gen Generator) Generator {

[dnj (Google), 2016/01/21 04:36:24]

Now that we have the concept of a generator, we can chain it!

+        return func() Iterator {
+                return TransientOnly(gen())
+        }
+}