|
A11 (C++ runtime)
Native C++ implementation of the A11 streaming action runtime
|
#include "a11/stores/sqlite_chunk_store.h"#include <algorithm>#include <cstddef>#include <cstdint>#include <cstdlib>#include <filesystem>#include <limits>#include <memory>#include <optional>#include <string>#include <string_view>#include <utility>#include <variant>#include <vector>#include <absl/container/flat_hash_set.h>#include <absl/status/status.h>#include <absl/status/status_macros.h>#include <absl/status/statusor.h>#include <absl/strings/str_cat.h>#include <absl/time/clock.h>#include <absl/time/time.h>#include <sqlite3.h>#include "a11/concurrency/executor.h"#include "a11/concurrency/future.h"#include "a11/data/msgpack.h"#include "a11/data/types.h"#include "a11/stores/internal/chunk_store_common.h"#include "a11/stores/internal/sqlite_database.h"#include "thread/selectables.h"Namespaces | |
| namespace | a11 |
| namespace | a11::stores |
| std::uint64_t arrival_order = 0 |
| std::string data |
| bool final_marker = false |
| std::optional<std::string> metadata |
| std::optional<std::string> mimetype |
| std::optional<std::string> node_ref_id |
| std::optional<std::uint64_t> node_ref_length |
| std::uint32_t node_ref_offset = 0 |
| std::string owned_blob |
Set when this row owns a blob file, so a failed batch can unlink it.
| std::uint64_t payload_bytes = 0 |
| std::string ref |
| std::uint32_t seq = 0 |
| int storage = kStorageInline |
| std::optional<absl::Time> timestamp |
| bool timestamp_explicit = false |
| std::int64_t timestamp_micros = 0 |
| bool tombstone = false |