heartbeater.hh

Go to the documentation of this file.

/*
 * heatbeater.hh
 *
 *  Created on: Apr 26, 2019
 *      Author: N.S. Oblath
 */
 
#ifndef DRIPLINE_HEARTBEATER_HH_
#define DRIPLINE_HEARTBEATER_HH_
 
#include "dripline_api.hh"
#include "dripline_fwd.hh"
#include "uuid.hh"
 
#include "cancelable.hh"
#include "member_variables.hh"
 
#include <thread>
 
namespace dripline
{
 
    class DRIPLINE_API heartbeater : public virtual scarab::cancelable
    {
        public:
            heartbeater( service* a_service );
            heartbeater( const heartbeater& ) = delete;
            heartbeater( heartbeater&& a_orig ) = default;
            virtual ~heartbeater() = default;
 
            heartbeater& operator=( const heartbeater& ) = delete;
            heartbeater& operator=( heartbeater&& a_orig ); // we have to explicitly define this because of the virtual inheritance of scarab::cancelable
 
            void execute( const std::string& a_name, uuid_t a_id, const std::string& a_routing_key );
 
            mv_accessible( unsigned, heartbeat_interval_s );
            mv_accessible( unsigned, check_timeout_ms );
 
            mv_accessible( service*, service );
 
            //mv_atomic( bool, stop );
 
        protected:
            std::thread f_heartbeat_thread;
 
    };
 
} /* namespace dripline */
 
#endif /* DRIPLINE_HEARTBEATER_HH_ */