View Source Kraken.Pipelines (kraken v0.3.4)

Link to this section Summary

Link to this section Functions

Link to this function

call(pipeline_name, args, opts \\ %{})

View Source
@spec call(String.t(), map(), map()) :: map() | [map()] | {:error, any()}
Link to this function

cast(pipeline_name, args, opts \\ %{})

View Source
@spec cast(String.t(), map(), map()) :: reference() | [reference()] | {:error, any()}
@spec define(String.t()) :: {:ok, String.t()} | {:error, any()}
@spec define(map()) :: {:ok, String.t()} | {:error, any()}
Link to this function

definition(pipeline_name)

View Source
@spec definition(String.t()) :: {:ok, map()} | {:error, any()}
@spec delete(String.t()) :: :ok | {:error, any()}
@spec pipelines() :: [String.t()]
Link to this function

start(pipeline_name, args \\ %{})

View Source
@spec start(String.t(), map()) :: {:ok, map()} | {:error, any()}
@spec status(String.t()) :: :undefined | :not_ready | :ready
@spec stop(String.t()) :: :ok | {:error, any()}
Link to this function

stream(pipeline_name, args, opts \\ %{})

View Source
@spec stream(String.t(), map(), map()) :: Enumerable.t() | {:error, any()}