[−][src]Trait nakadion::instrumentation::Instruments
An interface on which Nakadion
exposes metrics
An implementor of this interface can be used with
Instrumentation::new
Required methods
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.
This is a correction for the inflight metrics.
fn stream_connect_attempt_success(&self, time: Duration)
Triggered when a single connect attempt for a stream was successful
time
is the time for the request
fn stream_connect_attempt_failed(&self, time: Duration)
Triggered when a single connect attempt for a stream failed
time
is the time for the request
fn stream_connected(&self, time: Duration)
Triggered when a stream was finally connect after maybe multiple attempts
time
is the time for the whole cycle until a connection was made
fn stream_not_connected(&self, time: Duration)
Triggered when connecting to a stream finally failed after maybe multiple attempts
time
is the time for the whole cycle until a connection attempts finally failed
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
)
&self,
frame_received_at: Instant,
events_bytes: usize
)
The controller received a frame which contained events
The time it took from receiving the first chunk until it reached the controller are passed along with the complete bytes of the frame
fn controller_info_received(&self, frame_received_at: Instant)
The controller received a frame which contained info data
The time it took from receiving the first chunk until it reached the controller are passed along with the complete bytes of the frame
fn controller_keep_alive_received(&self, frame_received_at: Instant)
The controller received a frame which contained no events
The time it took from receiving the first chunk until it reached the controller are passed along with the complete bytes of the frame
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.
The time the processing took for all events and the number of events are passed.
fn handler_batch_processed_2(&self, frame_received_at: Instant, n_bytes: usize)
Events were processed.
The bytes for all events and time elapsed from receiving the first chunk of the frame are passed.
fn handler_deserialization(&self, n_bytes: usize, time: Duration)
Events have been deserialized.
The amount of bytes deserialized and the time it took are passed.
fn committer_cursor_received(&self, frame_received_at: Instant)
Cursors to be committed have reached the commit stage.
The time it took from receiving the first chunk until it reached the commit stage are passed
fn committer_cursors_committed(&self, n_cursors: usize, time: Duration)
Cursors were successfully committed.
The time request took is passed
fn committer_cursors_not_committed(&self, n_cursors: usize, time: Duration)
Cursors were not successfully committed.
The time request took is passed
fn committer_commit_attempt_failed(&self, n_cursors: usize, time: Duration)
An attempt to commit cursors failed. There might still be a retry
The time request took is passed
Implementors
impl Instruments for Metrix
[src]
fn consumer_batches_in_flight_inc(&self)
[src]
fn consumer_batches_in_flight_dec(&self)
[src]
fn consumer_batches_in_flight_dec_by(&self, by: usize)
[src]
fn stream_connect_attempt_success(&self, time: Duration)
[src]
fn stream_connect_attempt_failed(&self, time: Duration)
[src]
fn stream_connected(&self, time: Duration)
[src]
fn stream_not_connected(&self, time: Duration)
[src]
fn stream_chunk_received(&self, n_bytes: usize)
[src]
fn stream_frame_completed(&self, n_bytes: usize, time: Duration)
[src]
fn stream_tick_emitted(&self)
[src]
fn controller_batch_received(
&self,
frame_received_at: Instant,
events_bytes: usize
)
[src]
&self,
frame_received_at: Instant,
events_bytes: usize
)
fn controller_info_received(&self, frame_received_at: Instant)
[src]
fn controller_keep_alive_received(&self, frame_received_at: Instant)
[src]
fn controller_partition_activated(&self)
[src]
fn controller_partition_deactivated(&self, active_for: Duration)
[src]
fn controller_no_frames_warning(&self, no_frames_for: Duration)
[src]
fn controller_no_events_warning(&self, no_events_for: Duration)
[src]
fn handler_batch_processed_1(&self, n_events: Option<usize>, time: Duration)
[src]
fn handler_batch_processed_2(&self, frame_received_at: Instant, n_bytes: usize)
[src]
fn handler_deserialization(&self, n_bytes: usize, time: Duration)
[src]
fn committer_cursor_received(&self, frame_received_at: Instant)
[src]
fn committer_cursors_committed(&self, n_cursors: usize, time: Duration)
[src]
fn committer_cursors_not_committed(&self, n_cursors: usize, time: Duration)
[src]
fn committer_commit_attempt_failed(&self, n_cursors: usize, time: Duration)
[src]
impl Instruments for Instrumentation
[src]
fn consumer_batches_in_flight_inc(&self)
[src]
fn consumer_batches_in_flight_dec(&self)
[src]
fn consumer_batches_in_flight_dec_by(&self, by: usize)
[src]
fn stream_connect_attempt_success(&self, time: Duration)
[src]
fn stream_connect_attempt_failed(&self, time: Duration)
[src]
fn stream_connected(&self, time: Duration)
[src]
fn stream_not_connected(&self, time: Duration)
[src]
fn stream_chunk_received(&self, n_bytes: usize)
[src]
fn stream_frame_completed(&self, n_bytes: usize, time: Duration)
[src]
fn stream_tick_emitted(&self)
[src]
fn controller_batch_received(
&self,
frame_received_at: Instant,
events_bytes: usize
)
[src]
&self,
frame_received_at: Instant,
events_bytes: usize
)