connection.hpp

Go to the documentation of this file.

#ifndef KAGOME_TELEMETRY_CONNECTION_HPP
#define KAGOME_TELEMETRY_CONNECTION_HPP

#include <functional>
#include <memory>
#include <string>

#include "telemetry/endpoint.hpp"

namespace kagome::telemetry {

  class TelemetryConnection {
   public:
    using OnConnectedCallback =
        std::function<void(std::shared_ptr<TelemetryConnection>)>;

    virtual ~TelemetryConnection() = default;

    virtual void connect() = 0;

    virtual const TelemetryEndpoint &endpoint() const = 0;

    virtual void send(const std::string &data) = 0;

    virtual void send(std::size_t message_handle) = 0;

    virtual bool isConnected() const = 0;

    virtual void shutdown() = 0;
  };

}  // namespace kagome::telemetry

#endif  // KAGOME_TELEMETRY_CONNECTION_HPP