SharedMemoryBootstrapPlugin.h

Go to the documentation of this file.

#ifndef LINTEL_SHAREDMEMORYBOOTSTRAPPLUGIN_H
#define LINTEL_SHAREDMEMORYBOOTSTRAPPLUGIN_H
 
#include <memory>
 
#include "lintel/core/configuration/Configuration.h"
#include "lintel/core/configuration/DatabaseConnectionEntry.h"
#include "lintel/core/persistence/DatabaseConnectionConfigurations.h"
#include "lintel/core/plugins/BootstrapPlugin.h"
#include "lintel/features/base/configuration/EventBusEntry.h"
#include "lintel/features/base/events/EventBus.h"
#include "lintel/features/base/repositories/SharedMemoryRepository.h"
#include "lintel/features/base/services/SharedMemorySegmentManager.h"
 
namespace lintel {
class SharedMemoryBootstrapPlugin : public BootstrapPlugin
{
private:
  std::shared_ptr<DatabaseConnectionEntry> m_connectionEntry;
  std::vector<std::shared_ptr<SharedMemoryRepository>> m_sharedMemoryRepositories;
  std::shared_ptr<SharedMemorySegmentManager> m_sharedMemorySegmentManager;
  std::shared_ptr<Configuration> m_configuration;
 
  void validateSegments();
 
  void validateEventBuses();
 
  static EventBusConfig configOf(const std::shared_ptr<EventBusEntry> &entry);
 
public:
  SharedMemoryBootstrapPlugin(const std::shared_ptr<DatabaseConnectionConfigurations> &connectionConfigurations,
    std::vector<std::shared_ptr<SharedMemoryRepository>> sharedMemoryRepositories,
    std::shared_ptr<SharedMemorySegmentManager> sharedMemorySegmentManager,
    std::shared_ptr<Configuration> configuration);
 
  void onStart() override;
 
  BootstrapSequence getPriority() override;
};
 
}// namespace lintel
#endif// LINTEL_SHAREDMEMORYBOOTSTRAPPLUGIN_H