DdDataStreams.Carrier.Flat (DD Data Streams v0.3.0)

Copy Markdown View Source

The flat carrier: a Pub/Sub attribute map or a Kafka/RabbitMQ header list.

Reading and writing go through DdDataStreams.Propagator; the size is the sum of the keys and values of every entry, as the consume side has always measured.

Summary

Functions

put(carrier, pathway)