|
A11 (C++ runtime)
Native C++ implementation of the A11 action and streaming runtime
|
#include "a11/stores/redis_chunk_store.h"#include <algorithm>#include <charconv>#include <cstddef>#include <cstdint>#include <cstdlib>#include <limits>#include <memory>#include <optional>#include <string>#include <string_view>#include <type_traits>#include <utility>#include <variant>#include <vector>#include <absl/container/flat_hash_set.h>#include <absl/status/status.h>#include <absl/status/statusor.h>#include <absl/strings/match.h>#include <absl/strings/str_cat.h>#include <absl/time/time.h>#include "a11/concurrency/executor.h"#include "a11/concurrency/future.h"#include "a11/data/msgpack.h"#include "a11/data/types.h"#include "a11/stores/redis_chunk_store_script.h"#include "redis/client.h"#include "redis/reply.h"Namespaces | |
| namespace | a11 |
| namespace | a11::stores |
| NextDisposition disposition = NextDisposition::kWait |
| std::vector<std::optional<data::NodeFragment> > fragments |
| std::optional<absl::Status> terminal_status |