ALF.Manager (alf v0.8.4) View Source

t() :: %ALF.Manager{
  components: term(),
  name: term(),
  pid: term(),
  pipeline: term(),
  pipeline_module: term(),
  pipeline_sup_pid: term(),
  producer_pid: term(),
  sup_pid: term(),
  sync: term(),
  telemetry_enabled: term()
}

Link to this section Functions

call(event, name, opts \\ [return_ip: false])

Specs

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

cast(event, name, opts \\ [send_result: false])

Specs

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

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

See Supervisor.

components(name)

Specs

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

reload_components_states(name)

Specs

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

start(module)

Specs

start(atom()) :: :ok

start(module, opts)

Specs

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

start(module, name, opts)

Specs

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

start_link(state)

Specs

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

started?(name)

Specs

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

stop(module)

Specs

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

stream(stream, name, opts \\ [return_ip: false])

Specs

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