PublicationThrottle.h

Go to the documentation of this file.

/*
 * Copyright (c) 2026 MQSS Maintainers
 * All rights reserved.
 *
 * SPDX-License-Identifier: Apache-2.0 WITH LLVM-exception
 */

 
#pragma once
 
#include <chrono>
#include <optional>
 
namespace mqss::qrmci {

class PublicationThrottle {
public:
  using Clock = std::chrono::steady_clock;

  static constexpr Clock::duration DefaultInterval = std::chrono::seconds(5);

  explicit PublicationThrottle(Clock::duration interval = DefaultInterval)
      : publishInterval(interval) {}

  [[nodiscard]] bool claim(Clock::time_point now = Clock::now()) {
    if (lastClaimed.has_value() && now - *lastClaimed < publishInterval) {
      return false;
    }
    lastClaimed = now;
    return true;
  }

  [[nodiscard]] Clock::duration getInterval() const noexcept {
    return publishInterval;
  }
 
private:
  Clock::duration publishInterval;
  std::optional<Clock::time_point> lastClaimed;
};
 
} // namespace mqss::qrmci