Astarte.Flow.Flows.Flow (astarte_flow v0.1.0)
This module implements an embedded_schema representing a Flow and also the GenServer responsible of starting and monitoring the Flow.
Link to this section Summary
Functions
Returns a specification to start this module under a supervisor.
Returns the %Flow{} struct that was used to create the flow.
Start a Flow as linked process.
Returns a Stream created by calling GenStage.stream/1 on the last stage of the Flow.
Link to this section Functions
Link to this function
child_spec(init_arg)
Returns a specification to start this module under a supervisor.
See Supervisor.
Link to this function
get_flow(pid_or_via_tuple)
See get_flow/2.
Link to this function
get_flow(realm, name)
Returns the %Flow{} struct that was used to create the flow.
Link to this function
start_link(args)
Start a Flow as linked process.
Arguments:
realm: the realm the Flow belongs to.flow: a%Flow{}struct with the parameters of the Flow.
Link to this function
tap(realm, name)
Returns a Stream created by calling GenStage.stream/1 on the last stage of the Flow.