Astarte.Flow.Flows.DETSStorage (astarte_flow v0.1.0)

Link to this section Summary

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

Delete a flow from the dets table

get_all_flows()

Return a list of all saved Flows in the form {realm, %Flow{}}

Insert a flow into the dets table

start_link(args)

Returns a specification to start this module under a supervisor.

@spec delete_flow(realm :: String.t(), name :: String.t()) ::
  :ok | {:error, reason :: term()}

Delete a flow from the dets table

@spec get_all_flows() :: [{realm :: String.t(), Astarte.Flow.Flows.Flow.t()}]

Return a list of all saved Flows in the form {realm, %Flow{}}

@spec insert_flow(realm :: String.t(), flow :: Astarte.Flow.Flows.Flow.t()) ::
  :ok | {:error, reason :: term()}

Insert a flow into the dets table