storage.hpp

#pragma once
 
/// @file userver/alert/storage.hpp
/// @brief @copybrief alert::Storage
 
#include <chrono>
#include <string>
#include <vector>
 
#include <userver/concurrent/variable.hpp>
 
USERVER_NAMESPACE_BEGIN
 
namespace alerts {
 
struct Alert final {
    std::string id;
    std::string description;
    std::chrono::steady_clock::time_point stop_timepoint;
};
 
inline constexpr auto kDefaultDuration = std::chrono::seconds{120};
inline constexpr auto kInfinity = std::chrono::hours{24 * 999};
 
/// @ingroup userver_clients
///
/// @brief Storage for active fired alerts.
class Storage final {
public:
    Storage() = default;
    Storage(const Storage&) = delete;
    Storage(Storage&&) = delete;
 
    /// Fire an alert. It will be stopped either after `StopAlertNow` for the
    /// `alert_id` is called or after `duration` seconds.
    void FireAlert(
        std::string_view alert_id,
        std::string_view description,
        std::chrono::seconds duration = kDefaultDuration
    ) noexcept;
 
    /// Stop an alert before its duration has ended.
    void StopAlertNow(std::string_view alert_id) noexcept;
 
    /// Collect fired and active alerts.
    std::vector<Alert> CollectActiveAlerts();
 
private:
    static void DoStopAlertNow(std::string_view alert_id, std::vector<Alert>& alerts);
 
    concurrent::Variable<std::vector<Alert>> alerts_;
};
 
}  // namespace alerts
 
USERVER_NAMESPACE_END