ALF.Components.Producer (alf v0.11.0) View Source

Link to this section Summary

Link to this section Types

Specs

result() :: :composed | :destroyed

Specs

t() :: %ALF.Components.Producer{
  count: term(),
  demand: term(),
  ips: term(),
  name: term(),
  number: term(),
  opts: term(),
  pid: term(),
  pipeline_module: term(),
  set_ref: term(),
  source_code: term(),
  subscribed_to: term(),
  subscribers: term(),
  telemetry: term(),
  type: term()
}

Link to this section Functions

Link to this function

build_error_ip(ip, error, stacktrace, state)

View Source
Link to this function

component_added(component)

View Source
Link to this function

init_sync(state, telemetry)

View Source
Link to this function

read_source_code(module)

View Source
Link to this function

read_source_code(module, function)

View Source
Link to this function

send_error_result(ip, error, stacktrace, state)

View Source

Specs

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

Specs

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

Specs

start_link(t()) :: GenServer.on_start()
Link to this function

telemetry_data(ip, state)

View Source