ALF.Manager (alf v0.12.0) View Source

t() :: %ALF.Manager{
  ips: term(),
  pid: term(),
  pipeline: term(),
  pipeline_module: term(),
  pipeline_sup_pid: term(),
  producer_pid: term(),
  removed_stages: term(),
  stages: term(),
  sup_pid: term(),
  sync: term(),
  tasks: term(),
  telemetry: term()
}

Link to this section Functions

call(event, pipeline_module, opts \\ [])

Specs

call(any(), atom(), Keyword.t()) :: any() | [any()] | nil

cast(event, pipeline_module, opts \\ [])

Specs

cast(any(), atom(), Keyword.t()) :: reference()

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

See Supervisor.

component_added(component)

Specs

component_added(map()) :: :ok

component_updated(component)

Specs

component_updated(map()) :: :ok

components(pipeline_module)

Specs

components(atom()) :: [map()]

reload_components_states(pipeline_module)

Specs

reload_components_states(atom()) :: [map()]

start(module)

Specs

start(atom()) :: :ok

start(module, opts)

Specs

start(atom(), list()) :: :ok

start_link(state)

Specs

start_link(t()) :: GenServer.on_start()

started?(pipeline_module)

Specs

started?(atom()) :: true | false

stop(module)

Specs

stop(atom()) :: :ok | {:exit, {atom(), any()}}

stream(stream, pipeline_module, opts \\ [])

Specs

stream(Enumerable.t(), atom(), Keyword.t()) :: Enumerable.t()

wait_for_done(pipeline_module, stream_ref)