astarte_flow
astarte_flow v0.1.0

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

Link to this section Summary

Callbacks

delete_block(realm, name)
fetch_block(realm, name)
insert_block(realm, pipeline)
list_blocks(realm)

Link to this section Callbacks

Link to this callback

delete_block(realm, name)

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

fetch_block(realm, name)

@callback fetch_block(realm :: String.t(), name :: String.t()) ::
  {:ok, Astarte.Flow.Blocks.Block.t()} | {:error, reason :: term()}
Link to this callback

insert_block(realm, pipeline)

@callback insert_block(realm :: String.t(), pipeline :: Astarte.Flow.Blocks.Block.t()) ::
  :ok | {:error, reason :: term()}
Link to this callback

list_blocks(realm)

@callback list_blocks(realm :: String.t()) :: [Astarte.Flow.Blocks.Block.t()]