A11 (C++ runtime)
Native C++ implementation of the A11 streaming action runtime
Loading...
Searching...
No Matches
sqlite_chunk_store.cc File Reference
#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
 

Variable Documentation

◆ arrival_order

std::uint64_t arrival_order = 0

◆ data

std::string data

◆ final_marker

bool final_marker = false

◆ metadata

std::optional<std::string> metadata

◆ mimetype

std::optional<std::string> mimetype

◆ node_ref_id

std::optional<std::string> node_ref_id

◆ node_ref_length

std::optional<std::uint64_t> node_ref_length

◆ node_ref_offset

std::uint32_t node_ref_offset = 0

◆ owned_blob

std::string owned_blob

Set when this row owns a blob file, so a failed batch can unlink it.

◆ payload_bytes

std::uint64_t payload_bytes = 0

◆ ref

std::string ref

◆ seq

std::uint32_t seq = 0

◆ storage

int storage = kStorageInline

◆ timestamp

std::optional<absl::Time> timestamp

◆ timestamp_explicit

bool timestamp_explicit = false

◆ timestamp_micros

std::int64_t timestamp_micros = 0

◆ tombstone

bool tombstone = false