Nous.Workflow.Checkpoint.Store behaviour (nous v0.16.1)

View Source

Behaviour for checkpoint storage backends.

Summary

Callbacks

delete(run_id)
list(workflow_id)
load(run_id)
save(t)

Callbacks

delete(run_id)

@callback delete(run_id :: String.t()) :: :ok | {:error, term()}

list(workflow_id)

@callback list(workflow_id :: String.t()) :: {:ok, [Nous.Workflow.Checkpoint.t()]}

load(run_id)

@callback load(run_id :: String.t()) ::
  {:ok, Nous.Workflow.Checkpoint.t()} | {:error, :not_found}

save(t)

@callback save(Nous.Workflow.Checkpoint.t()) :: :ok | {:error, term()}