From 72a276e7edcf3a7abfd2b2eea509cfa895f49526 Mon Sep 17 00:00:00 2001 From: Brian Brazil Date: Thu, 25 May 2017 17:11:29 +0100 Subject: [PATCH] Pass through storage errors in limitAppender. --- retrieval/target.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/retrieval/target.go b/retrieval/target.go index 708125d92..72e0f0b23 100644 --- a/retrieval/target.go +++ b/retrieval/target.go @@ -238,11 +238,11 @@ type limitAppender struct { func (app *limitAppender) Add(lset labels.Labels, t int64, v float64) (string, error) { if app.i+1 > app.limit { - return "", errors.New("sample limit exceeded") + return "", fmt.Errorf("sample limit of %d exceeded", app.limit) } ref, err := app.Appender.Add(lset, t, v) if err != nil { - return "", fmt.Errorf("sample limit of %d exceeded", app.limit) + return "", err } app.i++ return ref, nil @@ -250,11 +250,11 @@ func (app *limitAppender) Add(lset labels.Labels, t int64, v float64) (string, e func (app *limitAppender) AddFast(ref string, t int64, v float64) error { if app.i+1 > app.limit { - return errors.New("sample limit exceeded") + return fmt.Errorf("sample limit of %d exceeded", app.limit) } if err := app.Appender.AddFast(ref, t, v); err != nil { - return fmt.Errorf("sample limit of %d exceeded", app.limit) + return err } app.i++ return nil