Struct nakadion::consumer::Metrix

pub struct Metrix { /* fields omitted */ }

Instrumentation with Metrix

Methods

impl Metrix

pub fn new<A: AggregatesProcessors>(
    config: &MetrixConfig,
    processor: &mut A
) -> Self

Initializes the metrics.

Adds them directly into the given processor without creating an additional group.

pub fn new_mountable(
    config: &MetrixConfig,
    name: Option<&str>
) -> (Metrix, ProcessorMount)

Creates new Metrix instrumentation and returns a mount that can be plugged with metrix and the instrumentation which can be plugged into the Consumer

Trait Implementations

impl Clone for Metrix

fn clone(&self) -> Metrix

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Instruments for Metrix

fn consumer_batches_in_flight_inc(&self)

Triggered when a new batch with events was received

fn consumer_batches_in_flight_dec(&self)

Triggered when a batch with events was processed

fn consumer_batches_in_flight_dec_by(&self, by: usize)

Usually triggered when there are still batches in flight and the stream aborts.

fn stream_connect_attempt_success(&self, time: Duration)

Triggered when a single connect attempt for a stream was successful

fn stream_connect_attempt_failed(&self, time: Duration)

Triggered when a single connect attempt for a stream failed

fn stream_connected(&self, time: Duration)

Triggered when a stream was finally connect after maybe multiple attempts

fn stream_not_connected(&self, time: Duration)

Triggered when connecting to a stream finally failed after maybe multiple attempts

fn stream_chunk_received(&self, n_bytes: usize)

A chunk of data with n_bytes was received over the network

fn stream_frame_completed(&self, n_bytes: usize, time: Duration)

Chunks have been assembled to a complete frame containing all required data

fn stream_tick_emitted(&self)

An internal tick signal has been emitted

fn controller_batch_received(
    &self,
    frame_received_at: Instant,
    events_bytes: usize
)

The controller received a frame which contained events

fn controller_info_received(&self, frame_received_at: Instant)

The controller received a frame which contained info data

fn controller_keep_alive_received(&self, frame_received_at: Instant)

The controller received a frame which contained no events

fn controller_partition_activated(&self)

A partition which was formerly not known to be active was sent data on

fn controller_partition_deactivated(&self, active_for: Duration)

A partition did not receive data for some time is is therefore considered inactive.

fn controller_no_frames_warning(&self, no_frames_for: Duration)

No frames have been received for the given time and the warning has already threshold elapsed

fn controller_no_events_warning(&self, no_events_for: Duration)

No events have been received for the given time and the warning threshold has already elapsed

fn handler_batch_processed_1(&self, n_events: Option<usize>, time: Duration)

Events were processed.

fn handler_batch_processed_2(&self, frame_received_at: Instant, n_bytes: usize)

Events were processed.

fn handler_deserialization(&self, n_bytes: usize, time: Duration)

Events have been deserialized.

fn committer_cursor_received(&self, frame_received_at: Instant)

Cursors to be committed have reached the commit stage.

fn committer_cursors_committed(&self, n_cursors: usize, time: Duration)

Cursors were successfully committed.

fn committer_cursors_not_committed(&self, n_cursors: usize, time: Duration)

Cursors were not successfully committed.