@spec call(String.t(), map(), map()) :: map() | [map()] | {:error, any()}

@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()}

@spec definition(String.t()) :: {:ok, map()} | {:error, any()}

@spec delete(String.t()) :: :ok | {:error, any()}

@spec pipelines() :: [String.t()]

@spec start(String.t(), map()) :: {:ok, map()} | {:error, any()}

@spec status(String.t()) :: :undefined | :not_ready | :ready

@spec stop(String.t()) :: :ok | {:error, any()}

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