KafkaMetrics

mockforge_kafka::metrics

Struct KafkaMetrics

pub struct KafkaMetrics {Show 13 fields
    pub connections_total: AtomicU64,
    pub connections_active: AtomicU64,
    pub requests_total: AtomicU64,
    pub requests_by_api: HashMap<i16, AtomicU64>,
    pub responses_total: AtomicU64,
    pub messages_produced_total: AtomicU64,
    pub messages_consumed_total: AtomicU64,
    pub topics_created_total: AtomicU64,
    pub topics_deleted_total: AtomicU64,
    pub consumer_groups_total: AtomicU64,
    pub partitions_total: AtomicU64,
    pub request_latency_micros: AtomicU64,
    pub errors_total: AtomicU64,
}

Expand description

Metrics collector for Kafka broker operations

Fields§

§connections_total: AtomicU64

Total number of connections

§connections_active: AtomicU64

Active connections

§requests_total: AtomicU64

Total requests received

§requests_by_api: HashMap<i16, AtomicU64>

Requests by API key

§responses_total: AtomicU64

Total responses sent

§messages_produced_total: AtomicU64

Total messages produced

§messages_consumed_total: AtomicU64

Total messages consumed

§topics_created_total: AtomicU64

Total topics created

§topics_deleted_total: AtomicU64

Total topics deleted

§consumer_groups_total: AtomicU64

Total consumer groups

§partitions_total: AtomicU64

Total partitions

§request_latency_micros: AtomicU64

Request latency (in microseconds)

§errors_total: AtomicU64

Error responses

Implementations§

impl KafkaMetrics

pub fn new() -> Self

Create a new metrics collector

pub fn record_connection(&self)

Record a new connection

pub fn record_connection_closed(&self)

Record a connection closed

pub fn record_request(&self, api_key: i16)

Record a request

pub fn record_response(&self)

Record a response

pub fn record_messages_produced(&self, count: u64)

Record messages produced

pub fn record_messages_consumed(&self, count: u64)

Record messages consumed

pub fn record_topic_created(&self)

Record topic created

pub fn record_topic_deleted(&self)

Record topic deleted

pub fn record_consumer_group_created(&self)

Record consumer group created

pub fn record_partition_created(&self)

Record partition created

pub fn record_request_latency(&self, latency_micros: u64)

Record request latency

pub fn record_error(&self)

Record an error

pub fn snapshot(&self) -> MetricsSnapshot

Get metrics snapshot

Trait Implementations§

impl Debug for KafkaMetrics

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

Formats the value using the given formatter. Read more

impl Default for KafkaMetrics

fn default() -> Self

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

Auto Trait Implementations§

impl !Freeze for KafkaMetrics

impl RefUnwindSafe for KafkaMetrics

impl Send for KafkaMetrics

impl Sync for KafkaMetrics

impl Unpin for KafkaMetrics

impl UnwindSafe for KafkaMetrics

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<T> From<T> for T

fn from(t: T) -> T

Returns the argument unchanged.

impl<T> Instrument for T

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

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

fn in_current_span(self) -> Instrumented<Self>

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

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> Pointable for T

const ALIGN: usize

The alignment of pointer.

type Init = T

The type for initializers.

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

Initializes a with the given initializer. Read more

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

Dereferences the given pointer. Read more

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

Mutably dereferences the given pointer. Read more

unsafe fn drop(ptr: usize)

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

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

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow only if self and other return Action::Follow. Read more

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow if either self or other returns Action::Follow. Read more

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

impl<T> WithSubscriber for T

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

fn with_current_subscriber(self) -> WithDispatch<Self>

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

impl<T> ParallelSend for T