Skip to main content

Metrics

Struct Metrics

pub struct Metrics {
    pub mcp_messages: AtomicU64,
    pub dcp_messages: AtomicU64,
    pub mcp_bytes: AtomicU64,
    pub dcp_bytes: AtomicU64,
    pub mcp_latency_us: AtomicU64,
    pub dcp_latency_us: AtomicU64,
    pub tool_invocations: AtomicU64,
    pub errors: AtomicU64,
}

Expand description

Performance metrics for protocol comparison

Fields§

§mcp_messages: AtomicU64

MCP message count

§dcp_messages: AtomicU64

DCP message count

§mcp_bytes: AtomicU64

MCP total bytes

§dcp_bytes: AtomicU64

DCP total bytes

§mcp_latency_us: AtomicU64

MCP total latency (microseconds)

§dcp_latency_us: AtomicU64

DCP total latency (microseconds)

§tool_invocations: AtomicU64

Tool invocation count

§errors: AtomicU64

Error count

Implementations§

impl Metrics

pub fn record_mcp(&self, bytes: u64, latency_us: u64)

Record an MCP message

pub fn record_dcp(&self, bytes: u64, latency_us: u64)

Record a DCP message

pub fn record_invocation(&self)

Record a tool invocation

pub fn record_error(&self)

Record an error

pub fn avg_mcp_latency_us(&self) -> u64

Get average MCP latency in microseconds

pub fn avg_dcp_latency_us(&self) -> u64

Get average DCP latency in microseconds

pub fn avg_mcp_size(&self) -> u64

Get average MCP message size

pub fn avg_dcp_size(&self) -> u64

Get average DCP message size

pub fn snapshot(&self) -> MetricsSnapshot

Get snapshot of all metrics

Trait Implementations§

impl Debug for Metrics

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

Formats the value using the given formatter. Read more

impl Default for Metrics

fn default() -> Metrics

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

Auto Trait Implementations§

impl !Freeze for Metrics

impl RefUnwindSafe for Metrics

impl Send for Metrics

impl Sync for Metrics

impl Unpin for Metrics

impl UnsafeUnpin for Metrics

impl UnwindSafe for Metrics

Blanket Implementations§

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

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more

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

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

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

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

Mutably borrows from an owned value. Read more

impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
where ST: ?Sized, DT: ?Sized,

impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
where ST: ?Sized, DT: ?Sized,

impl<T> From<T> for T

fn from(t: T) -> T

Returns the argument unchanged.

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

fn into(self) -> U

Calls U::from(self).

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

impl<T> Read<Exclusive, BecauseExclusive> for T
where T: ?Sized,

impl<T> Same for T

type Output = T

Should always be Self

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

type Error = Infallible

The type returned in the event of a conversion error.

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

Performs the conversion.

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

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

The type returned in the event of a conversion error.

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

Performs the conversion.

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

fn vzip(self) -> V