asrt_stream_server Struct Reference

Controller-side stream server (ASRT_STRM channel). More...

#include <stream.h>

Public Attributes
struct asrt_allocator	alloc
struct asrt_u8d2msg	err_msg
struct asrt_stream_schema *	lookup [ASRT_STREAM_MAX_SCHEMAS]
	Internal lookup by ID.
struct asrt_node	node

Detailed Description

Controller-side stream server (ASRT_STRM channel).

Receives DEFINE messages to register schemas and DATA messages carrying raw records. Records are stored in per-schema linked lists and handed out to the user via take semantics.

Typical lifecycle:

1. Reactor sends DEFINE(schema_id, fields[...]).
2. Reactor sends DATA(schema_id, raw bytes) — one record per message.
3. After test ends, controller takes all schemas via take().
4. Free the result with asrt_stream_schemas_free().

---

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

• asrtc/stream.h