diff --git a/retrieval/target.go b/retrieval/target.go index 862911ebaa..5953a061d4 100644 --- a/retrieval/target.go +++ b/retrieval/target.go @@ -219,10 +219,8 @@ func (app *limitAppender) AddFast(lset labels.Labels, ref uint64, t int64, v flo return errSampleLimit } } - if err := app.Appender.AddFast(lset, ref, t, v); err != nil { - return err - } - return nil + err := app.Appender.AddFast(lset, ref, t, v) + return err } type timeLimitAppender struct { @@ -247,10 +245,8 @@ func (app *timeLimitAppender) AddFast(lset labels.Labels, ref uint64, t int64, v if t > app.maxTime { return storage.ErrOutOfBounds } - if err := app.Appender.AddFast(lset, ref, t, v); err != nil { - return err - } - return nil + err := app.Appender.AddFast(lset, ref, t, v) + return err } // populateLabels builds a label set from the given label set and scrape configuration. diff --git a/retrieval/targetmanager.go b/retrieval/targetmanager.go index 97bf1696d8..e1b3af4042 100644 --- a/retrieval/targetmanager.go +++ b/retrieval/targetmanager.go @@ -50,6 +50,7 @@ type targetSet struct { sp *scrapePool } +// Appendable returns an Appender. type Appendable interface { Appender() (storage.Appender, error) }