Module generator 

Synthetic data generator source — no external infrastructure.

Emits a deterministic sequence at a configured rate: row i is always (seq = i, ts_ms = i * 1000 / rows_per_second, value = "v{i}"), so output is a pure function of the offset. That makes the source fully replayable (exactly-once capable) and lets harnesses verify sink completeness by recomputing the expected rows — its primary consumer is the cluster soak test, but it works anywhere a self-driving source is needed (demos, benchmarks).

Structs

GeneratorSource

Deterministic rate-limited source. See module docs.

Functions

register_generator_source

Registers the generator source so CREATE SOURCE ... WITH (connector = 'generator') resolves.