MonitorInterface.hpp

#pragma once
 
#include <boost/signals2/connection.hpp>
#include <boost/signals2/signal.hpp>
#include <boost/signals2/variadic_signal.hpp>
 
#include <chrono>
#include <cstdint>
 
namespace etl {

class MonitorInterface {
public:
    static constexpr auto kDefaultRepeatInterval = std::chrono::seconds{1};
    using NewSequenceSignalType = boost::signals2::signal<void(uint32_t)>;
    using DbStalledSignalType = boost::signals2::signal<void()>;
 
    virtual ~MonitorInterface() = default;

    virtual void
    notifySequenceLoaded(uint32_t seq) = 0;

    virtual void
    notifyWriteConflict(uint32_t seq) = 0;

    [[nodiscard]] virtual boost::signals2::scoped_connection
    subscribeToNewSequence(NewSequenceSignalType::slot_type const& subscriber) = 0;

    [[nodiscard]] virtual boost::signals2::scoped_connection
    subscribeToDbStalled(DbStalledSignalType::slot_type const& subscriber) = 0;

    virtual void
    run(std::chrono::steady_clock::duration repeatInterval = kDefaultRepeatInterval) = 0;

    virtual void
    stop() = 0;
};
 
}  // namespace etl