DalaDev.LogCollector (dala_dev v0.0.3)

Unified log collection from dala Elixir cluster nodes.

Collects logs from:

BEAM logger (via RPC from remote nodes)
Android logcat (for Android devices)
iOS syslog (for iOS simulators/devices)
Distribution logs (EPMD, net_kernel)

Examples

# Stream logs from all connected nodes
DalaDev.LogCollector.stream_logs(:all_nodes, level: :info)

# Collect last 100 log lines from a specific node
DalaDev.LogCollector.collect_logs(:"dala_qa@192.168.1.5", last: 100)

# Export logs to file
DalaDev.LogCollector.export_logs("cluster_logs.jsonl", nodes: :all)

Summary

Types

filter()

log_entry()

node_ref()

Functions

collect_android_logs(serial, opts \\ [])

Collect Android logs via adb logcat.

collect_beam_logs(node, opts \\ [])

Get BEAM VM logs from a remote node via RPC.

collect_ios_device_logs(udid, opts \\ [])

Collect iOS physical device logs via idevicesyslog (requires libimobiledevice).

collect_ios_sim_logs(udid, opts \\ [])

Collect iOS simulator logs via xcrun simctl spawn log stream.

collect_logs(node_ref, opts \\ [])

Collect logs from a node or all connected nodes.

export_logs(path, opts \\ [])

Export logs to a file.

fetch_local_logs(opts \\ [])

Fetch local logs (called via RPC on remote nodes).

stream_android_logs(serial, opts \\ [])

Stream Android logs in real-time.

stream_logs(node_ref, opts \\ [])

Stream logs in real-time.

Types

filter()

@type filter() ::
  {:level, Logger.level()}
  | {:module, module()}
  | {:node, node()}
  | {:time_range, {DateTime.t(), DateTime.t()}}
  | {:pattern, String.t() | Regex.t()}

log_entry()

@type log_entry() :: %{
  ts: DateTime.t(),
  node: node(),
  level: Logger.level(),
  message: String.t(),
  metadata: keyword()
}

node_ref()

@type node_ref() :: node() | :all_nodes | DalaDev.Device.t()

Functions

collect_android_logs(serial, opts \\ [])

@spec collect_android_logs(
  String.t(),
  keyword()
) :: {:ok, String.t()} | {:error, term()}

Collect Android logs via adb logcat.

Filters for the app package by default.

collect_beam_logs(node, opts \\ [])

@spec collect_beam_logs(
  node(),
  keyword()
) :: [log_entry()]

Get BEAM VM logs from a remote node via RPC.

Collects from:

Logger messages in :logger handler
error_logger (legacy)
SASL reports (if available)

collect_ios_device_logs(udid, opts \\ [])

@spec collect_ios_device_logs(
  String.t(),
  keyword()
) :: {:ok, String.t()} | {:error, term()}

Collect iOS physical device logs via idevicesyslog (requires libimobiledevice).

collect_ios_sim_logs(udid, opts \\ [])

@spec collect_ios_sim_logs(
  String.t(),
  keyword()
) :: {:ok, String.t()} | {:error, term()}

Collect iOS simulator logs via xcrun simctl spawn log stream.

collect_logs(node_ref, opts \\ [])

@spec collect_logs(
  node_ref(),
  keyword()
) :: {:ok, [log_entry()]} | {:error, term()}

Collect logs from a node or all connected nodes.

Options:

:last - number of recent log entries to return
:level - minimum log level (:error, :warning, :info, :debug)
:since - collect logs since this DateTime
:format - :text (default) or :jsonl

export_logs(path, opts \\ [])

@spec export_logs(
  Path.t(),
  keyword()
) :: :ok | {:error, term()}

Export logs to a file.

Format:

"jsonl" (default) - JSON Lines format, one log per line
"text" - Human-readable text
"csv" - CSV format with columns: ts,node,level,message,metadata

fetch_local_logs(opts \\ [])

@spec fetch_local_logs(keyword()) :: [log_entry()]

Fetch local logs (called via RPC on remote nodes).

This function runs ON the remote node to collect its local logs.

stream_android_logs(serial, opts \\ [])

@spec stream_android_logs(
  String.t(),
  keyword()
) :: Enumerable.t()

Stream Android logs in real-time.

stream_logs(node_ref, opts \\ [])

@spec stream_logs(
  node_ref(),
  keyword()
) :: Enumerable.t()

Stream logs in real-time.

Returns a stream that yields log entries as they arrive. Call Stream.run/1 or enumerate to start streaming.

Options:

:level - minimum log level
:nodes - list of nodes or :all_nodes
:format - :text or :jsonl