Runbox.Runtime.ComponentNetwork behaviour (runbox v26.0.0)

Component network builds and validates run component dependency network.

To build this network, module uses dependencies defined by the scenario.

Summary

component()

t()

create(list, t)

input_topics(t)

Creates base network with only template nodes

Main function. Given list of template modules, expands them into components network with input streams, timezips etc...

Return all input topic names that are being subscribed to in component network.

@type component() :: any()

@type t() :: any()

@callback convert_to_network([Runbox.ScenarioTemplate.t()]) :: t()

@callback create([Runbox.ScenarioTemplate.t()], Keyword.t()) ::
  {:ok, t()} | {:error, term()}

@callback input_topics(t()) :: [String.t()]

@spec convert_to_network(Runbox.Scenario.Type.t(), [Runbox.ScenarioTemplate.t()]) ::
  t()

Creates base network with only template nodes

@spec create(Runbox.Scenario.Type.t(), [Runbox.ScenarioTemplate.t()], Keyword.t()) ::
  {:ok, t()} | {:error, term()}

Main function. Given list of template modules, expands them into components network with input streams, timezips etc...

@spec input_topics(Runbox.Scenario.Type.t(), t()) :: [String.t()]

Return all input topic names that are being subscribed to in component network.

@spec topology_sort(Runbox.Scenario.Type.t(), t()) :: [component()]