alf v0.8.4

ALF.Components.Plug (alf v0.8.4) View Source

Link to this section Summary

Types

result()
t()

Functions

build_error_ip(ip, error, stacktrace, state)
init_opts(module, opts)
init_sync(state, telemetry_enabled)
read_source_code(module)
read_source_code(module, function)
send_error_result(ip, error, stacktrace, state)
send_result(ip, result)
start_link(state)
subscribers(pid)
sync_process(ip, state)
telemetry_data(ip, state)

Link to this section Types

Link to this type

result()

View Source

Specs

result() :: :cloned | :destroyed | :created_decomposer | :created_recomposer
Link to this type

t()

View Source

Specs

t() :: %ALF.Components.Plug{
  module: term(),
  name: term(),
  opts: term(),
  pid: term(),
  pipe_module: term(),
  pipeline_module: term(),
  source_code: term(),
  subscribe_to: term(),
  subscribed_to: term(),
  subscribers: term(),
  telemetry_enabled: 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

init_opts(module, opts)

View Source
Link to this function

init_sync(state, telemetry_enabled)

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()
Link to this function

send_result(ip, result)

View Source

Specs

send_result(
  ALF.IP.t() | ALF.ErrorIP.t(),
  result() | ALF.IP.t() | ALF.ErrorIP.t()
) ::
  ALF.IP.t() | ALF.ErrorIP.t()
Link to this function

start_link(state)

View Source

Specs

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

subscribers(pid)

View Source
Link to this function

sync_process(ip, state)

View Source
Link to this function

telemetry_data(ip, state)

View Source