nxt::io::arrow::ipc_trace class

#include <nxtio/arrow.hpp>

In-memory trace collector that writes Arrow IPC files on demand.

Constructors, destructors, conversion operators

ipc_trace(std::optional<std::string> output_path, std::string run_id_prefix = "nxt-trace") explicit

Create an enabled trace when output_path is set.

ipc_trace(const ipc_trace&) deleted

ipc_trace(ipc_trace&&) noexcept

~ipc_trace()

Public functions

void add(std::string phase, std::string event_type, std::string data, std::string payload_json)

Append a trace row using the current run id, sequence, and clock.

auto enabled() const →  bool noexcept

True when rows are being collected.

auto operator=(const ipc_trace&) →  ipc_trace& deleted

auto operator=(ipc_trace&&) →  ipc_trace& noexcept

auto output_path() const →  const std::optional<std::string>&

Destination IPC file, or std::nullopt for a disabled trace.

void write()

Write collected rows to output_path().