DfpClusterSharedPtr DFPClusterStore::load(const std::string cluster_name) {

  ClusterStoreType& clusterStore = getClusterStore();

  absl::ReaderMutexLock lock(clusterStore.mutex_);

  auto it = clusterStore.map_.find(cluster_name);

  if (it != clusterStore.map_.end()) {

    return it->second.lock();

  }

  return nullptr;

}

void DFPClusterStore::save(const std::string cluster_name, DfpClusterSharedPtr cluster) {

  ClusterStoreType& clusterStore = getClusterStore();

  absl::WriterMutexLock lock(clusterStore.mutex_);

  clusterStore.map_[cluster_name] = std::move(cluster);

}

void DFPClusterStore::remove(const std::string cluster_name) {

  ClusterStoreType& clusterStore = getClusterStore();

  absl::WriterMutexLock lock(clusterStore.mutex_);

  clusterStore.map_.erase(cluster_name);

}

DFPClusterStoreSharedPtr DFPClusterStoreFactory::get() {

  return singleton_manager_.getTyped<DFPClusterStore>(

      SINGLETON_MANAGER_REGISTERED_NAME(dynamic_forward_proxy_cluster_store),

      []() { return std::make_shared<DFPClusterStore>(); });

}