Runs the aggregator for the lifetime of the application.
The aggregator is started under a supervisor, so it is restarted if it dies;
an enabled pipeline that only calls DdDataStreams.attach/0 is therefore
recorded without the host adding the aggregator to its own supervision tree.
The transport comes from config :dd_data_streams, transport:, so a host can
reuse its own HTTP pool instead of the default Req implementation:
config :dd_data_streams, transport: MyApp.AgentTransportThe aggregator reads it on every flush rather than at start, so changing the key while it runs applies to the next payload. Without that key the Req implementation is used when Req is available. When neither resolves, the start logs an error naming the key, because every flush would otherwise be dropped in silence.
Whether it runs at all is decided once, when the application starts, from
DdDataStreams.Config.enabled?/0, which is on unless it is turned off.
Changing the flag while the application is running neither starts nor stops
the aggregator: restart the application to apply it, or in a test call
DdDataStreams.Testing.enable!/1, which starts the aggregator for the
duration of the test and stops it again. An idle aggregator sends
nothing, so a pipeline that has not attached costs one process and no
requests.
An aggregator that another application or a test suite already supervises under the registered name is left as it is instead of being started twice; it reads the same configuration, so it posts where this one would have.