Astarte.Flow.Pipelines.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 pipeline from the dets table

Fetch a pipeline given its realm and its name

Insert a pipeline into the dets table

List the pipelines for a specific realm

start_link(args)

Returns a specification to start this module under a supervisor.

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

Delete a pipeline from the dets table

@spec fetch_pipeline(realm :: String.t(), name :: String.t()) ::
  {:ok, Astarte.Flow.Pipelines.Pipeline.t()} | {:error, reason :: term()}

Fetch a pipeline given its realm and its name

@spec insert_pipeline(
  realm :: String.t(),
  pipeline :: Astarte.Flow.Pipelines.Pipeline.t()
) :: :ok | {:error, reason :: term()}

Insert a pipeline into the dets table

@spec list_pipelines(realm :: String.t()) :: [Astarte.Flow.Pipelines.Pipeline.t()]

List the pipelines for a specific realm