Method recordSuccess

pkg/dequeuer/batch_handler.go:90–96

()

}

func (h *BatchMessageHandler) recordSuccess() error {
	err := h.metrics.Incr("cortex_batch_succeeded", h.tags, 1.0)
	if err != nil {
		return errors.WithStack(err)
	}
	return nil
}

func (h *BatchMessageHandler) recordFailure() error {
	err := h.metrics.Incr("cortex_batch_failed", h.tags, 1.0)