subscription_fwd.hpp

Go to the documentation of this file.

#ifndef IROHA_SUBSCRIPTION_FWD_HPP
#define IROHA_SUBSCRIPTION_FWD_HPP

#include <memory>

namespace iroha {
  enum SubscriptionEngineHandlers {
    kYac = 0,
    kRequestProposal,
    kVoteProcess,
    kMetrics,
    //---------------
    kTotalCount
  };

  enum EventTypes {
    kOnOutcome = 0,
    kOnSynchronization,
    kOnInitialSynchronization,
    kOnCurrentRoundPeers,
    kOnRoundSwitch,
    kOnProposal,
    kOnVerifiedProposal,
    kOnProcessedHashes,
    kOnOutcomeFromYac,
    kOnOutcomeDelayed,
    kOnBlock,
    kOnInitialBlock,
    kOnBlockCreatorEvent,
    kOnFinalizedTxs,
    kOnApplyState,
    kOnNeedProposal,
    kOnNewProposal,
    kOnNewBatchInCache,
    kOnPackProposal,
    kOnProposalResponse,
    kOnTransactionResponse,
    kOnConsensusGateEvent,

    // MST
    kOnStateUpdate,
    kOnPreparedBatches,
    kOnExpiredBatches,

    // YAC
    kTimer,
    kOnState,

    // TEST
    kOnTestOperationComplete
  };

  static constexpr uint32_t kThreadPoolSize = 3u;

  namespace subscription {
    struct IDispatcher;

    template <uint32_t kHandlersCount, uint32_t kPoolSize>
    class SubscriptionManager;

    template <typename EventKey,
              typename Dispatcher,
              typename Receiver,
              typename... Arguments>
    class SubscriberImpl;
  }  // namespace subscription

  using Dispatcher = subscription::IDispatcher;
  using Subscription =
      subscription::SubscriptionManager<SubscriptionEngineHandlers::kTotalCount,
                                        kThreadPoolSize>;
  template <typename ObjectType, typename... EventData>
  using BaseSubscriber = subscription::
      SubscriberImpl<EventTypes, Dispatcher, ObjectType, EventData...>;

}  // namespace iroha

#endif  // IROHA_SUBSCRIPTION_FWD_HPP