data_source_status.hpp

#pragma once
 
#include <chrono>
#include <cstddef>
#include <cstdint>
#include <functional>
#include <memory>
#include <optional>
#include <utility>
 
#include <launchdarkly/connection.hpp>
#include <launchdarkly/data_sources/data_source_status_base.hpp>
 
namespace launchdarkly::client_side::data_sources {
 
enum class DataSourceState : std::int32_t {
    kInitializing = 0,
 
    kValid = 1,
 
    kInterrupted = 2,
 
    kSetOffline = 3,
 
    kShutdown = 4
};
 
char const* GetDataSourceStateName(DataSourceState state,
                                   char const* default_if_unknown);
 
using DataSourceStatus =
    common::data_sources::DataSourceStatusBase<DataSourceState>;
 
class IDataSourceStatusProvider {
   public:
    [[nodiscard]] virtual DataSourceStatus Status() const = 0;
 
    virtual std::unique_ptr<IConnection> OnDataSourceStatusChange(
        std::function<void(data_sources::DataSourceStatus status)> handler) = 0;
 
    virtual std::unique_ptr<IConnection> OnDataSourceStatusChangeEx(
        std::function<bool(data_sources::DataSourceStatus status)> handler) = 0;
 
    virtual ~IDataSourceStatusProvider() = default;
    IDataSourceStatusProvider(IDataSourceStatusProvider const& item) = delete;
    IDataSourceStatusProvider(IDataSourceStatusProvider&& item) = delete;
    IDataSourceStatusProvider& operator=(IDataSourceStatusProvider const&) =
        delete;
    IDataSourceStatusProvider& operator=(IDataSourceStatusProvider&&) = delete;
 
   protected:
    IDataSourceStatusProvider() = default;
};
 
std::ostream& operator<<(std::ostream& out,
                         DataSourceStatus::DataSourceState const& state);
 
std::ostream& operator<<(std::ostream& out, DataSourceStatus const& status);
 
}  // namespace launchdarkly::client_side::data_sources