Skip to main content

ProfilingMetrics

Struct ProfilingMetrics 

Source
pub struct ProfilingMetrics {
Show 15 fields pub profiles_active: AtomicU64, pub profiles_total: AtomicU64, pub schemas_total: AtomicU64, pub profile_updates_total: AtomicU64, pub schema_violations_total: Arc<RwLock<HashMap<String, u64>>>, pub anomalies_detected: Arc<RwLock<HashMap<String, u64>>>, pub avg_anomaly_score: AtomicU64, pub requests_with_anomalies: AtomicU64, pub endpoint_stats: Arc<RwLock<HashMap<String, EndpointStats>>>, pub total_bytes_in: AtomicU64, pub total_bytes_out: AtomicU64, pub max_request_size: AtomicU64, pub max_response_size: AtomicU64, pub bandwidth_request_count: AtomicU64, pub bandwidth_timeline: Arc<RwLock<BandwidthTimeline>>,
}
Expand description

Profiling and anomaly detection metrics (Phase 2).

Fields§

§profiles_active: AtomicU64

Active endpoint profiles

§profiles_total: AtomicU64

Total profiles created (gauge)

§schemas_total: AtomicU64

Total schemas learned (gauge)

§profile_updates_total: AtomicU64

Total profile updates (counter)

§schema_violations_total: Arc<RwLock<HashMap<String, u64>>>

Schema violations by endpoint (counter vec)

§anomalies_detected: Arc<RwLock<HashMap<String, u64>>>

Anomalies detected by type

§avg_anomaly_score: AtomicU64

Average anomaly score

§requests_with_anomalies: AtomicU64

Requests with anomalies

§endpoint_stats: Arc<RwLock<HashMap<String, EndpointStats>>>

Per-endpoint statistics (path -> stats)

§total_bytes_in: AtomicU64

Bandwidth tracking: total bytes received (request bodies)

§total_bytes_out: AtomicU64

Bandwidth tracking: total bytes sent (response bodies)

§max_request_size: AtomicU64

Bandwidth tracking: max request size seen

§max_response_size: AtomicU64

Bandwidth tracking: max response size seen

§bandwidth_request_count: AtomicU64

Bandwidth tracking: request count for averaging

§bandwidth_timeline: Arc<RwLock<BandwidthTimeline>>

Bandwidth timeline (circular buffer, 60 data points for last hour)

Implementations§

Source§

impl ProfilingMetrics

Source

pub fn set_active_profiles(&self, count: u64)

Update active profiles count.

Source

pub fn set_profiles_total(&self, count: u64)

Update total profiles count (gauge).

Source

pub fn set_schemas_total(&self, count: u64)

Update total schemas count (gauge).

Source

pub fn record_profile_update(&self)

Increment profile updates counter.

Source

pub fn record_schema_violation(&self, endpoint: &str)

Record a schema violation for a specific endpoint.

Source

pub fn get_schema_violations(&self) -> Vec<(String, u64)>

Get all schema violations by endpoint.

Source

pub fn record_anomaly(&self, anomaly_type: &str, score: f64)

Record an anomaly detection.

Source

pub fn record_endpoint(&self, path: &str, method: &str)

Record an endpoint hit for API profiling.

Source

pub fn get_endpoint_stats(&self) -> Vec<(String, EndpointStats)>

Get all endpoint statistics for the profiling API.

Source

pub fn record_request_bytes(&self, bytes: u64)

Record bandwidth for a request body.

Source

pub fn record_response_bytes(&self, bytes: u64)

Record bandwidth for a response body.

Source

pub fn get_bandwidth_stats(&self) -> BandwidthStats

Get bandwidth statistics for the API.

Source

pub fn reset(&self)

Reset all profiling metrics to initial state.

Trait Implementations§

Source§

impl Debug for ProfilingMetrics

Source§

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

Formats the value using the given formatter. Read more
Source§

impl Default for ProfilingMetrics

Source§

fn default() -> ProfilingMetrics

Returns the “default value” for a type. Read more

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> Downcast for T
where T: Any,

Source§

fn into_any(self: Box<T>) -> Box<dyn Any>

Convert Box<dyn Trait> (where Trait: Downcast) to Box<dyn Any>. Box<dyn Any> can then be further downcast into Box<ConcreteType> where ConcreteType implements Trait.
Source§

fn into_any_rc(self: Rc<T>) -> Rc<dyn Any>

Convert Rc<Trait> (where Trait: Downcast) to Rc<Any>. Rc<Any> can then be further downcast into Rc<ConcreteType> where ConcreteType implements Trait.
Source§

fn as_any(&self) -> &(dyn Any + 'static)

Convert &Trait (where Trait: Downcast) to &Any. This is needed since Rust cannot generate &Any’s vtable from &Trait’s.
Source§

fn as_any_mut(&mut self) -> &mut (dyn Any + 'static)

Convert &mut Trait (where Trait: Downcast) to &Any. This is needed since Rust cannot generate &mut Any’s vtable from &mut Trait’s.
Source§

impl<T> DowncastSync for T
where T: Any + Send + Sync,

Source§

fn into_any_arc(self: Arc<T>) -> Arc<dyn Any + Sync + Send>

Convert Arc<Trait> (where Trait: Downcast) to Arc<Any>. Arc<Any> can then be further downcast into Arc<ConcreteType> where ConcreteType implements Trait.
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> Instrument for T

Source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> IntoEither for T

Source§

fn into_either(self, into_left: bool) -> Either<Self, Self>

Converts self into a Left variant of Either<Self, Self> if into_left is true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
Source§

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

Converts self into a Left variant of Either<Self, Self> if into_left(&self) returns true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
Source§

impl<T> Pointable for T

Source§

const ALIGN: usize

The alignment of pointer.
Source§

type Init = T

The type for initializers.
Source§

unsafe fn init(init: <T as Pointable>::Init) -> usize

Initializes a with the given initializer. Read more
Source§

unsafe fn deref<'a>(ptr: usize) -> &'a T

Dereferences the given pointer. Read more
Source§

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

Mutably dereferences the given pointer. Read more
Source§

unsafe fn drop(ptr: usize)

Drops the object pointed to by the given pointer. Read more
Source§

impl<T> Same for T

Source§

type Output = T

Should always be Self
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

Source§

fn vzip(self) -> V

Source§

impl<T> WithSubscriber for T

Source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

impl<A, B, T> HttpServerConnExec<A, B> for T
where B: Body,