Class Counter

include/process/metrics/counter.hpp:26–80

A Metric that represents an integer value that can be incremented and decremented.

// A Metric that represents an integer value that can be incremented and
// decremented.
class Counter : public Metric
{
public:
  // 'name' is the unique name for the instance of Counter being constructed.
  // This is what will be used as the key in the JSON endpoint.
  // 'window' is the amount of history to keep for this Metric.
  Counter(const std::string& name, const Option<Duration>& window = None())
    : Metric(name, window),
      data(new Data())
  {
    push(static_cast<double>(data->value.load()));
  }

  ~Counter() override {}

  Future<double> value() const override
  {
    return static_cast<double>(data->value.load());
  }

  void reset()
  {
    data->value.store(0);
    push(0);
  }

  Counter& operator++()
  {
    return *this += 1;
  }

  Counter operator++(int)
  {
    Counter c(*this);
    ++(*this);
    return c;
  }

  Counter& operator+=(int64_t v)
  {
    int64_t prev = data->value.fetch_add(v);
    push(static_cast<double>(prev + v));
    return *this;
  }

private:
  struct Data
  {
    explicit Data() : value(0) {}

    std::atomic<int64_t> value;
  };

  std::shared_ptr<Data> data;
};

} // namespace metrics {
} // namespace process {