Struct QueryEvent 

pub struct QueryEvent {

    pub event_id: String,
    pub timestamp: SystemTime,
    pub query: String,
    pub params: Vec<ParamValue>,
    pub params_incomplete: bool,
    pub normalized_query: Option<String>,
    pub value_fingerprints: Option<Vec<String>>,
    pub duration: Duration,
    pub rows: Option<u64>,
    pub success: bool,
    pub error: Option<String>,
    pub database: String,
    pub connection_id: String,
}

Represents a captured SQL query event from the proxy

Fields

event_id: String

Unique identifier for this event

timestamp: SystemTime

Timestamp when the query was received

query: String

The SQL query text (raw if anonymization disabled, else same as normalized_query)

params: Vec<ParamValue>

Query parameters from Bind message

params_incomplete: bool

True if params couldn’t be fully decoded (cache miss)

normalized_query: Option<String>

Normalized query with placeholders (if anonymization enabled)

value_fingerprints: Option<Vec<String>>

Fingerprints of literal values (if anonymization enabled) Enables hot data detection while protecting PII

duration: Duration

Query execution duration

rows: Option<u64>

Number of rows affected/returned (if available)

success: bool

Whether the query succeeded

error: Option<String>

Error message if query failed

database: String

Database name

connection_id: String

Client connection ID

Trait Implementations

impl Clone for QueryEvent

fn clone(&self) -> QueryEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for QueryEvent

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for QueryEvent

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for QueryEvent

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

where __S: Serializer,

Serialize this value into the given Serde serializer.