Module event_streaming 

Structured Event Streaming (PMAT-043)

Stream metrics to time-series databases and event systems.

Features

• InfluxDB Line Protocol export
• JSON Lines file sink
• Batch buffering and compression
• Correlation ID tracking

Falsification Criteria (F1351-F1360)

See tests/event_streaming_f1351.rs for falsification tests.

Structs

EventBatch

Event batch

EventStreamer

Event streamer

MetricEvent

Metric event

RetryConfig

Retry configuration

SinkHealth

Sink health status

Enums

SinkType

Event sink type

Constants

DEFAULT_BATCH_SIZE

Default batch size

SCHEMA_VERSION

Schema version for event format

Functions

compress_data

Compress data using simple run-length encoding (placeholder)

event_from_sample

Create event from performance sample