ConnectionPoolRegistry.h

Go to the documentation of this file.

#ifndef LINTEL_CONNECTIONPOOLREGISTRY_H
#define LINTEL_CONNECTIONPOOLREGISTRY_H
 
#include <cstddef>
#include <map>
#include <memory>
#include <mutex>
#include <string>
#include <vector>
 
#include "lintel/core/persistence/ConnectionPool.h"
 
namespace lintel {
namespace db {
  class ConnectionPoolRegistry
  {
  public:
    static ConnectionPoolRegistry &instance();
 
    void registerPool(std::string name, std::shared_ptr<ConnectionPool> pool);
 
    [[nodiscard]] std::shared_ptr<ConnectionPool> poolOf(const std::string &name) const;
 
    [[nodiscard]] bool hasPool(const std::string &name) const;
 
    void clear();
 
    [[nodiscard]] bool empty() const;
 
    [[nodiscard]] std::size_t size() const;
 
    [[nodiscard]] std::vector<std::string> names() const;
 
  private:
    ConnectionPoolRegistry() = default;
 
    mutable std::mutex m_mutex;
    std::map<std::string, std::shared_ptr<ConnectionPool>> m_pools;
  };
}// namespace db
 
}// namespace lintel
#endif// LINTEL_CONNECTIONPOOLREGISTRY_H