signet::forge::StreamRecord Struct Reference

A single record flowing through the StreamingSink pipeline. More...

#include <streaming_sink.hpp>

Public Attributes
int64_t	timestamp_ns = 0
	Wall-clock timestamp in nanoseconds since Unix epoch.
uint32_t	type_id = 0
	User-defined record type tag (0 = untyped)
std::string	payload
	Serialized record bytes (UTF-8 safe or binary via base64)

Detailed Description

A single record flowing through the StreamingSink pipeline.

Records are submitted by producers, buffered in a ring, and compacted into Parquet row groups by the background thread. The payload is base64-encoded when written to Parquet for binary safety.

Definition at line 384 of file streaming_sink.hpp.

Member Data Documentation

payload

std::string signet::forge::StreamRecord::payload

Serialized record bytes (UTF-8 safe or binary via base64)

Definition at line 387 of file streaming_sink.hpp.

timestamp_ns

int64_t signet::forge::StreamRecord::timestamp_ns = 0

Wall-clock timestamp in nanoseconds since Unix epoch.

Definition at line 385 of file streaming_sink.hpp.

type_id

uint32_t signet::forge::StreamRecord::type_id = 0

User-defined record type tag (0 = untyped)

Definition at line 386 of file streaming_sink.hpp.

---

The documentation for this struct was generated from the following file:

• include/signet/ai/streaming_sink.hpp