streaming_sink.hpp File Reference

Lock-free SPSC/MPSC ring buffers, StreamingSink for background Parquet compaction, and HybridReader for querying across historical and live data. More...

#include "signet/error.hpp"
#include "signet/types.hpp"
#include "signet/schema.hpp"
#include "signet/writer.hpp"
#include "signet/reader.hpp"
#include "signet/ai/wal.hpp"
#include <atomic>
#include <chrono>
#include <condition_variable>
#include <cstdint>
#include <cstring>
#include <filesystem>
#include <functional>
#include <limits>
#include <memory>
#include <mutex>
#include <numeric>
#include <string>
#include <string_view>
#include <thread>
#include <vector>

Go to the source code of this file.

Classes
class	signet::forge::SpscRingBuffer< T, Capacity >
	Lock-free single-producer single-consumer (SPSC) bounded ring buffer. More...
class	signet::forge::MpscRingBuffer< T, Capacity >
	Multiple-producer single-consumer (MPSC) bounded ring buffer. More...
struct	signet::forge::StreamRecord
	A single record flowing through the StreamingSink pipeline. More...
class	signet::forge::StreamingSink
	Background-thread Parquet compaction sink fed by a lock-free ring buffer. More...
struct	signet::forge::StreamingSink::Options
	Configuration options for StreamingSink::create(). More...
struct	signet::forge::HybridReaderOptions
	Options for constructing a HybridReader via HybridReader::create(). More...
struct	signet::forge::HybridQueryOptions
	Per-query filter options passed to HybridReader::read(). More...
class	signet::forge::HybridReader
	Reads StreamRecords across historical Parquet files and (optionally) a live StreamingSink ring buffer snapshot. More...

Namespaces
namespace	signet
namespace	signet::forge

Detailed Description

Lock-free SPSC/MPSC ring buffers, StreamingSink for background Parquet compaction, and HybridReader for querying across historical and live data.

Definition in file streaming_sink.hpp.