astarte_flow
astarte_flow v0.1.0

Astarte.Flow.Blocks.Sorter (astarte_flow v0.1.0)

This block is a stateful realtime block, which reorders an out of order sequence of messages, and optionally removes any duplicate message.

Link to this section Summary

Functions

process_message(msg, config, state)

Process a message and stores it into the block state.

start_link(opts)
take_ready(ts, arg)

Take any ready message.

Link to this section Functions

Link to this function

process_message(msg, config, state)

@spec process_message(
  Astarte.Flow.Message.t(),
  Astarte.Flow.Blocks.Sorter.Config.t(),
  Astarte.Flow.Blocks.Sorter.State.t()
) :: Astarte.Flow.Blocks.Sorter.State.t()

Process a message and stores it into the block state.

Link to this function

start_link(opts)

Link to this function

take_ready(ts, arg)

@spec take_ready(
  pos_integer(),
  {Astarte.Flow.Blocks.Sorter.Config.t(), Astarte.Flow.Blocks.Sorter.State.t()}
) ::
  {[Astarte.Flow.Message.t()],
   {Astarte.Flow.Blocks.Sorter.Config.t(), Astarte.Flow.Blocks.Sorter.State.t()}}

Take any ready message.