astarte_flow
astarte_flow v0.1.0

Astarte.Flow.Flows.Storage behaviour (astarte_flow v0.1.0)

Link to this section Summary

Callbacks

delete_flow(realm, name)
get_all_flows()
insert_flow(realm, flow)

Link to this section Callbacks

Link to this callback

delete_flow(realm, name)

@callback delete_flow(realm :: String.t(), name :: String.t()) ::
  :ok | {:error, reason :: term()}
Link to this callback

get_all_flows()

@callback get_all_flows() :: [{realm :: String.t(), Astarte.Flow.Flows.Flow.t()}]
Link to this callback

insert_flow(realm, flow)

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