ALF.Components.Switch (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)

validate_options(name, options)

Link to this section Types

result()

Specs

result() :: :cloned | :destroyed | :created_decomposer | :created_recomposer

t()

Specs

t() :: %ALF.Components.Switch{
  branches: term(),
  function: term(),
  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

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)

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)