WriterDecider.hpp

#pragma once
 
#include "cluster/Backend.hpp"
#include "cluster/ClioNode.hpp"
#include "cluster/impl/FallbackRecoveryTimer.hpp"
#include "etl/WriterState.hpp"
 
#include <boost/asio/thread_pool.hpp>
 
#include <chrono>
#include <memory>
 
namespace cluster {

class WriterDecider {
public:
    static constexpr std::chrono::steady_clock::duration kRECOVERY_TIME = std::chrono::hours{1};
 
private:
    boost::asio::thread_pool& ctx_;

    std::unique_ptr<etl::WriterStateInterface> writerState_;

    impl::FallbackRecoveryTimer fallbackRecoveryTimer_;
 
public:
    WriterDecider(
        boost::asio::thread_pool& ctx,
        std::unique_ptr<etl::WriterStateInterface> writerState,
        std::chrono::steady_clock::duration recoveryTime = kRECOVERY_TIME
    );

    void
    onNewState(ClioNode::CUuid selfId, std::shared_ptr<Backend::ClusterData const> clusterData);
};
 
}  // namespace cluster