| 218 | } |
| 219 | |
| 220 | func (h *writeHandler) appendV1Samples(app storage.Appender, ss []prompb.Sample, labels labels.Labels) error { |
| 221 | var ref storage.SeriesRef |
| 222 | var err error |
| 223 | for _, s := range ss { |
| 224 | ref, err = app.Append(ref, labels, s.GetTimestamp(), s.GetValue()) |
| 225 | if err != nil { |
| 226 | if errors.Is(err, storage.ErrOutOfOrderSample) || |
| 227 | errors.Is(err, storage.ErrOutOfBounds) || |
| 228 | errors.Is(err, storage.ErrDuplicateSampleForTimestamp) || |
| 229 | errors.Is(err, storage.ErrTooOldSample) { |
| 230 | h.logger.Error("Out of order sample from remote write", "err", err.Error(), "series", labels.String(), "timestamp", s.Timestamp) |
| 231 | } |
| 232 | return err |
| 233 | } |
| 234 | } |
| 235 | return nil |
| 236 | } |
| 237 | |
| 238 | func (h *writeHandler) appendV1Histograms(app storage.Appender, hh []prompb.Histogram, labels labels.Labels) error { |
| 239 | var err error |