flexflow v0.2.0

Flexflow.Telemetry (flexflow v0.2.0) View Source

Telemetry

Link to this section Summary

Types

state_type()
t()

Options

  • enable_process_history Enable Process history in :ets
  • telemetry_logger Enable default logger handler, default false
  • telemetry_logger_level Logger level, default debug

Functions

attach_default_handler()
handle_history(list, measurements, metadata, config)
handle_logger(list, _, meta, level)
handle_state(state, measurements, meta, config)
invoke_process(p, name, f)
span(name, fun, meta \\ %{})

Link to this section Types

Link to this type

state_type()

View Source

Specs

state_type() :: :process_loop | :process_init
Link to this type

t()

View Source

Specs

t() :: %Flexflow.Telemetry{
  enable_process_history: boolean(),
  telemetry_logger: boolean(),
  telemetry_logger_level: Logger.level()
}

Options

  • enable_process_history Enable Process history in :ets
  • telemetry_logger Enable default logger handler, default false
  • telemetry_logger_level Logger level, default debug

Link to this section Functions

Link to this function

attach_default_handler()

View Source

Specs

attach_default_handler() :: :ok | {:error, :already_exists}
Link to this function

handle_history(list, measurements, metadata, config)

View Source

Specs

handle_history([atom()], map(), map(), term()) :: :ok
Link to this function

handle_logger(list, _, meta, level)

View Source

Specs

handle_logger([atom()], map(), map(), Logger.level()) :: :ok
Link to this function

handle_state(state, measurements, meta, config)

View Source

Specs

handle_state([atom()], map(), map(), t()) :: :ok
Link to this function

invoke_process(p, name, f)

View Source

Specs

invoke_process(
  Flexflow.Process.t(),
  atom(),
  (Flexflow.Process.t() -> Flexflow.Process.result())
) :: Flexflow.Process.result()
Link to this function

span(name, fun, meta \\ %{})

View Source

Specs

span(state_type(), fun :: (() -> {term(), map()}), meta :: map()) :: term()