View Source Dopple.Aggregator protocol (Dopple v0.1.1-alpha12)
A mechanism that listens to a set of measurements in order to act on the results
Link to this section Summary
Link to this section Types
@type t() :: term()
Link to this section Functions
@spec add_measurement(t(), Dopple.Measurement.t()) :: {:ok, t()} | {:error, any()}
@spec consumer(t()) :: {:ok, GenStage.stage()} | {:error, any()}