Streaming¶

Publish/subscribe, push/pull and request/reply of IQ over NATS.

Python module doppler.stream. Area: I/O.

Classes and functions¶

Name	Kind	API	Gallery	Example	Design
`CF32`	constant			work_queue_shutdown_demo	Streaming — one envelope, six roles, two planes
`CF64`	constant			pipeline_recv pipeline_send receiver +3 more	Streaming — one envelope, six roles, two planes
`CI16`	constant				Streaming — one envelope, six roles, two planes
`CI32`	constant			pipeline_recv	Streaming — one envelope, six roles, two planes
`CI8`	constant				Streaming — one envelope, six roles, two planes
`format_name`	function	format_name		receiver
`get_timestamp_ns`	function	get_timestamp_ns		pipeline_send receiver transmitter	Streaming — one envelope, six roles, two planes
`mean_power`	function	mean_power		receiver
`Publisher`	class	Publisher		transmitter	Streaming — one envelope, six roles, two planes Telemetry — zero-cost scalar taps for running pipelines
`Pull`	class	Pull		pipeline_recv work_queue_shutdown_demo	Streaming — one envelope, six roles, two planes Spectrum Analyzer The Spectrogram — the measurement record
`Push`	class	Push		pipeline_send work_queue_shutdown_demo	Streaming — one envelope, six roles, two planes
`Replier`	class	Replier		replier	Streaming — one envelope, six roles, two planes
`Requester`	class	Requester		requester	Streaming — one envelope, six roles, two planes
`Subscriber`	class	Subscriber	Waveform I/O — One Capture, Four File Types	graceful_shutdown_demo receiver wfm_realtime_stream	Streaming — one envelope, six roles, two planes Telemetry — zero-cost scalar taps for running pipelines The Spectrogram — the measurement record
`TLM16`	constant		Capturing All Receiver Telemetry Telemetry: Many Emitters, One Consumer		Streaming — one envelope, six roles, two planes Telemetry — zero-cost scalar taps for running pipelines
`WORK_QUEUE_MAX_ACK_PENDING`	constant

Guide pages in this domain¶

Real-Time Pacing & Timestamping — sample-accurate playback timing

Design pages in this domain¶

Streaming — one envelope, six roles, two planes — the transport contract: the 64-byte dp_header_t envelope every role shares, how a frame too big for the broker is chunked and reassembled, the subjects and JetStream objects derived from an endpoint, and who owns which buffer

Used in other domains¶

Pages filed under another domain that name a symbol of this module, or link to or from a page filed here: a class used for another task is found from both sides, never re-filed.