Struct PerfettoWriter 

pub struct PerfettoWriter { /* private fields */ }

A writer for Perfetto traces that writes packets through an AsyncWriter. Uses the AsyncWriter trait to abstract the underlying data sink.

Implementations

impl PerfettoWriter

pub fn new( writer: Box<dyn AsyncWriter + Send>, micromegas_process_id: &str, ) -> PerfettoWriter

Creates a new PerfettoWriter instance.

pub async fn write_packet(&mut self, packet: TracePacket) -> Result<(), Error>

Writes a single TracePacket to the chunk sender with proper protobuf framing.

pub async fn emit_process_descriptor(&mut self, exe: &str) -> Result<(), Error>

Emits a process descriptor packet to the stream.

pub async fn emit_thread_descriptor( &mut self, stream_id: &str, thread_id: i32, thread_name: &str, ) -> Result<(), Error>

Emits a thread descriptor packet to the stream.

pub fn set_current_thread(&mut self, stream_id: &str)

Sets the current thread for subsequent span emissions. Must be called before emitting spans for a specific thread.

pub async fn emit_async_track_descriptor(&mut self) -> Result<(), Error>

Emits an async track descriptor packet to the stream (single track for all async spans).

pub async fn emit_span( &mut self, begin_ns: u64, end_ns: u64, name: &str, target: &str, filename: &str, line: u32, ) -> Result<(), Error>

Emits a span event to the stream.

pub async fn emit_async_span_begin( &mut self, timestamp_ns: u64, name: &str, target: &str, filename: &str, line: u32, ) -> Result<(), Error>

Emits an async span begin event to the stream.

pub async fn emit_async_span_end( &mut self, timestamp_ns: u64, name: &str, target: &str, filename: &str, line: u32, ) -> Result<(), Error>

Emits an async span end event to the stream.

pub async fn flush(&mut self) -> Result<(), Error>

Flushes any buffered data in the writer.

pub fn into_inner(self) -> Box<dyn AsyncWriter + Send>

Consumes the writer and returns the underlying AsyncWriter. This is useful for testing to extract the written data.