astarte_flow
astarte_flow v0.1.0

Astarte.Flow.Blocks.DeviceEventsProducer.EventsDecoder (astarte_flow v0.1.0)

This module handles the decoding of Astarte Events and their transformation to Astarte Flow Messages

Link to this section Summary

Functions

decode_simple_event(payload)
simple_event_to_message(simple_event)

Link to this section Functions

Link to this function

decode_simple_event(payload)

@spec decode_simple_event(payload :: binary()) ::
  {:ok, decode_event :: Astarte.Core.Triggers.SimpleEvents.t()}
  | {:error, reason :: term()}
Link to this function

simple_event_to_message(simple_event)

@spec simple_event_to_message(Astarte.Core.Triggers.SimpleEvents.t()) ::
  {:ok, Astarte.Flow.Message.t()} | {:error, reason :: term()}