metric service /metrics/value endpoint

-> remotefeedwriter make max_spread configurable

-> timeouts

-> rpcchannel (rcpclient + servergroup_)

-> rpc numRetries/retryStrategie, onRetry(Duration delay) (instead of ready()/onError!)

  }

}

Sample Metric::getSample() {

  auto snapshot = getSnapshot();

  if (snapshot.get() == nullptr) {

    RAISE(kIndexError, "metric has no samples");

  }

  MetricCursor cursor(snapshot, &token_index_);

  if (!cursor.valid()) {

    RAISE(kIndexError, "invalid metric cusor");

  }

  cursor.seekToMostRecentSample();

  auto smpl_reader = cursor.sample<double>();

  return Sample(

      cursor.time(),

      smpl_reader->value(),

      smpl_reader->labels());

}

void Metric::compact(CompactionPolicy* compaction /* = nullptr */) {

  if (!compaction_mutex_.try_lock()) {

    return;

      const fnord::DateTime& time_end,

      std::function<bool (Sample* sample)> callback) override;

  Sample getSample() override;

  void compact(CompactionPolicy* compaction = nullptr);

  void setLiveTableMaxSize(size_t max_size);

    token_index_(token_index),

    table_index_(0) {}

void MetricCursor::seekToMostRecentSample() {

  table_index_ = snapshot_->tables().size() - 1;

  table_cur_ = snapshot_->tables()[table_index_]->cursor();

  // FIXPAUL: this is too slow!

  while (table_cur_->next());

}

bool MetricCursor::next() {

  if (tableCursor()->next()) {

    return true;

  }

  while (table_index_ < (snapshot_->tables().size() - 1)) {

    table_cur_ = snapshot_->tables()[++table_index_]->cursor();

  bool next();

  bool valid();

  void seekToMostRecentSample();

  uint64_t time();

  template <typename T>