service.hpp

Go to the documentation of this file.

#ifndef KAGOME_TELEMETRY_SERVICE_HPP
#define KAGOME_TELEMETRY_SERVICE_HPP

#include <string>

#include "primitives/common.hpp"

namespace kagome::telemetry {

  enum class BlockOrigin {
    kGenesis,

    kNetworkInitialSync,

    kNetworkBroadcast,

    kConsensusBroadcast,

    kOwn,

    kFile,
  };

  class TelemetryService {
   public:
    virtual ~TelemetryService() = default;

    virtual void setGenesisBlockHash(const primitives::BlockHash &hash) = 0;

    virtual void notifyWasSynchronized() = 0;

    virtual void notifyBlockImported(const primitives::BlockInfo &info,
                                     BlockOrigin origin) = 0;

    virtual void notifyBlockFinalized(const primitives::BlockInfo &info) = 0;

    virtual bool isEnabled() const = 0;
  };

  using Telemetry = std::shared_ptr<TelemetryService>;

  void setTelemetryService(Telemetry service);

  Telemetry createTelemetryService();

}  // namespace kagome::telemetry

#endif  // KAGOME_TELEMETRY_SERVICE_HPP