Enum TelemetryEvent 

pub enum TelemetryEvent {
    RequestProcessed {
        request_id: Option<String>,
        latency_ms: u64,
        status_code: u16,
        waf_action: Option<String>,
        site: String,
        method: String,
        path: String,
    },
    LogEntry {

        request_id: Option<String>,
        id: String,
        source: String,
        level: String,
        message: String,
        log_timestamp_ms: u64,
        fields: Option<Value>,
        method: Option<String>,
        path: Option<String>,
        status_code: Option<u16>,
        latency_ms: Option<f64>,
        client_ip: Option<String>,
        rule_id: Option<String>,
    
},
    WafBlock {
        request_id: Option<String>,
        rule_id: String,
        severity: String,
        client_ip: String,
        site: String,
        path: String,
    },
    RateLimitHit {
        request_id: Option<String>,
        client_ip: String,
        limit: u32,
        window_secs: u32,
        site: String,
    },
    ConfigReload {
        sites_loaded: usize,
        duration_ms: u64,
        success: bool,
        error: Option<String>,
    },
    ServiceHealth {
        uptime_secs: u64,
        memory_mb: u64,
        active_connections: u64,
        requests_per_sec: f64,
    },
    SensorReport {
        sensor_id: String,
        actor: ExternalActorContext,
        signal: ExternalSignalContext,
        request: ExternalRequestContext,
    },
    CampaignReport {
        campaign_id: String,
        confidence: f64,
        attack_types: Vec<String>,
        actor_count: usize,
        correlation_reasons: Vec<String>,
        timestamp_ms: u64,
    },
    AuthCoverage(AuthCoverageSummary),
}

Telemetry event payload.

Variants

RequestProcessed

Fields

request_id: Option<String>

latency_ms: u64

status_code: u16

waf_action: Option<String>

site: String

method: String

path: String

LogEntry

Fields

request_id: Option<String>

id: String

source: String

level: String

message: String

log_timestamp_ms: u64

fields: Option<Value>

method: Option<String>

path: Option<String>

status_code: Option<u16>

latency_ms: Option<f64>

client_ip: Option<String>

rule_id: Option<String>

WafBlock

Fields

request_id: Option<String>

rule_id: String

severity: String

client_ip: String

site: String

path: String

RateLimitHit

Fields

request_id: Option<String>

client_ip: String

limit: u32

window_secs: u32

site: String

ConfigReload

Fields

sites_loaded: usize

duration_ms: u64

success: bool

error: Option<String>

ServiceHealth

Fields

uptime_secs: u64

memory_mb: u64

active_connections: u64

requests_per_sec: f64

SensorReport

Fields

sensor_id: String

actor: ExternalActorContext

signal: ExternalSignalContext

request: ExternalRequestContext

CampaignReport

Fields

campaign_id: String

confidence: f64

attack_types: Vec<String>

actor_count: usize

correlation_reasons: Vec<String>

timestamp_ms: u64

AuthCoverage(AuthCoverageSummary)

Implementations

impl TelemetryEvent

pub fn event_type(&self) -> EventType

Trait Implementations

impl Clone for TelemetryEvent

fn clone(&self) -> TelemetryEvent

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for TelemetryEvent

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for TelemetryEvent

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for TelemetryEvent

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.