agentsight_capture/analyzers/
mod.rs

1// SPDX-License-Identifier: MIT
2// Copyright (c) 2026 eunomia-bpf org.
3
4use crate::runners::EventStream;
5use async_trait::async_trait;
6
7/// Type alias for errors that can be sent between threads
8pub type AnalyzerError = Box<dyn std::error::Error + Send + Sync>;
9
10/// Base trait for all analyzers that process event streams
11#[async_trait]
12pub trait Analyzer: Send + Sync {
13    /// Process an event stream and return a processed stream
14    async fn process(&mut self, stream: EventStream) -> Result<EventStream, AnalyzerError>;
15}
16
17pub mod auth_header_remover;
18pub mod common;
19mod filter_base;
20mod filter_metrics;
21pub mod http_decompressor;
22pub mod http_filter;
23pub mod http_parser;
24pub mod materializing;
25mod protocol_events;
26pub mod sse_processor;
27pub mod ssl_filter;
28pub mod timestamp_normalizer;
29
30#[cfg(test)]
31mod sse_processor_tests;
32
33pub use auth_header_remover::AuthHeaderRemover;
34pub use http_decompressor::HTTPDecompressor;
35pub use http_filter::{HTTPFilter, print_global_http_filter_metrics};
36pub use http_parser::HTTPParser;
37pub use materializing::MaterializingAnalyzer;
38pub use sse_processor::SSEProcessor;
39pub use ssl_filter::{SSLFilter, print_global_ssl_filter_metrics};
40pub use timestamp_normalizer::TimestampNormalizer;
41
42#[cfg(test)]
43#[path = "mod_tests.rs"]
44mod comprehensive_analyzer_chain_tests;
agentsight_capture/analyzers/mod.rs

agentsight_capture/analyzers/
mod.rs
