pub struct StreamingTraceParser { /* private fields */ }Expand description
Streaming parser for trace events received in segments TraceContext is externally managed by the loader
Implementations§
Source§impl StreamingTraceParser
impl StreamingTraceParser
Sourcepub fn new() -> Self
pub fn new() -> Self
Create a new streaming parser with RingBuf mode (default) Note: TraceContext is provided by loader during parsing
Sourcepub fn with_event_source(event_source: EventSource) -> Self
pub fn with_event_source(event_source: EventSource) -> Self
Create a new streaming parser with specified event source
Sourcepub fn process_segment(
&mut self,
data: &[u8],
trace_context: &TraceContext,
) -> Result<Option<ParsedTraceEvent>, String>
pub fn process_segment( &mut self, data: &[u8], trace_context: &TraceContext, ) -> Result<Option<ParsedTraceEvent>, String>
Process incoming data segment and return complete trace events TraceContext is provided by the loader (uprobe config after compilation)
Sourcepub fn get_state(&self) -> &ParseState
pub fn get_state(&self) -> &ParseState
Get current parse state for debugging
Trait Implementations§
Auto Trait Implementations§
impl Freeze for StreamingTraceParser
impl RefUnwindSafe for StreamingTraceParser
impl Send for StreamingTraceParser
impl Sync for StreamingTraceParser
impl Unpin for StreamingTraceParser
impl UnwindSafe for StreamingTraceParser
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more