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

Link to this section Summary


Initialize config from a keyword list.

Link to this section Types

@type option() :: {:deduplicate, boolean()} | {:delay_ms, pos_integer()}
@type t() :: %Astarte.Flow.Blocks.Sorter.Config{delay_us: term(), policy: term()}

Link to this section Functions

Link to this function


@spec from_keyword([option()]) :: {:ok, t()}

Initialize config from a keyword list.



  • :deduplicate - true when messages deduplication is enabled, otherwise false. Two messages are duplicate when they have same timestamp and value (any other field is ignored).
  • :delay_ms - the amount of time the message is kept for reorder and deduplicate operations.