ALF.Components.Composer (alf v0.12.1) View Source

t() :: %ALF.Components.Composer{
  collected_ips: term(),
  count: term(),
  function: term(),
  memo: term(),
  module: term(),
  name: term(),
  new_collected_ips: term(),
  number: term(),
  opts: term(),
  pid: term(),
  pipeline_module: term(),
  set_ref: term(),
  source_code: term(),
  stream_memos: term(),
  subscribed_to: term(),
  subscribers: term(),
  telemetry: term(),
  type: term()
}

Link to this section Functions

build_error_ip(ip, error, stacktrace, state)

component_added(component)

history(ip, state)

init_opts(module, opts)

init_sync(state, telemetry)

read_source_code(module)

read_source_code(module, function)

send_error_result(ip, error, stacktrace, state)

Specs

send_error_result(ALF.IP.t(), any(), list(), t()) :: ALF.ErrorIP.t()

send_result(ip, result)

Specs

send_result(
  ALF.IP.t() | ALF.ErrorIP.t(),
  result() | ALF.IP.t() | ALF.ErrorIP.t()
) ::
  ALF.IP.t() | ALF.ErrorIP.t()

start_link(state)

Specs

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

subscribers(pid)

sync_process(ip, state)

telemetry_data(ip, state)

validate_options(name, options)