node_map.h

Go to the documentation of this file.

// Copyright 2025 Google LLC
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
//     http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.
 
#ifndef ACTIONENGINE_NODES_NODE_MAP_H_
#define ACTIONENGINE_NODES_NODE_MAP_H_
 
#include <memory>
#include <string>
#include <string_view>
#include <vector>
 
#include <absl/base/nullability.h>
#include <absl/base/thread_annotations.h>
#include <absl/container/flat_hash_map.h>
 
#include "actionengine/concurrency/concurrency.h"
#include "actionengine/nodes/async_node.h"
#include "actionengine/stores/chunk_store.h"

 
namespace act {

class NodeMap {
 public:
  explicit NodeMap(ChunkStoreFactory chunk_store_factory = {});
 
  ~NodeMap();
 
  // This class cannot be copied as each AsyncNode contains non-trivial state
  // that cannot be duplicated safely.
  NodeMap(const NodeMap& other) = delete;
  NodeMap& operator=(const NodeMap& other) = delete;
 
  // NodeMap can be safely moved by value.
  NodeMap(NodeMap&& other) noexcept;
  NodeMap& operator=(NodeMap&& other) noexcept;
 
  auto Get(std::string_view id,
           const ChunkStoreFactory& chunk_store_factory = {})
      -> AsyncNode* absl_nonnull;
  auto operator[](std::string_view id) -> AsyncNode* absl_nonnull;
 
  auto Get(const std::vector<std::string_view>& ids,
           const ChunkStoreFactory& chunk_store_factory = {})
      -> std::vector<AsyncNode*>;
 
  [[nodiscard]] std::unique_ptr<AsyncNode> Extract(std::string_view id);
 
  auto insert(std::string_view id, AsyncNode&& node) -> AsyncNode&;
  bool contains(std::string_view id) const;
 
 private:
  std::unique_ptr<ChunkStore> MakeChunkStore(
      const ChunkStoreFactory& factory = {}, std::string_view id = "") const;
 
  mutable act::Mutex mu_;
  absl::flat_hash_map<std::string, std::unique_ptr<AsyncNode>> nodes_
      ABSL_GUARDED_BY(mu_){};
 
  ChunkStoreFactory chunk_store_factory_;
};
}  // namespace act
 
#endif  // ACTIONENGINE_NODES_NODE_MAP_H_