Tracker.h

Go to the documentation of this file.

#pragma once

#include <swarmio/Endpoint.h>
#include <swarmio/data/Variant.pb.h>
#include <swarmio/data/telemetry/SubscribeRequest.pb.h>
#include <map>
#include <string>

namespace swarmio::services::telemetry 
{
    class Tracker final
    {
        private:

            const Node* _node;

            uint64_t _identifier;

            data::telemetry::SubscribeRequest _request;

            std::atomic<uint32_t> _currentTick;

            std::atomic<bool> _valid;

        public:

            Tracker(const Node* node, uint64_t identifier, const data::telemetry::SubscribeRequest& request)
                : _identifier(identifier), _request(request), _node(node), _currentTick(0), _valid(true) { }


            uint64_t GetIdentifier() const
            {
                return _identifier;
            }

            const Node* GetNode() const
            {
                return _node;
            }

            const data::telemetry::SubscribeRequest& GetRequest() const
            {
                return _request;
            }

            uint32_t GetTick() const
            {
                return _currentTick;
            }

            uint32_t GetAndIncrementTick()
            {
                return _currentTick++;
            }

            bool IsValid() const
            {
                return _valid;
            }

            void Invalidate()
            {
                _valid = false;
            }
    };
}